harvester

Documentation

Index

• Constants
• type Config
• type Harvester
  • func NewHarvester(path string, offset int64) (*Harvester, error)
  • func (h *Harvester) Close() error
  • func (h *Harvester) NewJsonFileReader(pattern string, showLineNumber bool) (reader.Reader, error)
  • func (h *Harvester) NewLogFileReader(pattern string, showLineNumber bool) (reader.Reader, error)

Constants

const (
	Byte = 1 << (iota * 10)
	KiByte
	MiByte
	GiByte
	TiByte
	PiByte
	EiByte
)

Types

type Config

type Config struct {
	Encoding       string                  `config:"encoding"`
	BufferSize     int                     `config:"harvester_buffer_size"`
	MaxBytes       int                     `config:"max_bytes" validate:"min=0,nonzero"`
	LineTerminator readfile.LineTerminator `config:"line_terminator"`
	JSON           *readjson.Config        `config:"json"`
	Multiline      *multiline.Config       `config:"multiline"`
	LineNumber     *linenumber.Config
}

type Harvester

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

func NewHarvester

func NewHarvester(path string, offset int64) (*Harvester, error)

func (*Harvester) Close

func (h *Harvester) Close() error

func (*Harvester) NewJsonFileReader

func (h *Harvester) NewJsonFileReader(pattern string, showLineNumber bool) (reader.Reader, error)

func (*Harvester) NewLogFileReader

func (h *Harvester) NewLogFileReader(pattern string, showLineNumber bool) (reader.Reader, error)