storage

Sep 7, 2026

Changes in this version

type PartSyncStats

+ Retained int64

+ Withheld int64

type SignalStats

+ Holes int

+ LostParts uint64

+ WantedParts int

Sep 1, 2026

Changes in this version

type PartDetail

+ LogicalBytes int64

Sep 1, 2026

Changes in this version

type Storage

+ func (s *Storage) TraceKeys(ctx context.Context, tenant signal.TenantID, start, end int64) ([]KeyInfo, error)

Sep 1, 2026

Changes in this version

type Options

+ MaxQueryBytes int64

type SignalStats

+ HeadAge time.Duration

type Storage

+ func (s *Storage) WithQueryBudget(ctx context.Context) context.Context

Aug 30, 2026

Changes in this version

type Storage

+ func (s *Storage) ColumnValues(ctx context.Context, tenant signal.TenantID, req ValuesRequest) ([][]byte, error)

+ type ValuesRequest struct

+ AttrKey []byte

+ Column string

+ End int64

+ Limit int

+ Signal signal.Signal

+ Start int64

Aug 21, 2026

Changes in this version

type ClusterStats

+ Rejoins int64

+ SelfAbsent bool

type Option

+ func WithDiskReserve(minFreeBytes, minFreeInodes int64) Option

type Options

+ MinFreeBytes int64

+ MinFreeInodes int64

type SignalStats

+ OutOfSpace bool

Aug 17, 2026

Changes in this version

type ClusterStats

+ NodeLocalBackendUnshared bool

+ PrivateBackend bool

Aug 17, 2026

Changes in this version

type SignalStats

+ HasReadGap bool

+ ReadGapAfterUnixNano int64

Aug 15, 2026

Changes in this version

type Admin

+ func (a Admin) CompactNow(ctx context.Context, key signal.TenantID, sig signal.Signal) error

+ func (a Admin) PruneIdentities(ctx context.Context, key signal.TenantID) (int, error)

+ type ColumnCost struct

+ DiskBytes int64

+ Distinct int64

+ DistinctNormalized int64

+ Name string

+ RawBytes int64

type ColumnInfo

+ Level int

type Option

+ func WithMergeMemory(maxBytes int64) Option

type Options

+ MergeMemoryBytes int64

type SignalStats

+ IdentityBytes int64

+ MergeCandidates int

+ MergeCapBytes int64

+ SealedParts int

type Storage

+ func (s *Storage) MetricSeries(ctx context.Context, t signal.TenantID, matchers []fetch.Matcher, ...) ([]signal.Series, error)

+ func (s *Storage) StreamCosts(ctx context.Context, tenant signal.TenantID, sig signal.Signal, ...) ([]StreamCost, error)

+ type StreamCost struct

+ Columns []ColumnCost

+ DiskBytes int64

+ DistinctEstimated bool

+ Key string

+ RawBytes int64

+ Rows int64

+ Streams int

+ type StreamCostOptions struct

+ Columns []string

+ GroupBy string

+ MaxSketchGroups int

+ TopN int

Jul 28, 2026

Changes in this version

type Storage

+ func (s *Storage) AggregateMetricsWindowNamed(ctx context.Context, t signal.TenantID, r fetch.Request, ...) ([]engine.NamedWindowAgg, error)

Jul 28, 2026

Changes in this version

type Storage

+ func (s *Storage) AggregateMetricsStepNamed(ctx context.Context, t signal.TenantID, r fetch.Request, step int64) ([]engine.NamedAgg, error)

Jul 25, 2026

Changes in this version

type MaintenanceStats

+ PressureFlushes int64

Jul 21, 2026

Changes in this version

type ClusterStats

+ EC *ECStats

+ PartSync *PartSyncStats

+ type ECStats struct

+ ConvertErrors int64

+ Converted int64

+ PrunedStagedParts int64

+ ReconstructErrors int64

+ Reconstructs int64

+ RepairErrors int64

+ RepairedSlots int64

+ type MaintenanceStats struct

+ Cycles int64

+ LastCycleDurationNano int64

+ LastCycleStartUnixNano int64

+ LastCycleTasks int64

+ type PartSyncStats struct

+ Copied int64

+ CopiedBytes int64

+ Errors int64

+ LastSyncUnixNano int64

+ Mirrored int64

+ Passes int64

+ Pruned int64

+ type SignalEfficiency struct

+ BytesPerPoint float64

+ CompressionRatio float64

+ LogicalBytes int64

+ Parts int

+ Points int64

+ Series int64

+ Signal signal.Signal

+ StoredBytes int64

type Storage

+ func (s *Storage) EfficiencyStats(ctx context.Context) ([]TenantEfficiency, error)

+ func (s *Storage) LogsForTrace(ctx context.Context, tenant signal.TenantID, traceID []byte) ([]*fetch.Batch, error)

type StoreStats

+ Maintenance MaintenanceStats

+ type TenantEfficiency struct

+ Signals []SignalEfficiency

+ Tenant signal.TenantID

Jul 2, 2026

Changes in this version

type Option

+ func WithDecodeMemory(maxBytes int64) Option

type Options

+ DecodeMemoryBytes int64

Jun 28, 2026

Changes in this version

+ type CardinalityStats struct

+ DistinctLabelNames int

+ SymbolCount int

+ TopLabelNames []LabelCardinality

+ TotalSeries int64

+ type ColumnInfo struct

+ Codec string

+ Compress string

+ Kind string

+ Name string

+ type LabelCardinality struct

+ DistinctValues int

+ Name string

+ Series int64

+ type PartDetail struct

+ Bytes int64

+ Chunks int

+ Columns []ColumnInfo

+ type PartInfo struct

+ ID string

+ MaxTime int64

+ MinTime int64

+ Rows int64

+ Series int

type SignalStats

+ MergeBacklog int

+ MergeRunning bool

+ WAL bool

+ WALBytes int64

+ WALEpoch uint64

+ WALSegments int

type Storage

+ func (s *Storage) Cardinality(tenant signal.TenantID, sig signal.Signal, topN int) CardinalityStats

+ func (s *Storage) Parts(tenant signal.TenantID, sig signal.Signal) []PartInfo

+ func (s *Storage) PartsDetailed(ctx context.Context, tenant signal.TenantID, sig signal.Signal) ([]PartDetail, error)

Jun 27, 2026

Changes in this version

+ var ErrNotOwner = errors.New("storage: this node is not the compaction owner of the tenant/shard")

+ type Admin struct

+ func (a Admin) Compact(ctx context.Context, key signal.TenantID, sig signal.Signal) error

+ func (a Admin) Flush(ctx context.Context, key signal.TenantID, sig signal.Signal) error

+ func (a Admin) MaintainNow(ctx context.Context) error

+ func (a Admin) Rebalance(ctx context.Context) error

+ func (a Admin) Retention(ctx context.Context, key signal.TenantID) error

type AdmissionStats

+ Overflowed int64

+ type CacheStats struct

+ Decode engine.DecodeCacheStats

+ type ClusterStats struct

+ LastRebalance []RebalanceMove

+ Members []MemberStats

+ Owned []string

+ Self string

+ type MemberStats struct

+ Addr string

+ ID string

+ Zone string

+ type RebalanceMove struct

+ Added []string

+ Removed []string

+ Shard string

+ type SignalStats struct

+ HeadBytes int64

+ HeadItems int64

+ MaxTimeUnixNano int64

+ MinTimeUnixNano int64

+ Parts int

+ Series int64

+ Signal signal.Signal

type Storage

+ func (s *Storage) Admin() Admin

+ func (s *Storage) Inspect() StoreStats

+ type StoreStats struct

+ Caches CacheStats

+ Cluster *ClusterStats

+ Tenants []TenantStats

+ type TenantStats struct

+ Admission AdmissionStats

+ Signals []SignalStats

+ Tenant signal.TenantID

Jun 27, 2026

Changes in this version

+ type SeriesAggregate struct

+ Series signal.Series

type Storage

+ func (s *Storage) AggregateMetricsNamed(ctx context.Context, t signal.TenantID, r fetch.Request) ([]SeriesAggregate, error)

Jun 27, 2026

Changes in this version

type Option

+ func WithAggregateStats() Option

+ func WithDecodeCache(maxBytes int64) Option

+ func WithMaintenanceConcurrency(n int) Option

+ func WithReadCache(maxBytes int64) Option

type Options

+ AggregateStats bool

+ DecodeCacheBytes int64

+ MaintenanceConcurrency int

+ ReadCacheBytes int64

type Storage

+ func (s *Storage) AggregateMetrics(ctx context.Context, t signal.TenantID, r fetch.Request) (map[signal.SeriesID]engine.SeriesAgg, error)

+ func (s *Storage) AggregateMetricsStep(ctx context.Context, t signal.TenantID, r fetch.Request, step int64) (map[signal.SeriesID][]engine.BucketAgg, error)

Jun 27, 2026

Changes in this version

+ const KeyScopeRecord

+ const KeyScopeResource

+ const KeyScopeScope

+ type KeyInfo struct

+ Key []byte

+ Scope KeyScope

+ type KeyScope uint8

type Option

+ func WithLogger(l *zap.Logger) Option

+ func WithMeterProvider(mp metric.MeterProvider) Option

+ func WithRetry(c reliability.RetryConfig) Option

+ func WithTracerProvider(tp trace.TracerProvider) Option

type Options

+ Logger *zap.Logger

+ MeterProvider metric.MeterProvider

+ Retry reliability.RetryConfig

+ TracerProvider trace.TracerProvider

type Storage

+ func (s *Storage) LogKeys(_ context.Context, tenant signal.TenantID, start, end int64) ([]KeyInfo, error)

Jun 26, 2026

Changes in this version

+ type AdmissionStats struct

+ Accepted int64

+ RejectedCardinality int64

+ RejectedInFlight int64

+ RejectedOOO int64

+ RejectedRate int64

+ SampledDropped int64

+ func (s AdmissionStats) Rejected() int64

type Storage

+ func (s *Storage) AdmissionStats(tid signal.TenantID) AdmissionStats

Jun 26, 2026

Changes in this version

type Option

+ func WithWALSync(m WALSyncMode) Option

+ func WithWALSyncInterval(d time.Duration) Option

type Options

+ WALSync WALSyncMode

+ WALSyncInterval int64

type Storage

+ func (s *Storage) LogSeries(_ context.Context, tenant signal.TenantID, matchers []fetch.Matcher, ...) ([]signal.Series, error)

+ func (s *Storage) TraceSeries(_ context.Context, tenant signal.TenantID, matchers []fetch.Matcher, ...) ([]signal.Series, error)

+ type WALSyncMode uint8

+ const WALSyncAlways

+ const WALSyncInterval

+ const WALSyncNone

Jun 26, 2026

Changes in this version

type Option

+ func WithQueryCache(maxEntries int) Option

+ func WithQueryCacheFreshness(ns int64) Option

+ func WithQuerySplitInterval(ns int64) Option

type Options

+ QueryCacheEntries int

+ QueryCacheFreshness int64

+ QuerySplitInterval int64

type Storage

+ func (s *Storage) LogFetcher(tenants ...signal.TenantID) fetch.Fetcher

+ func (s *Storage) ProfileFetcher(tenants ...signal.TenantID) fetch.Fetcher

+ func (s *Storage) ProfileResolver(ctx context.Context, tenant signal.TenantID) (*profile.Resolver, error)

+ func (s *Storage) ProfileSeries(ctx context.Context, tenant signal.TenantID, matchers []fetch.Matcher, ...) ([]signal.Series, error)

+ func (s *Storage) Trace(ctx context.Context, tenant signal.TenantID, traceID []byte) ([]*fetch.Batch, error)

+ func (s *Storage) TraceFetcher(tenants ...signal.TenantID) fetch.Fetcher

Jun 26, 2026

Changes in this version

+ var ErrClosed = errors.New("storage: closed")

+ var ErrNotEphemeral = errors.New("storage: reset requires an ephemeral backend")

+ var ErrNotImplemented = errors.New("storage: not implemented in this milestone")

+ type Accepted struct

+ Accepted int64

+ Rejected int64

+ RejectedReason string

+ type Durability uint8

+ const DurabilityDefault

+ const DurabilityEphemeral

+ type Option func(*Options)

+ func WithBackend(b backend.Backend) Option

+ func WithCluster(c *cluster.Config) Option

+ func WithDurability(d Durability) Option

+ func WithEncoding(p encoding.Profile) Option

+ func WithFlushInterval(ns int64) Option

+ func WithFlushThresholdBytes(n int64) Option

+ func WithOOOWindow(ns int64) Option

+ func WithTenancy(r tenant.Resolver) Option

+ func WithTenant(fn func(signal.Resource, signal.Scope) signal.TenantID) Option

+ func WithWALDir(dir string) Option

+ type Options struct

+ Backend backend.Backend

+ Cluster *cluster.Config

+ Durability Durability

+ Encoding encoding.Profile

+ FlushInterval int64

+ FlushThresholdBytes int64

+ OOOWindow int64

+ Tenancy tenant.Resolver

+ Tenant func(signal.Resource, signal.Scope) signal.TenantID

+ WALDir string

+ type Storage struct

+ func InMemory(opts ...Option) (*Storage, error)

+ func Open(ctx context.Context, o Options, opts ...Option) (*Storage, error)

+ func (s *Storage) Close(ctx context.Context) error

+ func (s *Storage) Fetcher(tenants ...signal.TenantID) fetch.Fetcher

+ func (s *Storage) Reset(ctx context.Context) error

+ func (s *Storage) WriteLogs(_ context.Context, _ log.Logs) (Accepted, error)

+ func (s *Storage) WriteMetrics(ctx context.Context, md metric.Metrics) (Accepted, error)

+ func (s *Storage) WriteProfiles(_ context.Context, _ profile.Profiles) (Accepted, error)

+ func (s *Storage) WriteTraces(_ context.Context, _ trace.Traces) (Accepted, error)