Function NewChunkMergeIterator

pkg/querier/batch/batch.go:55–62

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

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

// NewChunkMergeIterator returns a chunkenc.Iterator that merges Cortex chunks together.
func NewChunkMergeIterator(it chunkenc.Iterator, chunks []chunk.Chunk, _, _ model.Time) chunkenc.Iterator {
	converted := make([]GenericChunk, len(chunks))
	for i, c := range chunks {
		converted[i] = NewGenericChunk(int64(c.From), int64(c.Through), c.NewIterator)
	}

	return NewGenericChunkMergeIterator(it, converted)
}

// NewGenericChunkMergeIterator returns a chunkenc.Iterator that merges generic chunks together.
func NewGenericChunkMergeIterator(it chunkenc.Iterator, chunks []GenericChunk) chunkenc.Iterator {