engine

package

Go to main page

Versions in this module

v0

v0.40.1

Aug 22, 2026

v0.40.0

Aug 21, 2026

Changes in this version

type Config

+ MinFreeBytes int64

+ MinFreeInodes int64

+ Term func() uint64

+ WriterID string

type Stats

+ OutOfSpace bool

v0.39.0

Aug 17, 2026

v0.38.0

Aug 17, 2026

v0.37.2

Aug 15, 2026

v0.37.1

Aug 15, 2026

v0.37.0

Aug 15, 2026

Changes in this version

+ const DefaultDecodeBudgetForceAfter

type ColumnStat

+ Level int

type Config

+ MergeCeilingBytes int64

+ MergeConcurrency func() int

+ MergeMemoryBytes int64

type Engine

+ func (e *Engine) IdentityBytes() int64

+ func (e *Engine) LabelNames(ctx context.Context, r fetch.Request) ([]string, error)

+ func (e *Engine) LabelValues(ctx context.Context, r fetch.Request, name []byte) ([]string, error)

+ func (e *Engine) MergeShape() MergeShape

+ func (e *Engine) PruneIdentities(ctx context.Context) (int, error)

+ func (e *Engine) PruneIdentitiesWith(ctx context.Context, opts PruneOptions) (int, error)

+ func (e *Engine) Series(ctx context.Context, r fetch.Request) ([]signal.Series, error)

type MergeOptions

+ Force bool

+ type MergeShape struct

+ Backlog int

+ BestMultiplier float64

+ Candidates int

+ CapBytes int64

+ IdleRounds int

+ MinMultiplier float64

+ Parts int

+ Sealed int

+ WaiveAfter int

type PartStat

+ SizeBytes int64

+ type PruneOptions struct

+ Force bool

type Stats

+ IdentityBytes int64

v0.36.0

Jul 28, 2026

Changes in this version

type Engine

+ func (e *Engine) AggregateWindow(ctx context.Context, r fetch.Request, spec WindowSpec) (map[signal.SeriesID][]WindowAgg, error)

+ func (e *Engine) AggregateWindowNamed(ctx context.Context, r fetch.Request, spec WindowSpec) ([]NamedWindowAgg, error)

+ type NamedWindowAgg struct

+ Series signal.Series

+ Windows []WindowAgg

+ type WindowAgg struct

+ End int64

+ type WindowSpec struct

+ Anchor int64

+ Step int64

+ Window int64

v0.35.0

Jul 28, 2026

v0.34.0

Jul 27, 2026

v0.33.0

Jul 25, 2026

v0.32.0

Jul 21, 2026

v0.31.2

Jul 18, 2026

v0.31.1

Jul 18, 2026

v0.31.0

Jul 18, 2026

v0.30.0

Jul 17, 2026

v0.29.0

Jul 17, 2026

v0.28.0

Jul 2, 2026

v0.27.0

Jul 2, 2026

v0.26.0

Jul 2, 2026

v0.25.0

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)

v0.24.0

Jul 1, 2026

v0.23.0

Jul 1, 2026

v0.22.0

Jul 1, 2026

v0.21.0

Jul 1, 2026

Changes in this version

type Config

+ DecodeMemoryBytes int64

v0.20.0

Jun 30, 2026

Changes in this version

+ const DefaultMetricBlockRows

type Config

+ MetricBlockRows int

v0.19.0

Jun 30, 2026

v0.18.0

Jun 29, 2026

v0.17.0

Jun 29, 2026

Changes in this version

type Engine

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

v0.16.0

Jun 29, 2026

v0.15.0

Jun 29, 2026

Changes in this version

type Config

+ RecentWindow int64

v0.14.0

Jun 28, 2026

v0.13.0

Jun 28, 2026

v0.12.0

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

v0.11.0

Jun 28, 2026

v0.10.0

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

v0.9.0

Jun 27, 2026

v0.8.0

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

v0.7.0

Jun 27, 2026

v0.6.0

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

v0.5.0

Jun 27, 2026

Changes in this version

type Config

+ Obs *obs.Obs

v0.4.0

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

v0.3.0

Jun 26, 2026

Changes in this version

type Engine

+ func (e *Engine) SyncWAL() error

v0.2.0

Jun 26, 2026

Changes in this version

type Engine

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

v0.1.0

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

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