batch

Documentation

Index

• func NewChunkMergeIterator(it chunkenc.Iterator, lbls labels.Labels, chunks []chunk.Chunk) chunkenc.Iterator
• func NewGenericChunkMergeIterator(it chunkenc.Iterator, lbls labels.Labels, chunks []GenericChunk) chunkenc.Iterator
• type GenericChunk
  • func NewGenericChunk(minTime, maxTime int64, iterator func(reuse chunk.Iterator) chunk.Iterator) GenericChunk
  • func (c GenericChunk) Iterator(reuse chunk.Iterator) chunk.Iterator

Functions

func NewChunkMergeIterator

func NewChunkMergeIterator(it chunkenc.Iterator, lbls labels.Labels, chunks []chunk.Chunk) chunkenc.Iterator

NewChunkMergeIterator returns a chunkenc.Iterator that merges Mimir chunks together.

func NewGenericChunkMergeIterator

func NewGenericChunkMergeIterator(it chunkenc.Iterator, lbls labels.Labels, chunks []GenericChunk) chunkenc.Iterator

NewGenericChunkMergeIterator returns a chunkenc.Iterator that merges generic chunks together.

Types

type GenericChunk

type GenericChunk struct {
	MinTime int64
	MaxTime int64
	// contains filtered or unexported fields
}

GenericChunk is a generic chunk used by the batch iterator, in order to make the batch iterator general purpose.

func NewGenericChunk

func NewGenericChunk(minTime, maxTime int64, iterator func(reuse chunk.Iterator) chunk.Iterator) GenericChunk

func (GenericChunk) Iterator

func (c GenericChunk) Iterator(reuse chunk.Iterator) chunk.Iterator