stream

Documentation

Index

• func Parse(req *http.Request, callback func(rows []opentsdbhttp.Row) error) error

Functions

func Parse

func Parse(req *http.Request, callback func(rows []opentsdbhttp.Row) error) error

Parse parses OpenTSDB http lines from req and calls callback for the parsed rows.

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

callback shouldn't hold rows after returning.