stream

Documentation

Index

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

Functions

func Parse

func Parse(r io.Reader, defaultTimestamp int64, isGzipped, limitConcurrency 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.

limitConcurrency defines whether to control the number of concurrent calls to this function. It is recommended setting limitConcurrency=true if the caller doesn't have concurrency limits set, like /api/v1/write calls.