stream

Documentation

Index

• func Parse(r io.Reader, isGzipped bool, precision, db string, ...) error

Functions

func Parse

func Parse(r io.Reader, isGzipped bool, precision, db string, callback func(db string, rows []influx.Row) error) error

Parse parses r with the given args and calls callback for the parsed rows.

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

callback shouldn't hold rows after returning.