harvester

type FileSource interface {
	LogSource
	Stat() (os.FileInfo, error)
	Continuable() bool // can we continue processing after EOF?
}

type FileStat struct {
	Fileinfo      os.FileInfo /* the file info */
	Return        chan int64  /* the harvester will send an event with its offset when it closes */
	LastIteration uint32      /* int number of the last iterations in which we saw this file */
}

type Harvester struct {
	Path             string /* the file path to harvest */
	ProspectorConfig config.ProspectorConfig
	Config           *config.HarvesterConfig
	Offset           int64
	Stat             *FileStat
	SpoolerChan      chan *input.FileEvent
	// contains filtered or unexported fields
}

type LogSource interface {
	io.ReadCloser
	Name() string
}

type Typer interface {
	// contains filtered or unexported methods
}