storage

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)