stream

Documentation

Index

• func Parse(r io.Reader, isGzip bool, callback func(block *Block) error) error
• type Block

Functions

func Parse

func Parse(r io.Reader, isGzip bool, callback func(block *Block) error) error

Parse parses /api/v1/import/native lines from req and calls callback for parsed blocks.

The callback can be called concurrently multiple times for streamed data from r.

callback shouldn't hold block after returning.

Types

type Block

type Block struct {
	MetricName storage.MetricName
	Values     []float64
	Timestamps []int64
}

Block is a single block from `/api/v1/import/native` request.