file

Oct 5, 2021

Changes in this version

+ type Finder struct

+ Exclude []string

+ Include []string

+ func (f Finder) FindFiles() []string

Jul 27, 2021

Changes in this version

type InputConfig

+ Splitter helper.SplitterConfig

type InputOperator

+ Splitter helper.SplitterConfig

type Reader

+ func (r *Reader) Read(dst []byte) (int, error)

Jun 22, 2021

Changes in this version

type InputConfig

+ IncludeFileNameResolved bool

+ IncludeFilePathResolved bool

type InputOperator

+ FileNameResolvedField entry.Field

+ FilePathResolvedField entry.Field

type Reader

+ func (f *Reader) Close()

Feb 2, 2021

Changes in this version

+ func NewLineEndSplitFunc(re *regexp.Regexp) bufio.SplitFunc

+ func NewLineStartSplitFunc(re *regexp.Regexp) bufio.SplitFunc

+ func NewNewlineSplitFunc(encoding encoding.Encoding) (bufio.SplitFunc, error)

+ type Fingerprint struct

+ FirstBytes []byte

+ func (f Fingerprint) Copy() *Fingerprint

+ func (f Fingerprint) StartsWith(old *Fingerprint) bool

+ type FingerprintUpdatingReader struct

+ func NewFingerprintUpdatingReader(r io.Reader, offset int64, f *Fingerprint, fingerprintSize int) *FingerprintUpdatingReader

+ func (f *FingerprintUpdatingReader) Read(dst []byte) (int, error)

+ type InputConfig struct

+ Encoding string

+ Exclude []string

+ FingerprintSize helper.ByteSize

+ Include []string

+ IncludeFileName bool

+ IncludeFilePath bool

+ MaxConcurrentFiles int

+ MaxLogSize helper.ByteSize

+ Multiline *MultilineConfig

+ PollInterval helper.Duration

+ StartAt string

+ func NewInputConfig(operatorID string) *InputConfig

+ func (c InputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

+ type InputOperator struct

+ Exclude []string

+ FileNameField entry.Field

+ FilePathField entry.Field

+ Include []string

+ MaxConcurrentFiles int

+ MaxLogSize int

+ PollInterval time.Duration

+ SeenPaths map[string]struct{}

+ SplitFunc bufio.SplitFunc

+ func (f *InputOperator) NewFingerprint(file *os.File) (*Fingerprint, error)

+ func (f *InputOperator) NewReader(path string, file *os.File, fp *Fingerprint) (*Reader, error)

+ func (f *InputOperator) Start() error

+ func (f *InputOperator) Stop() error

+ type MultilineConfig struct

+ LineEndPattern string

+ LineStartPattern string

+ type PositionalScanner struct

+ func NewPositionalScanner(r io.Reader, maxLogSize int, startOffset int64, splitFunc bufio.SplitFunc) *PositionalScanner

+ func (ps *PositionalScanner) Pos() int64

+ type Reader struct

+ Fingerprint *Fingerprint

+ Offset int64

+ Path string

+ func (f *Reader) Copy(file *os.File) (*Reader, error)

+ func (f *Reader) InitializeOffset(startAtBeginning bool) error

+ func (f *Reader) ReadToEnd(ctx context.Context)