metricsdata

Nov 21, 2022

Changes in this version

+ var MetricDataMerger kv.MergerType = "MetricDataMerger"

+ func NewMerger(flusher kv.Flusher) (kv.Merger, error)

+ type FieldReader interface

+ Close func()

+ GetFieldData func(fieldID field.ID) []byte

+ Reset func(seriesEntry []byte, slotRange timeutil.SlotRange)

+ SlotRange func() timeutil.SlotRange

+ type Filter interface

+ Filter func(seriesIDs *roaring.Bitmap, fields field.Metas) ([]flow.FilterResultSet, error)

+ func NewFilter(familyTime int64, snapshot version.Snapshot, readers []MetricReader) Filter

+ type Flusher interface

+ CommitMetric func(slotRange timeutil.SlotRange) error

+ FlushField func(data []byte) error

+ FlushSeries func(seriesID uint32) error

+ GetEncoder func(fieldIdx int) *encoding.TSDEncoder

+ GetFieldMetas func() field.Metas

+ PrepareMetric func(metricID uint32, fieldMetas field.Metas)

+ func NewFlusher(kvFlusher kv.Flusher) (Flusher, error)

+ type MetricReader interface

+ GetFields func() field.Metas

+ GetSeriesIDs func() *roaring.Bitmap

+ GetTimeRange func() timeutil.SlotRange

+ Load func(ctx *flow.DataLoadContext) flow.DataLoader

+ Path func() string

+ func NewReader(path string, metricBlock []byte) (MetricReader, error)

+ type SeriesMerger interface