Documentation
¶
Index ¶
- Variables
- func NewBoundedSeriesIterator(it chunkenc.Iterator, mint, maxt int64) *boundedSeriesIterator
- func NewChunkSeriesMerger() storage.VerticalChunkSeriesMergeFunc
- func NewOverlapSplit(set storepb.SeriesSet) storepb.SeriesSet
- func NewSeriesSet(set storage.SeriesSet, f string, pushdownEnabled bool) storage.SeriesSet
Constants ¶
This section is empty.
Variables ¶
var PushdownMarker = labels.Label{Name: "__thanos_pushed_down", Value: "true"}
PushdownMarker is a label that gets attached on pushed down series so that the receiver would be able to handle them in potentially special way.
Functions ¶
func NewBoundedSeriesIterator ¶
func NewBoundedSeriesIterator(it chunkenc.Iterator, mint, maxt int64) *boundedSeriesIterator
func NewChunkSeriesMerger ¶ added in v0.22.0
func NewChunkSeriesMerger() storage.VerticalChunkSeriesMergeFunc
NewChunkSeriesMerger merges several chunk series into one. Deduplication is based on penalty based deduplication algorithm without handling counter reset.
func NewOverlapSplit ¶ added in v0.31.0
func NewOverlapSplit(set storepb.SeriesSet) storepb.SeriesSet
NewOverlapSplit splits overlapping chunks into separate series entry, so existing algorithm can work as usual. We cannot do this in dedup.SeriesSet as it iterates over samples already. TODO(bwplotka): Remove when we move to per chunk deduplication code. We expect non-duplicated series with sorted chunks by min time (possibly overlapped).
func NewSeriesSet ¶
func NewSeriesSet(set storage.SeriesSet, f string, pushdownEnabled bool) storage.SeriesSet
NewSeriesSet returns seriesSet that deduplicates the same series. The series in series set are expected be sorted by all labels.
Types ¶
This section is empty.
Source Files