shipper

type ErrorBehaviour int

type LineHandler interface {
	HandleLine(line string)
}

type LogShipper struct {
	APIClient           *api.Client
	URL                 string
	Fields              map[string]string
	ParserName          string
	MaxAttemptsPerBatch int
	ErrorBehaviour      ErrorBehaviour
	BatchSizeLines      int
	BatchSizeBytes      int
	BatchTimeout        time.Duration
	Logger              func(format string, v ...interface{})
	// contains filtered or unexported fields
}

type MultiLineHandler struct {
	LineHandler LineHandler
	Regex       *regexp.Regexp
	Mode        MultiLineHandlerMode
	// contains filtered or unexported fields
}

type MultiLineHandlerMode int