(line LogLine)
| 32 | } |
| 33 | |
| 34 | func (p *JSONParser) ReadLine(line LogLine) error { |
| 35 | row, err := p.reader.ReadSlice('\n') |
| 36 | if err != nil && len(row) == 0 { |
| 37 | return err |
| 38 | } |
| 39 | if len(row) > 0 && row[len(row)-1] == '\n' { |
| 40 | row = row[:len(row)-1] |
| 41 | } |
| 42 | return p.Parse(row, line) |
| 43 | } |
| 44 | |
| 45 | func (p *JSONParser) Parse(row []byte, line LogLine) error { |
| 46 | val, err := p.parser.ParseBytes(row) |