native

Documentation

Index

• func ParseStream(req *http.Request, callback func(block *Block) error) error
• type Block

Functions

func ParseStream

func ParseStream(req *http.Request, 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 req.

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.