parser

type Parsed struct {
	Message  map[string]interface{}
	LogEvent *datasource.LogEvent
}

type Parser interface {
	Parse(context.Context, <-chan *datasource.LogEvent) <-chan *Parsed
	ParseLogEvent(*datasource.LogEvent) ([]*Parsed, error)
	NewFakeLogEvent() (*datasource.LogEvent, error)
	Err() error
}