stream

func ParseStream ¶

func ParseStream(r io.Reader, encoding string, processBody func(data []byte) ([]byte, error), callback func(tss []prompb.TimeSeries, mms []prompb.MetricMetadata) error) error

ParseStream parses OpenTelemetry protobuf or json data from r and calls callback for the parsed rows.

callback shouldn't hold tss items after returning.

optional processBody can be used for pre-processing the read request body from r before parsing it in OpenTelemetry format.