tracker

Documentation

Index

• type Tracker
  • func NewFileTracker(logger *zap.SugaredLogger, maxBatchFiles int) Tracker
  • func NewNoStateTracker(logger *zap.SugaredLogger, maxBatchFiles int) Tracker

Types

type Tracker

type Tracker interface {
	Add(reader *reader.Reader)
	GetCurrentFile(fp *fingerprint.Fingerprint) *reader.Reader
	GetOpenFile(fp *fingerprint.Fingerprint) *reader.Reader
	GetClosedFile(fp *fingerprint.Fingerprint) *reader.Metadata
	GetMetadata() []*reader.Metadata
	LoadMetadata(metadata []*reader.Metadata)
	CurrentPollFiles() []*reader.Reader
	PreviousPollFiles() []*reader.Reader
	ClosePreviousFiles()
	EndPoll()
	EndConsume()
	TotalReaders() int
}

Interface for tracking files that are being consumed.

func NewFileTracker

func NewFileTracker(logger *zap.SugaredLogger, maxBatchFiles int) Tracker

func NewNoStateTracker

func NewNoStateTracker(logger *zap.SugaredLogger, maxBatchFiles int) Tracker