stream

Documentation

Index

• func ParseStream(r io.Reader, isGzipped bool, processBody func([]byte) ([]byte, error), ...) error

Functions

func ParseStream

func ParseStream(r io.Reader, isGzipped bool, processBody func([]byte) ([]byte, error), callback func(tss []prompbmarshal.TimeSeries) 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.