shipper

Jan 11, 2021

Changes in this version

+ type ErrorBehaviour int

+ const ErrorBehaviourDrop

+ const ErrorBehaviourPanic

+ type LineHandler interface

+ HandleLine func(line string)

+ type LogShipper struct

+ APIClient *api.Client

+ BatchSizeBytes int

+ BatchSizeLines int

+ BatchTimeout time.Duration

+ ErrorBehaviour ErrorBehaviour

+ Fields map[string]string

+ Logger func(format string, v ...interface{})

+ MaxAttemptsPerBatch int

+ ParserName string

+ URL string

+ func (s *LogShipper) Finish()

+ func (s *LogShipper) HandleLine(line string)

+ func (s *LogShipper) Start()

+ type MultiLineHandler struct

+ LineHandler LineHandler

+ Mode MultiLineHandlerMode

+ Regex *regexp.Regexp

+ func (h *MultiLineHandler) HandleLine(line string)

+ type MultiLineHandlerMode int

+ const MultiLineHandlerModeBeginsWith

+ const MultiLineHandlerModeContinuesWith