recordengine

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 Engine

+ func (e *Engine) Stats() Stats

+ type Stats struct

+ HeadBytes int64

+ HeadRecords int64

+ MaxTime int64

+ MinTime int64

+ Parts int

+ Streams int64

Jun 27, 2026

Changes in this version

+ var ErrCorruptKeys = errors.New("recordengine: corrupt record-keys footer")

type Config

+ Obs *obs.Obs

+ Signal string

type Engine

+ func (e *Engine) Keys(start, end int64) []KeyInfo

+ type KeyInfo struct

+ Key []byte

+ Scope KeyScope

+ type KeyScope uint8

+ const KeyScopeRecord

+ const KeyScopeResource

+ const KeyScopeScope

Jun 26, 2026

Changes in this version

+ type AppendLimits struct

+ MaxInFlightBytes int64

+ MaxSeries int64

+ type AppendResult struct

+ Accepted int

+ RejectedBytes int

+ RejectedCardinality int

+ RejectedOOO int

+ func (r AppendResult) Rejected() int

type Batch

+ func (b *Batch) ByteSize() int64

type Engine

+ func (e *Engine) CloseWAL() error

+ func (e *Engine) HeadBytes() int64

Jun 26, 2026

Changes in this version

type Engine

+ func (e *Engine) SyncWAL() error

Jun 26, 2026

Changes in this version

+ func EncodeWAL(b *Batch) []byte

+ type Batch struct

+ Bytes [][][]byte

+ Identity func() signal.Series

+ Ints [][]int64

+ Side []byte

+ Stream signal.SeriesID

+ Ts []int64

+ func (b *Batch) Len() int

+ type BloomMode uint8

+ const BloomAttrs

+ const BloomEquality

+ const BloomFullText

+ const BloomNone

+ type Column struct

+ Bloom BloomMode

+ Codec chunk.Codec

+ Kind Kind

+ Name string

+ type Config struct

+ Backend backend.Backend

+ OOOWindow int64

+ Prefix string

+ Schema *Schema

+ SideStore SideStore

+ WAL *wal.SegmentWriter

+ type Engine struct

+ func New(cfg Config) *Engine

+ func (e *Engine) AppendBatch(b *Batch) (accepted int, err error)

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

+ func (e *Engine) ApplyReplicated(data []byte) 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) HeadRecordCount() 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) Series(matchers []fetch.Matcher, start, end int64) []signal.Series

+ func (e *Engine) SideSnapshot(ctx context.Context) (map[string][]byte, error)

+ func (e *Engine) StreamCount() int

+ type Kind uint8

+ const KindBytes

+ const KindInt64

+ type Schema struct

+ func NewSchema(cols ...Column) *Schema

+ type SideStore interface

+ Absorb func(delta []byte) error

+ Encode func() map[string][]byte

+ Names func() []string

+ Reset func()

+ Union func(parts []map[string][]byte) (map[string][]byte, error)