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. The callback can be called after ParseStream returns.

callback shouldn't hold block after returning. callback can be called in parallel from multiple concurrent goroutines.

Types

type Block

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

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