batch

Documentation

Index

• func NewChunkMergeIterator(chunks []chunk.Chunk, _, _ model.Time) chunkenc.Iterator
• func NewGenericChunkMergeIterator(chunks []GenericChunk) chunkenc.Iterator
• type GenericChunk
  • func NewGenericChunk(minTime, maxTime int64, ...) GenericChunk
  • func (c GenericChunk) Iterator(reuse encoding.Iterator) encoding.Iterator

Functions

func NewChunkMergeIterator

func NewChunkMergeIterator(chunks []chunk.Chunk, _, _ model.Time) chunkenc.Iterator

NewChunkMergeIterator returns a storage.SeriesIterator that merges Cortex chunks together.

func NewGenericChunkMergeIterator

func NewGenericChunkMergeIterator(chunks []GenericChunk) chunkenc.Iterator

NewGenericChunkMergeIterator returns a storage.SeriesIterator 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 encoding.Iterator) encoding.Iterator) GenericChunk

func (GenericChunk) Iterator

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