downsample

Feb 8, 2019

Changes in this version

+ func NewStreamedBlockWriter(blockDir string, indexReader tsdb.IndexReader, logger log.Logger, ...) (w *streamedBlockWriter, err error)

Sep 18, 2018

Changes in this version

+ const ChunkEncAggr

+ const ResLevel0

+ const ResLevel1

+ const ResLevel2

+ var ErrAggrNotExist = errors.New("aggregate does not exist")

+ func Downsample(logger log.Logger, origMeta *block.Meta, b tsdb.BlockReader, dir string, ...) (id ulid.ULID, err error)

+ func NewPool() chunkenc.Pool

+ type AggrChunk []byte

+ func EncodeAggrChunk(chks [5]chunkenc.Chunk) *AggrChunk

+ func (c AggrChunk) Appender() (chunkenc.Appender, error)

+ func (c AggrChunk) Bytes() []byte

+ func (c AggrChunk) Encoding() chunkenc.Encoding

+ func (c AggrChunk) Get(t AggrType) (chunkenc.Chunk, error)

+ func (c AggrChunk) Iterator() chunkenc.Iterator

+ func (c AggrChunk) NumSamples() int

+ type AggrType uint8

+ const AggrCount

+ const AggrCounter

+ const AggrMax

+ const AggrMin

+ const AggrSum

+ func (t AggrType) String() string

+ type AverageChunkIterator struct

+ func NewAverageChunkIterator(cnt, sum chunkenc.Iterator) *AverageChunkIterator

+ func (it *AverageChunkIterator) At() (int64, float64)

+ func (it *AverageChunkIterator) Err() error

+ func (it *AverageChunkIterator) Next() bool

+ type CounterSeriesIterator struct

+ func NewCounterSeriesIterator(chks ...chunkenc.Iterator) *CounterSeriesIterator

+ func (it *CounterSeriesIterator) At() (t int64, v float64)

+ func (it *CounterSeriesIterator) Err() error

+ func (it *CounterSeriesIterator) Next() bool

+ func (it *CounterSeriesIterator) Seek(x int64) bool