(output chan<- *baker.Data)
| 34 | } |
| 35 | |
| 36 | func (in *LogLine) Run(output chan<- *baker.Data) error { |
| 37 | var buf []byte |
| 38 | |
| 39 | // Send all lines via a single baker.Data blob. |
| 40 | for _, ll := range in.Lines { |
| 41 | buf = ll.ToText(buf) |
| 42 | buf = append(buf, '\n') |
| 43 | } |
| 44 | |
| 45 | output <- &baker.Data{Bytes: buf, Meta: in.Metadata} |
| 46 | |
| 47 | return nil |
| 48 | } |
| 49 | |
| 50 | func (in *LogLine) Stop() {} |
| 51 | func (in *LogLine) FreeMem(data *baker.Data) {} |