NewLogLine creates a LogLine baker input.
(cfg baker.InputParams)
| 24 | |
| 25 | // NewLogLine creates a LogLine baker input. |
| 26 | func NewLogLine(cfg baker.InputParams) (baker.Input, error) { |
| 27 | if cfg.DecodedConfig == nil { |
| 28 | cfg.DecodedConfig = &LogLineConfig{} |
| 29 | } |
| 30 | dcfg := cfg.DecodedConfig.(*LogLineConfig) |
| 31 | return &LogLine{ |
| 32 | LogLineConfig: *dcfg, |
| 33 | }, nil |
| 34 | } |
| 35 | |
| 36 | func (in *LogLine) Run(output chan<- *baker.Data) error { |
| 37 | var buf []byte |
nothing calls this directly
no outgoing calls
no test coverage detected