本文整理汇总了Golang中github.com/elastic/beats/filebeat/harvester.Harvester类的典型用法代码示例。如果您正苦于以下问题:Golang Harvester类的具体用法?Golang Harvester怎么用?Golang Harvester使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Harvester类的3个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: checkExistingFile
// checkExistingFile checks if a harvester has to be started for a already known file
// For existing files the following options exist:
// * Last reading position is 0, no harvester has to be started as old harvester probably still busy
// * The old known modification time is older then the current one. Start at last known position
// * The new file is not the same as the old file, means file was renamed
// ** New file is actually really a new file, start a new harvester
// ** Renamed file has a state, continue there
func (p ProspectorLog) checkExistingFile(h *harvester.Harvester, newFile *input.File, oldFile *input.File) {
logp.Debug("prospector", "Update existing file for harvesting: %s", h.Path)
// We assume it is the same file, but it wasn't
if !oldFile.IsSameFile(newFile) {
logp.Debug("prospector", "File previously found: %s", h.Path)
if previousFile, err := p.getPreviousFile(h.Path, h.Stat.Fileinfo); err == nil {
p.continueExistingFile(h, previousFile)
} else {
// File is not the same file we saw previously, it must have rotated and is a new file
logp.Debug("prospector", "Launching harvester on rotated file: %s", h.Path)
// Forget about the previous harvester and let it continue on the old file - so start a new channel to use with the new harvester
h.Stat.Ignore()
// Start a new harvester on the path
h.Start()
}
// Keep the old file in missingFiles so we don't rescan it if it was renamed and we've not yet reached the new filename
// We only need to keep it for the remainder of this iteration then we can assume it was deleted and forget about it
p.missingFiles[h.Path] = oldFile.FileInfo
} else if h.Stat.Finished() && oldFile.FileInfo.ModTime() != h.Stat.Fileinfo.ModTime() {
// Resume harvesting of an old file we've stopped harvesting from
// Start a harvester on the path; a file was just modified and it doesn't have a harvester
// The offset to continue from will be stored in the harvester channel - so take that to use and also clear the channel
p.resumeHarvesting(h, <-h.Stat.Return)
} else {
logp.Debug("prospector", "Not harvesting, file didn't change: %s", h.Path)
}
}
开发者ID:jarpy,项目名称:beats,代码行数:42,代码来源:prospector_log.go
示例2: continueExistingFile
// Continue reading on an existing file.
// The given file was renamed from another file we know -> The same harvester channel is linked as the old file
// The file param is only used for logging
func (p *ProspectorLog) continueExistingFile(h *harvester.Harvester, previousFile string) {
logp.Debug("prospector", "Launching harvester on renamed file. File rename was detected: %s -> %s", previousFile, h.Path)
lastinfo := p.harvesterStats[previousFile]
h.Stat.Continue(&lastinfo)
// Update state because of file rotation
h.UpdateState()
}
开发者ID:yan2jared,项目名称:beats,代码行数:12,代码来源:prospector_log.go
示例3: resumeHarvesting
// Start / resume harvester with a predefined offset
func (p *ProspectorLog) resumeHarvesting(h *harvester.Harvester, offset int64) {
logp.Debug("prospector", "Start / resuming harvester of file: %s", h.Path)
h.SetOffset(offset)
h.Start()
}
开发者ID:yan2jared,项目名称:beats,代码行数:7,代码来源:prospector_log.go
注:本文中的github.com/elastic/beats/filebeat/harvester.Harvester类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论