filereader

Documentation

Index

• type FileReader
  • 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
  • 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

Types

type FileReader

type FileReader struct {
	// contains filtered or unexported fields
}

func NewFileReader

func NewFileReader(maxDuration time.Duration, fileName string, position int64) (*FileReader, error)

func (*FileReader) Close

func (r *FileReader) Close()

func (*FileReader) GetPosition

func (r *FileReader) GetPosition() (offset int64, err error)

func (*FileReader) ReadFile

func (r *FileReader) ReadFile(sendFunc SendFunc, watch bool) (position int64, err error)

func (*FileReader) ReadLine

func (r *FileReader) ReadLine() (line string, err error)

func (*FileReader) Reopen

func (r *FileReader) Reopen() (err error)

func (*FileReader) WaitForChanges

func (r *FileReader) WaitForChanges() (err error)

type Reader

type Reader struct {
	// contains filtered or unexported fields
}

func NewReader

func NewReader(ctx context.Context, l *zap.Logger, maxDuration, waitForNewFilesDuration time.Duration, fileNameRegexp, path string) (reader *Reader, err error)

func (*Reader) Close

func (r *Reader) Close()

func (*Reader) StartSendingFilesInQueue

func (r *Reader) StartSendingFilesInQueue(sendFunc SendFunc) error

type SendFunc

type SendFunc func(string)