Function NewJSONParser

src/go/plugin/go.d/pkg/logs/json.go:25–32

(config JSONConfig, in io.Reader)

}

func NewJSONParser(config JSONConfig, in io.Reader) (*JSONParser, error) {
	parser := &JSONParser{
		reader:  bufio.NewReader(in),
		mapping: config.Mapping,
		buf:     make([]byte, 0, 100),
	}
	return parser, nil
}

func (p *JSONParser) ReadLine(line LogLine) error {
	row, err := p.reader.ReadSlice('\n')