native

Documentation

Index

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

Functions

func ParseStream

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

ParseStream 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.