NewGenericChunkMergeIterator returns a chunkenc.Iterator that merges generic chunks together.
(it chunkenc.Iterator, chunks []GenericChunk)
| 63 | |
| 64 | // NewGenericChunkMergeIterator returns a chunkenc.Iterator that merges generic chunks together. |
| 65 | func NewGenericChunkMergeIterator(it chunkenc.Iterator, chunks []GenericChunk) chunkenc.Iterator { |
| 66 | |
| 67 | var underlying iterator |
| 68 | |
| 69 | if ia, ok := it.(*iteratorAdapter); ok { |
| 70 | underlying = ia.underlying |
| 71 | } |
| 72 | |
| 73 | iter := newMergeIterator(underlying, chunks) |
| 74 | return newIteratorAdapter(iter) |
| 75 | } |
| 76 | |
| 77 | // iteratorAdapter turns a batchIterator into a chunkenc.Iterator. |
| 78 | // It fetches ever increasing batchSizes (up to promchunk.BatchSize) on each |
no test coverage detected