stream

Documentation

Index

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

Functions

func Parse

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

Parse parses Graphite lines from r 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.