stream

Documentation

Index

• func Parse(r io.Reader, isGzipped bool, callback func(rows []vmimport.Row) error) error

Functions

func Parse

func Parse(r io.Reader, isGzipped bool, callback func(rows []vmimport.Row) error) error

Parse parses /api/v1/import lines from req and calls callback for the parsed rows.

The callback can be called concurrently multiple times for streamed data from reader.

callback shouldn't hold rows after returning.