engine

Jul 2, 2026

Changes in this version

type Config

+ DecodeBudget *DecodeBudget

+ type DecodeBudget struct

+ func NewDecodeBudget(maxBytes int64) *DecodeBudget

type Engine

+ func (e *Engine) CountBy(ctx context.Context, r fetch.Request, label []byte) (map[string]int, error)

Jul 1, 2026

Changes in this version

type Config

+ DecodeMemoryBytes int64

Jun 30, 2026

Changes in this version

+ const DefaultMetricBlockRows

type Config

+ MetricBlockRows int

Jun 29, 2026

Changes in this version

type Engine

+ func (e *Engine) Count(ctx context.Context, r fetch.Request) (int, error)

Jun 29, 2026

Changes in this version

type Config

+ RecentWindow int64

Jun 28, 2026

Changes in this version

+ type CardinalityStat struct

+ DistinctLabelNames int

+ SymbolCount int

+ Top []LabelCard

+ TotalSeries int64

+ type ColumnStat struct

+ Codec string

+ Compress string

+ Kind string

+ Name string

type Engine

+ func (e *Engine) Cardinality(topN int) CardinalityStat

+ func (e *Engine) MergeBacklog() int

+ func (e *Engine) MergeRunning() bool

+ func (e *Engine) Parts() []PartStat

+ func (e *Engine) PartsDetailed(ctx context.Context) ([]PartDetailStat, error)

+ func (e *Engine) WALState() (segments int, bytes int64, epoch uint64, ok bool)

+ type LabelCard struct

+ DistinctValues int

+ Name string

+ Series int64

+ type PartDetailStat struct

+ Bytes int64

+ Chunks int

+ Columns []ColumnStat

+ type PartStat struct

+ ID string

+ MaxTime int64

+ MinTime int64

+ Rows int64

+ Series int

Jun 27, 2026

Changes in this version

type AppendLimits

+ MaxSeriesSoft int64

+ Overflow func(s signal.Series) signal.Series

type AppendResult

+ Overflowed int

type Config

+ MaxPartBytes int64

type Engine

+ func (e *Engine) Stats() Stats

+ type Stats struct

+ HeadBytes int64

+ HeadSamples int64

+ MaxTime int64

+ MinTime int64

+ Parts int

+ Series int64

Jun 27, 2026

Changes in this version

type Engine

+ func (e *Engine) AggregateStepNamed(ctx context.Context, r fetch.Request, step int64) ([]NamedAgg, error)

+ type NamedAgg struct

+ Buckets []BucketAgg

+ Series signal.Series

Jun 27, 2026

Changes in this version

+ type BucketAgg struct

+ Start int64

type Config

+ AggregateStats bool

+ DecodeCacheBytes int64

+ type DecodeCacheStats struct

+ Bytes int64

+ Hits int64

+ Items int

+ Misses int64

type Engine

+ func (e *Engine) AggregateRange(ctx context.Context, r fetch.Request) (map[signal.SeriesID]SeriesAgg, error)

+ func (e *Engine) AggregateStep(ctx context.Context, r fetch.Request, step int64) (map[signal.SeriesID][]BucketAgg, error)

+ func (e *Engine) DecodeCacheStats() (DecodeCacheStats, bool)

type MergeOptions

+ Precision []PrecisionTier

+ type PrecisionTier struct

+ Before int64

+ Bits uint8

+ type SeriesAgg struct

+ Count int64

+ Max float64

+ Min float64

+ Sum float64

Jun 27, 2026

Changes in this version

type Config

+ Obs *obs.Obs

Jun 26, 2026

Changes in this version

+ const SampleBytes

+ type AppendLimits struct

+ MaxInFlightBytes int64

+ MaxSeries int64

+ type AppendResult struct

+ Accepted int

+ RejectedBytes int

+ RejectedCardinality int

+ RejectedOOO int

+ func (r AppendResult) Rejected() int

+ type DownsampleTier struct

+ Agg signal.Aggregation

+ Before int64

+ Interval int64

type Engine

+ func (e *Engine) CloseWAL() error

+ func (e *Engine) HeadBytes() int64

+ func (e *Engine) MergeWith(ctx context.Context, opts MergeOptions) error

+ type MergeOptions struct

+ Downsample []DownsampleTier

+ Recompress *RecompressSpec

+ RetainFrom int64

+ type RecompressSpec struct

+ Algorithm compress.Algorithm

+ Before int64

+ Level compress.Level

Jun 26, 2026

Changes in this version

type Engine

+ func (e *Engine) SyncWAL() error

Jun 26, 2026

Changes in this version

type Engine

+ func (e *Engine) ApplyPrimary(data []byte) (accepted []byte, rejected int, err error)

Jun 26, 2026

Changes in this version

+ type Config struct

+ Backend backend.Backend

+ OOOWindow int64

+ Prefix string

+ WAL *wal.SegmentWriter

+ type Engine struct

+ func New(cfg Config) *Engine

+ func (e *Engine) Append(s signal.Series, ts int64, value float64) (bool, error)

+ func (e *Engine) AppendBatch(ids []signal.SeriesID, ts []int64, values []float64, ...) (accepted int, err error)

+ func (e *Engine) ApplyReplicated(data []byte) (rejected int, err error)

+ func (e *Engine) Close(ctx context.Context) error

+ func (e *Engine) Fetch(ctx context.Context, r fetch.Request) (fetch.Iterator, error)

+ func (e *Engine) Flush(ctx context.Context) error

+ func (e *Engine) HeadSampleCount() int

+ func (e *Engine) LoadParts(ctx context.Context) error

+ func (e *Engine) Merge(ctx context.Context, retainFrom int64) error

+ func (e *Engine) PartCount() int

+ func (e *Engine) RefreshReplica(ctx context.Context) error

+ func (e *Engine) Replay(dir string) error

+ func (e *Engine) Reset(ctx context.Context) error

+ func (e *Engine) SeriesCount() int