batch

package
v0.0.0-...-e3e1202 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 3, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewChunkMergeIterator

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

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

func NewGenericChunkMergeIterator

func NewGenericChunkMergeIterator(it chunkenc.Iterator, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL