Versions in this module Expand all Collapse all v0 v0.7.1 Dec 8, 2023 v0.7.0 Nov 3, 2023 Changes in this version + type FileReader struct + func NewFileReader(maxDuration time.Duration, fileName string, position int64) (*FileReader, error) + func (r *FileReader) Close() + func (r *FileReader) GetPosition() (offset int64, err error) + func (r *FileReader) ReadFile(sendFunc SendFunc, watch bool) (position int64, err error) + func (r *FileReader) ReadLine() (line string, err error) + func (r *FileReader) Reopen() (err error) + func (r *FileReader) WaitForChanges() (err error) + type Reader struct + func NewReader(ctx context.Context, l *zap.Logger, ...) (reader *Reader, err error) + func (r *Reader) Close() + func (r *Reader) StartSendingFilesInQueue(sendFunc SendFunc) error + type SendFunc func(string)