stream

Documentation

Index

• func Parse(r io.Reader, defaultTimestamp int64, isGzipped bool, ...) error

Functions

func Parse

func Parse(r io.Reader, defaultTimestamp int64, isGzipped bool, callback func(rows []prometheus.Row) error, errLogger func(string)) error

Parse parses lines with Prometheus exposition format 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.