aggregate

package

Go to main page

Versions in this module

v0

v0.6.8

Oct 21, 2026

v0.6.7

Oct 21, 2026

v0.6.6

Oct 21, 2026

Changes in this version

+ const ReasonNonFiniteValue

type MetricPointOutcome

+ const MetricPointRejectedValue

v0.6.6-alpha.1

Oct 20, 2026

v0.6.5

Oct 20, 2026

v0.6.4

Oct 20, 2026

v0.6.3

Oct 20, 2026

Changes in this version

+ const LimitedCoverageNote

type BucketsResult

+ IdentityCoverage IdentityCoverage

type Cache

+ func (c *Cache) FindID(tenantID uint32, kind Kind, value string) (uint32, bool)

type Coverage

+ const CoverageLimited

type DashboardResult

+ IdentityCoverage IdentityCoverage

type DurableRegistrar

+ func (r *DurableRegistrar) FindID(tenantID uint32, kind Kind, value string) (uint32, bool)

type Engine

+ func (e *Engine) QueryLogSummary(ctx context.Context, q Query) (*LogSummaryResult, error)

+ type IdentityCoverage struct

+ EdgePoints uint64

+ LogPoints uint64

+ MetricPoints uint64

+ TracePoints uint64

+ func (c IdentityCoverage) Limited() bool

+ type LogSummaryPoint struct

+ Count int64

+ WindowStart time.Time

+ type LogSummaryResult struct

+ Coverage Coverage

+ Epoch string

+ IdentityCoverage IdentityCoverage

+ Points []LogSummaryPoint

+ ResolutionSeconds int

+ Revision uint64

type MemRegistrar

+ func (r *MemRegistrar) FindID(tenantID uint32, kind Kind, value string) (uint32, bool)

type Selector

+ ServiceIDs []uint32

type SumRow

+ IdentityCount uint64

type TopologyResult

+ IdentityCoverage IdentityCoverage

type TopologySnapshot

+ IdentityCoverage IdentityCoverage

v0.6.2

Oct 19, 2026

v0.6.1

Sep 21, 2026

v0.6.0

Sep 21, 2026

v0.5.0

Sep 5, 2026

Changes in this version

+ const AllowedLateness

+ const CoverageHeader

+ const DefaultAggregateDBPath

+ const DefaultCommitCoalesceMs

+ const DefaultCommitMaxBytes

+ const DefaultCommitMaxDeltas

+ const DefaultCommitMaxPendingBytes

+ const DefaultCommitMaxPendingDeltas

+ const DefaultCommitMaxWaiters

+ const DefaultEdgeResolverSpans

+ const DefaultFinalizeIntervalSec

+ const DefaultMaxClosedWindows

+ const DefaultMaxDimKeys

+ const DefaultMaxDimKeysPerTenant

+ const DefaultMaxDimTuples

+ const DefaultMaxDimTuplesPerTenant

+ const DefaultMaxDimValues

+ const DefaultMaxDimValuesPerTenant

+ const DefaultMaxLogTemplatesPerService

+ const DefaultMaxMetricSeriesPerService

+ const DefaultMaxOperationsPerService

+ const DefaultMaxProducerBaselinesPerSeries

+ const DefaultMaxSeries

+ const DefaultMaxSeriesEdges

+ const DefaultMaxSeriesLogs

+ const DefaultMaxSeriesMetrics

+ const DefaultMaxSeriesSystem

+ const DefaultMaxSeriesTraces

+ const DefaultMaxServices

+ const DefaultMaxServicesPerTenant

+ const DefaultMaxTenantBytes

+ const DefaultMaxTenants

+ const DefaultMaxTraceSeriesPerService

+ const DefaultMaxValueBytes

+ const DefaultTopologyHorizon

+ const DefaultTopologyMaxEdges

+ const DefaultTopologyMaxMetrics

+ const DefaultTopologyMaxOperationsPerService

+ const DefaultTopologyMaxServices

+ const DefaultTopologyRestoreMaxRows

+ const DimsRejectUnsupportedValue

+ const EncodedSeriesKeyLen

+ const ExemplarCoverageNote

+ const ExpHistogramMaxScale

+ const ExpHistogramMinScale

+ const GlobalTenant

+ const HistHasMax

+ const HistHasMin

+ const HistPercentilesUnavailable

+ const HistUnboundedTail

+ const IDPlaceholder

+ const MaxDimensionKeys

+ const MaxFutureSkew

+ const MaxReadWindowSpan

+ const MetaDictWatermark

+ const MetaSeriesWatermark

+ const ModeAggregate

+ const ModeLegacy

+ const ModeShadow

+ const NumShards

+ const OtherValue

+ const ReasonCumulativeTemporality

+ const ReasonMalformedPoint

+ const ReasonUnspecifiedTemporality

+ const ReasonUnsupportedType

+ const SampledCoverageNote

+ const SeriesKeyVersion

+ const SketchDefaultScale

+ const SketchEncodingVersion

+ const SketchMaxBins

+ const SketchMaxScale

+ const SketchMaxSerializedBins

+ const StoreSchemaVersion

+ const TemplateOther

+ const TemplateWildcard

+ const WindowSize

+ var ErrDictFull = errors.New("aggregate: dictionary full")

+ var ErrHistogramMalformed = errors.New("aggregate: malformed histogram point")

+ var ErrKeyTrailingBytes = errors.New("aggregate: encoded series key has trailing bytes")

+ var ErrKeyTruncated = errors.New("aggregate: encoded series key truncated")

+ var ErrSaturated = errors.New("aggregate: store admission saturated")

+ var ErrSelectorUnbounded = errors.New("aggregate: unbounded selector")

+ var ErrSketchCorrupt = errors.New("aggregate: corrupt sketch encoding")

+ var ErrSketchScale = errors.New("aggregate: unsupported sketch scale")

+ var ErrSketchTruncated = errors.New("aggregate: truncated sketch encoding")

+ var ErrSketchVersion = errors.New("aggregate: unsupported sketch encoding version")

+ var ErrStoreClosed = errors.New("aggregate: store closed")

+ var ErrTenantRejected = errors.New("aggregate: tenant identity rejected")

+ var MaxDictRows = 2_000_000

+ var MaxReadRows = 20000

+ var MaxSeriesRows = 500_000

+ func AppendCanonicalDims(dst []byte, pairs []DimPair) []byte

+ func DecodeSketchInto(dst *Sketch, data []byte) error

+ func FinalizeCutoff(now time.Time) int64

+ func InternDimValues(c *Cache, tenantID uint32, keys, values []string) uint32

+ func IsDiskFull(err error) bool

+ func IsGaugeLike(temporality Temporality, monotonic bool) bool

+ func IsRequestSpan(root bool, spanKind int32) bool

+ func LogGC(stats GCStats, err error)

+ func LogRecovery(stats RecoveryStats, path string)

+ func MutableSince(now time.Time) int64

+ func NormalizeOperation(httpRoute, urlPath, spanName string) string

+ func NormalizePath(path string) string

+ func NormalizeSpanName(name string) string

+ func PercentileFromSketch(s *Sketch) *latency.Percentile

+ func RestoreMiner(store Store, miner *TemplateMiner) (int, error)

+ func WindowStart(t time.Time) int64

+ type AccuracyMetadata struct

+ Approximate bool

+ Degraded bool

+ PercentilesUnavailable bool

+ PercentilesUnavailableReason string

+ RelativeErrorBound float64

+ SketchScale uint8

+ SourceBucketError float64

+ UnboundedTail bool

+ UnboundedTailBound float64

+ func AccuracyFromHistogramDelta(d *AggregateDelta) AccuracyMetadata

+ func AccuracyFromSketch(s *Sketch) AccuracyMetadata

+ type Admission struct

+ Key SeriesKey

+ Overflowed bool

+ Reason OverflowReason

+ Reserved bool

+ type AdmissionPlan struct

+ Resolved DeltaMap

+ type AggregateDelta struct

+ Count uint64

+ CounterDelta float64

+ DurationCount uint64

+ DurationMax float64

+ DurationMin float64

+ DurationSum float64

+ ErrorCount uint64

+ ErrorRequestCount uint64

+ FirstTimestamp time.Time

+ GaugeCount uint64

+ GaugeLast float64

+ GaugeLastTime time.Time

+ GaugeMax float64

+ GaugeMin float64

+ GaugeSum float64

+ HistogramCount uint64

+ HistogramFlags uint32

+ HistogramMax float64

+ HistogramMin float64

+ HistogramSourceError float64

+ HistogramSum float64

+ HistogramTailBound float64

+ HistogramTailCount uint64

+ LastTimestamp time.Time

+ LogCount uint64

+ RequestCount uint64

+ ResetCount uint64

+ Sketch *Sketch

+ func (d *AggregateDelta) Clone() *AggregateDelta

+ func (d *AggregateDelta) HistogramPercentilesAvailable() bool

+ func (d *AggregateDelta) HistogramQuantile(q float64) (value float64, lowerBound, ok bool)

+ func (d *AggregateDelta) Merge(other *AggregateDelta)

+ func (d *AggregateDelta) ObserveCounter(delta float64, reset bool)

+ func (d *AggregateDelta) ObserveGauge(value float64, ts time.Time)

+ func (d *AggregateDelta) ObserveHistogram(f HistogramFold)

+ func (d *AggregateDelta) ObserveLog(ts time.Time, isError bool)

+ func (d *AggregateDelta) ObserveSpan(durationMicros float64, isError, isRequest bool)

+ type Applier interface

+ Apply func(DeltaMap) uint64

+ type BacklogStats struct

+ Bytes int64

+ OldestWindow int64

+ Rows int64

+ type Barrier interface

+ RunBarrier func(fn func()) error

+ type Baseline struct

+ LastTimestamp time.Time

+ StartTime time.Time

+ Value float64

+ type BaselineRow struct

+ Baseline Baseline

+ Producer ProducerID

+ SeriesID SeriesID

+ type BaselineStats struct

+ Entries int

+ Gaps uint64

+ GlobalOverflow uint64

+ Owed int

+ ProducerOverflow uint64

+ Recovered uint64

+ ResetsRegression uint64

+ ResetsStartTime uint64

+ Seeded uint64

+ Series int

+ Stale uint64

+ Stranded uint64

+ type BaselineTracker struct

+ func NewBaselineTracker(cfg BaselineTrackerConfig) *BaselineTracker

+ func (t *BaselineTracker) Baseline(key SeriesKey, producer ProducerID) (Baseline, bool)

+ func (t *BaselineTracker) DirtyCount() int

+ func (t *BaselineTracker) DrainDirty() []DirtyBaseline

+ func (t *BaselineTracker) ObserveCumulative(key SeriesKey, producer ProducerID, startTime, ts time.Time, value float64) CumulativeOutcome

+ func (t *BaselineTracker) Rollback(rows []DirtyBaseline)

+ func (t *BaselineTracker) Seed(key SeriesKey, producer ProducerID, b Baseline)

+ func (t *BaselineTracker) Stats() BaselineStats

+ type BaselineTrackerConfig struct

+ GapThreshold time.Duration

+ MaxBaselines int

+ MaxProducersPerSeries int

+ type Bounds struct

+ InstanceKind map[Kind]int

+ MaxTenantBytes int

+ MaxTenants int

+ MaxValueBytes int

+ PerTenantKind map[Kind]int

+ type Bucket struct

+ Delta *AggregateDelta

+ SeriesID SeriesID

+ Source BucketSource

+ WindowStart int64

+ type BucketCursor struct

+ SeriesID SeriesID

+ Source BucketSource

+ WindowStart int64

+ func (c BucketCursor) After(window int64, id SeriesID, src BucketSource) bool

+ type BucketPage struct

+ Buckets []Bucket

+ Limit int

+ Next BucketCursor

+ Truncated bool

+ type BucketSource uint8

+ const SourceDelta

+ const SourceFinalized

+ type BucketsResult struct

+ Coverage Coverage

+ Epoch string

+ Points []TrafficPoint

+ Revision uint64

+ type Cache struct

+ func NewCache(reg Registrar) *Cache

+ func NewCacheWithBounds(reg Registrar, b Bounds) *Cache

+ func (c *Cache) Bounds() Bounds

+ func (c *Cache) Fence(ids map[uint32]struct{})

+ func (c *Cache) Forget(ids map[uint32]struct{})

+ func (c *Cache) Intern(tenantID uint32, kind Kind, value string) uint32

+ func (c *Cache) InternBytes(tenantID uint32, kind Kind, value []byte) uint32

+ func (c *Cache) InternDims(tenantID uint32, pairs []DimPair) uint32

+ func (c *Cache) InternTenant(name string) (uint32, bool)

+ func (c *Cache) Len() int

+ func (c *Cache) Lookup(id uint32) (DictEntry, bool)

+ func (c *Cache) OtherID(tenantID uint32, kind Kind) uint32

+ func (c *Cache) Roots() map[uint32]struct{}

+ func (c *Cache) SetOverflowSink(fn func(kind Kind, bound string))

+ func (c *Cache) Stats() CacheStats

+ func (c *Cache) Unfence()

+ type CacheStats struct

+ Errors uint64

+ Fenced uint64

+ Hits uint64

+ Misses uint64

+ OverLength uint64

+ Overflows uint64

+ TenantsRejected uint64

+ type Coverage string

+ const CoverageExemplar

+ const CoverageFull

+ const CoverageSampled

+ func (c Coverage) Note() string

+ type CumulativeOutcome struct

+ Degraded bool

+ Delta float64

+ Gap bool

+ Ignored bool

+ Reason ResetReason

+ Recovered bool

+ Reset bool

+ Seeded bool

+ type DashboardResult struct

+ Accuracy AccuracyMetadata

+ ActiveServices int64

+ AvgLatencyMs float64

+ Coverage Coverage

+ Epoch string

+ ErrorRequestCount int64

+ LatencyProvenance latency.Provenance

+ P99LatencyMicros float64

+ RequestCount int64

+ RequestErrorRate float64

+ Revision uint64

+ SpanCount int64

+ SpanErrorCount int64

+ SpanErrorRate float64

+ TopFailing []ServiceStat

+ TotalLogs int64

+ type DeltaMap map[SeriesWindowKey]*AggregateDelta

+ type DeltaRow struct

+ Delta *AggregateDelta

+ SeriesID SeriesID

+ WindowStart int64

+ type DictEntry struct

+ ID uint32

+ Kind Kind

+ TenantID uint32

+ Value []byte

+ type DictRow struct

+ ID uint32

+ Kind Kind

+ TenantID uint32

+ Value []byte

+ type DimPair struct

+ KeyID uint32

+ ValueID uint32

+ type DimsConfig map[string][]string

+ func (d DimsConfig) ExtractDimensionValues(metricName string, attrs []*commonpb.KeyValue) []string

+ func (d DimsConfig) Get(metricName string) []string

+ type DirtyBaseline struct

+ Baseline Baseline

+ Inflight float64

+ Key SeriesKey

+ Producer ProducerID

+ type DurableRegistrar struct

+ func NewDurableRegistrar(store Store, limits map[Kind]int) (*DurableRegistrar, error)

+ func NewDurableRegistrarWithBounds(store Store, b Bounds) (*DurableRegistrar, error)

+ func (r *DurableRegistrar) ClearTouched()

+ func (r *DurableRegistrar) Committed(rows []DictRow)

+ func (r *DurableRegistrar) DrainPending() []DictRow

+ func (r *DurableRegistrar) Fence(ids map[uint32]struct{})

+ func (r *DurableRegistrar) Forget(ids map[uint32]struct{})

+ func (r *DurableRegistrar) Lookup(id uint32) (DictEntry, bool)

+ func (r *DurableRegistrar) Next() uint32

+ func (r *DurableRegistrar) OtherID(tenantID uint32, kind Kind) uint32

+ func (r *DurableRegistrar) PendingCount() int

+ func (r *DurableRegistrar) Register(tenantID uint32, kind Kind, value []byte) (uint32, error)

+ func (r *DurableRegistrar) Revalidate(candidates map[uint32]struct{})

+ func (r *DurableRegistrar) Roots() map[uint32]struct{}

+ func (r *DurableRegistrar) Unfence()

+ type EdgeInput struct

+ Callee string

+ Caller string

+ DurationMicros float64

+ HTTPRoute string

+ HTTPStatusCode int

+ Method string

+ Root bool

+ SpanKind int32

+ SpanName string

+ StatusCode int32

+ Tenant string

+ Timestamp time.Time

+ URLPath string

+ type EdgeResolver struct

+ func NewEdgeResolver(maxSpans int) *EdgeResolver

+ func (r *EdgeResolver) Len() int

+ func (r *EdgeResolver) Observe(tenant, spanID, parentSpanID, service string) (string, bool)

+ type Engine struct

+ func NewEngine(cfg EngineConfig) (*Engine, error)

+ func (e *Engine) ActiveSeriesKeys() map[SeriesKey]struct{}

+ func (e *Engine) ApplyCommitted(m DeltaMap) uint64

+ func (e *Engine) ApplyDeltas(m DeltaMap) uint64

+ func (e *Engine) ApplyDeltasErr(m DeltaMap) (uint64, error)

+ func (e *Engine) ApplyReducer(r *Reducer) uint64

+ func (e *Engine) ApplyReducerErr(r *Reducer) (uint64, error)

+ func (e *Engine) Baselines() *BaselineTracker

+ func (e *Engine) Cache() *Cache

+ func (e *Engine) CommitAdmission(plan *AdmissionPlan) uint64

+ func (e *Engine) EdgeResolver() *EdgeResolver

+ func (e *Engine) Epoch() string

+ func (e *Engine) Limiter() *Limiter

+ func (e *Engine) MarkFinalized(windowStart int64)

+ func (e *Engine) MetricDims() DimsConfig

+ func (e *Engine) Miner() *TemplateMiner

+ func (e *Engine) Mode() string

+ func (e *Engine) NewReducer(arrival time.Time) *Reducer

+ func (e *Engine) Ownership() Ownership

+ func (e *Engine) PlanAdmission(m DeltaMap) *AdmissionPlan

+ func (e *Engine) PruneTopology()

+ func (e *Engine) QueryBuckets(ctx context.Context, q Query) (*BucketsResult, error)

+ func (e *Engine) QueryDashboard(ctx context.Context, q Query) (*DashboardResult, error)

+ func (e *Engine) QueryTopology(ctx context.Context, q Query) (*TopologyResult, error)

+ func (e *Engine) RestoreTopology(ids map[SeriesWindowKey]topoIdentity, deltas DeltaMap) int

+ func (e *Engine) Revision() uint64

+ func (e *Engine) RollbackAdmission(plan *AdmissionPlan)

+ func (e *Engine) Rollover(now time.Time) int

+ func (e *Engine) SetApplier(a Applier)

+ func (e *Engine) SetStore(st Store)

+ func (e *Engine) SetTemplateFactSink(fn func(TemplateFact))

+ func (e *Engine) Snapshot() Snapshot

+ func (e *Engine) Store() Store

+ func (e *Engine) TenantID(name string) (uint32, bool)

+ func (e *Engine) TopologyEpoch() uint64

+ func (e *Engine) TopologyHorizon() time.Duration

+ func (e *Engine) TopologyRevision(tenant string) uint64

+ func (e *Engine) TopologySnapshot(tenant string) TopologySnapshot

+ func (e *Engine) TopologyTenants() []string

+ type EngineConfig struct

+ Bounds Bounds

+ EdgeResolverSpans int

+ Epoch uint64

+ Limiter LimiterConfig

+ MaxBaselines int

+ MaxClosedWindows int

+ MaxProducerBaselinesPerSeries int

+ MetricDims DimsConfig

+ Metrics MetricsRecorder

+ Miner *TemplateMiner

+ Mode string

+ Now func() time.Time

+ Registrar Registrar

+ Topology TopologyConfig

+ type ExpBuckets struct

+ Counts []uint64

+ Offset int32

+ type ExponentialHistogramInput struct

+ Negative ExpBuckets

+ Positive ExpBuckets

+ Scale int32

+ ZeroCount uint64

+ type FailableApplier interface

+ ApplyErr func(DeltaMap) (uint64, error)

+ type FieldError struct

+ Field string

+ Signal Signal

+ Value uint8

+ func (e *FieldError) Error() string

+ type FinalizeStats struct

+ Buckets int

+ DeltaRows int

+ Duration time.Duration

+ WindowStart int64

+ type FinalizedPage struct

+ Buckets []Bucket

+ Truncated bool

+ type GCConfig struct

+ Barrier Barrier

+ Cache *Cache

+ Engine *Engine

+ Metrics StoreMetrics

+ Miner *TemplateMiner

+ Registrar *DurableRegistrar

+ Series *seriesRegistry

+ Store Store

+ type GCSnapshot struct

+ Dict []DictRow

+ Referenced map[SeriesID]struct{}

+ Series []SeriesRow

+ Templates []TemplateRow

+ type GCStats struct

+ BarrierDuration time.Duration

+ DictRetained int

+ DictScanned int

+ DictSwept int64

+ Duration time.Duration

+ MarkDuration time.Duration

+ Revalidated int

+ SeriesRetained int

+ SeriesScanned int

+ SeriesSwept int64

+ TemplatesScanned int

+ TemplatesSwept int64

+ func Collect(cfg GCConfig) (GCStats, error)

+ type GCStore interface

+ GCSnapshot func() (*GCSnapshot, error)

+ LoadTemplates func(max int) ([]TemplateRow, error)

+ SaveTemplateStats func(rows []TemplateStatRow) error

+ SweepIdentities func(series []SeriesID, dict []uint32, templates []uint32) (SweepStats, error)

+ type GroupBatch struct

+ Baselines []BaselineRow

+ Deltas []DeltaRow

+ Dicts []DictRow

+ Series []SeriesRow

+ Templates []TemplateRow

+ func (b *GroupBatch) Empty() bool

+ type GroupBy uint8

+ const GroupByName

+ const GroupByService

+ const GroupBySignal

+ const GroupByWindow

+ type HTTPClass uint8

+ const HTTPClass1xx

+ const HTTPClass2xx

+ const HTTPClass3xx

+ const HTTPClass4xx

+ const HTTPClass5xx

+ const HTTPClassNone

+ func HTTPClassFromStatus(code int) HTTPClass

+ func (h HTTPClass) String() string

+ type HistogramCommon struct

+ Attributes []*commonpb.KeyValue

+ Count uint64

+ HasMax bool

+ HasMin bool

+ HasSum bool

+ Max float64

+ Min float64

+ Name string

+ Resource ResourceIdentity

+ ResourceAttributes []*commonpb.KeyValue

+ Service string

+ StartTime time.Time

+ Sum float64

+ Temporality Temporality

+ Tenant string

+ Timestamp time.Time

+ type HistogramFold struct

+ Count uint64

+ DropReason SketchDropReason

+ HasMax bool

+ HasMin bool

+ HasSum bool

+ Max float64

+ Min float64

+ PercentilesUnavailable bool

+ Sketch *Sketch

+ SourceBucketError float64

+ Sum float64

+ UnboundedTail bool

+ UnboundedTailBound float64

+ UnboundedTailCount uint64

+ func FoldExponentialHistogram(in ExponentialHistogramInput) (HistogramFold, error)

+ func FoldHistogram(in HistogramInput) (HistogramFold, error)

+ type HistogramInput struct

+ Bounds []float64

+ BucketCounts []uint64

+ type Kind uint8

+ const KindDimKey

+ const KindDimTuple

+ const KindDimValue

+ const KindLogTemplate

+ const KindMetricName

+ const KindOperation

+ const KindService

+ const KindTenant

+ func NameKind(s Signal) (Kind, bool)

+ func (k Kind) String() string

+ func (k Kind) Valid() bool

+ type Limiter struct

+ func NewLimiter(cfg LimiterConfig) *Limiter

+ func (l *Limiter) Admit(key SeriesKey, window int64) Admission

+ func (l *Limiter) IsOverflowSeries(key SeriesKey) bool

+ func (l *Limiter) Release(key SeriesKey, window int64)

+ func (l *Limiter) Stats() LimiterStats

+ type LimiterConfig struct

+ MaxLogTemplatesPerService int

+ MaxMetricSeriesPerService int

+ MaxOperationsPerService int

+ MaxSeries int

+ MaxSeriesEdges int

+ MaxSeriesLogs int

+ MaxSeriesMetrics int

+ MaxSeriesSystem int

+ MaxSeriesTraces int

+ MaxTraceSeriesPerService int

+ OtherNameID func(tenantID uint32, signal Signal) uint32

+ SeriesPerTenantFraction float64

+ func (c LimiterConfig) Validate() error

+ type LimiterStats struct

+ Active int

+ ActiveBySignal map[Signal]int

+ Overflow map[OverflowReason]uint64

+ OverflowSeries int

+ OverflowSeriesBySignal map[Signal]int

+ type LogInput struct

+ Body string

+ Service string

+ Severity string

+ SeverityNumber int32

+ Tenant string

+ Timestamp time.Time

+ type MemRegistrar struct

+ func NewMemRegistrar(opts *MemRegistrarOptions) *MemRegistrar

+ func (r *MemRegistrar) Count(tenantID uint32, kind Kind) int

+ func (r *MemRegistrar) Lookup(id uint32) (DictEntry, bool)

+ func (r *MemRegistrar) OtherID(tenantID uint32, kind Kind) uint32

+ func (r *MemRegistrar) Register(tenantID uint32, kind Kind, value []byte) (uint32, error)

+ type MemRegistrarOptions struct

+ Limits map[Kind]int

+ type Method uint8

+ const MethodConnect

+ const MethodDelete

+ const MethodGet

+ const MethodHead

+ const MethodNone

+ const MethodOptions

+ const MethodOther

+ const MethodPatch

+ const MethodPost

+ const MethodPut

+ const MethodTrace

+ func LookupMethod(s string) (Method, bool)

+ func ParseMethod(s string) Method

+ func (m Method) String() string

+ type MetricInput struct

+ Attributes []*commonpb.KeyValue

+ Monotonic bool

+ Name string

+ Resource ResourceIdentity

+ ResourceAttributes []*commonpb.KeyValue

+ Service string

+ StartTime time.Time

+ Temporality Temporality

+ Tenant string

+ Timestamp time.Time

+ Value float64

+ type MetricPointOutcome uint8

+ const MetricPointAccepted

+ const MetricPointExcluded

+ const MetricPointRejectedMalformed

+ const MetricPointRejectedTemporality

+ type MetricPointResult struct

+ DropReason SketchDropReason

+ Err error

+ Outcome MetricPointOutcome

+ Reason string

+ SketchDropped bool

+ func (r MetricPointResult) Rejected() bool

+ type MetricsRecorder interface

+ RecordClosedWindowEvicted func()

+ RecordIdentityOverflow func(kind Kind, bound string)

+ RecordOverflow func(signal Signal, reason OverflowReason)

+ RecordReduction func(stats ReducerStats, deltas map[Signal]uint64)

+ RecordTenantRejected func(signal Signal)

+ SetActiveSeries func(active, overflow map[Signal]int)

+ SetClosedWindows func(held int)

+ func NewPrometheusRecorder(m *telemetry.Metrics) MetricsRecorder

+ type OverflowReason uint8

+ const OverflowGlobal

+ const OverflowNone

+ const OverflowServiceNames

+ const OverflowServiceSeries

+ const OverflowSignal

+ const OverflowTenant

+ func (r OverflowReason) String() string

+ type Ownership struct

+ Epoch string

+ FinalizedWatermark int64

+ Mutable []int64

+ Revision uint64

+ func (o Ownership) OwnsInMemory(windowStart int64) bool

+ type PointDisposition uint8

+ const PointAccepted

+ const PointFuture

+ const PointLate

+ func Classify(arrival, pointTime time.Time) (int64, PointDisposition)

+ func (d PointDisposition) String() string

+ type PreloadError struct

+ Max int

+ Rows int

+ Table string

+ func (e *PreloadError) Error() string

+ type ProducerID uint64

+ func ResolveProducerID(id ResourceIdentity) ProducerID

+ type PurgeStats struct

+ Baselines int64

+ Buckets int64

+ Deltas int64

+ Duration time.Duration

+ type Query struct

+ End time.Time

+ Services []string

+ Signal Signal

+ Start time.Time

+ Tenant string

+ type RecoverOptions struct

+ TopologyHorizon time.Duration

+ TopologyMaxRows int

+ type RecoveryGate struct

+ func NewRecoveryGate() *RecoveryGate

+ func (g *RecoveryGate) Complete()

+ func (g *RecoveryGate) Done() bool

+ type RecoveryStats struct

+ Duration time.Duration

+ FinalizedWindows int

+ ReplayedRows int

+ ReplayedSeries int

+ RestoredTopologyRows int

+ RestoredTopologyTruncated bool

+ RestoredTopologyWindows int

+ SeededBaselines int

+ SkippedSeries int

+ func Recover(store Store, engine *Engine, w *Writer, now time.Time, opts RecoverOptions) (RecoveryStats, error)

+ type Reducer struct

+ func (r *Reducer) Arrival() time.Time

+ func (r *Reducer) Deltas() DeltaMap

+ func (r *Reducer) Len() int

+ func (r *Reducer) MergeFrom(other *Reducer)

+ func (r *Reducer) ReduceEdge(in EdgeInput)

+ func (r *Reducer) ReduceExponentialHistogramPoint(in ExponentialHistogramInput) MetricPointResult

+ func (r *Reducer) ReduceHistogramPoint(in HistogramInput) MetricPointResult

+ func (r *Reducer) ReduceLog(in LogInput)

+ func (r *Reducer) ReduceMetricPoint(in MetricInput)

+ func (r *Reducer) ReduceSpan(in SpanInput)

+ func (r *Reducer) Stats() ReducerStats

+ type ReducerStats struct

+ Accepted [signalCount]uint64

+ DimsRejected uint64

+ ErrorsByService map[string]uint64

+ FuturePoints [signalCount]uint64

+ InputPoints [signalCount]uint64

+ LatePoints [signalCount]uint64

+ StaleCumulative uint64

+ TenantsRejected uint64

+ type Registrar interface

+ OtherID func(tenantID uint32, kind Kind) uint32

+ Register func(tenantID uint32, kind Kind, value []byte) (uint32, error)

+ type ResetReason uint8

+ const ResetNone

+ const ResetStartTimeChange

+ const ResetValueRegression

+ func (r ResetReason) String() string

+ type Resolver interface

+ Lookup func(id uint32) (DictEntry, bool)

+ type ResourceIdentity struct

+ Host string

+ ServiceInstanceID string

+ ServiceName string

+ ServiceNamespace string

+ Workload string

+ type SQLiteStore struct

+ func OpenSQLiteStore(cfg StoreConfig) (*SQLiteStore, error)

+ func (s *SQLiteStore) Analyze() error

+ func (s *SQLiteStore) Backlog() (BacklogStats, error)

+ func (s *SQLiteStore) Close() error

+ func (s *SQLiteStore) CommitGroup(b *GroupBatch) error

+ func (s *SQLiteStore) FinalizableWindows(cutoff int64, limit int) ([]int64, error)

+ func (s *SQLiteStore) FinalizeWindow(windowStart int64) (FinalizeStats, error)

+ func (s *SQLiteStore) GCSnapshot() (*GCSnapshot, error)

+ func (s *SQLiteStore) LoadBaselines(max int) ([]BaselineRow, error)

+ func (s *SQLiteStore) LoadDict(max int) ([]DictRow, error)

+ func (s *SQLiteStore) LoadSeries(max int) ([]SeriesRow, error)

+ func (s *SQLiteStore) LoadTemplates(max int) ([]TemplateRow, error)

+ func (s *SQLiteStore) Path() string

+ func (s *SQLiteStore) PingContext(ctx context.Context) error

+ func (s *SQLiteStore) PurgeBefore(cutoff int64) (PurgeStats, error)

+ func (s *SQLiteStore) ReadBuckets(ctx context.Context, sel Selector) (BucketPage, error)

+ func (s *SQLiteStore) ReadFinalizedSince(since int64, signals []Signal, limit int) (FinalizedPage, error)

+ func (s *SQLiteStore) ReplayMutable(since int64) ([]DeltaRow, error)

+ func (s *SQLiteStore) ResolveSeries(ids []SeriesID) ([]SeriesInfo, error)

+ func (s *SQLiteStore) SaveTemplateStats(rows []TemplateStatRow) error

+ func (s *SQLiteStore) SumBuckets(ctx context.Context, sel Selector, by GroupBy) ([]SumRow, error)

+ func (s *SQLiteStore) SweepIdentities(series []SeriesID, dict []uint32, templates []uint32) (SweepStats, error)

+ func (s *SQLiteStore) UUID() string

+ func (s *SQLiteStore) VisitSketches(ctx context.Context, sel Selector, ...) error

+ func (s *SQLiteStore) Watermarks() (uint32, SeriesID, error)

+ type SaturationError struct

+ Bound string

+ Current int64

+ Limit int64

+ func (e *SaturationError) Error() string

+ func (e *SaturationError) Is(target error) bool

+ type SchemaError struct

+ Detail string

+ Got string

+ Key string

+ Reason string

+ Want string

+ func (e *SchemaError) Error() string

+ type Selector struct

+ After BucketCursor

+ End int64

+ Limit int

+ SeriesIDs []SeriesID

+ Signal Signal

+ Signals []Signal

+ SketchOnly bool

+ Start int64

+ TenantID uint32

+ func (s Selector) Validate() (int, error)

+ type SeriesID int64

+ type SeriesInfo struct

+ ID SeriesID

+ Key SeriesKey

+ type SeriesKey struct

+ DimsID uint32

+ HTTPClass HTTPClass

+ Method Method

+ NameID uint32

+ ServiceID uint32

+ Signal Signal

+ StatusClass StatusClass

+ TenantID uint32

+ Variant Variant

+ func DecodeSeriesKey(b []byte) (SeriesKey, error)

+ func (k *SeriesKey) UnmarshalBinary(b []byte) error

+ func (k SeriesKey) AppendBinary(dst []byte) ([]byte, error)

+ func (k SeriesKey) MarshalBinary() ([]byte, error)

+ func (k SeriesKey) String() string

+ func (k SeriesKey) Validate() error

+ type SeriesRow struct

+ ID SeriesID

+ Key SeriesKey

+ type SeriesWindowKey struct

+ Key SeriesKey

+ WindowStart int64

+ type ServiceStat struct

+ AvgLatencyMs float64

+ Count int64

+ ErrorCount int64

+ ErrorRate float64

+ ErrorRequestCount int64

+ LatencyProvenance latency.Provenance

+ P99LatencyMicros float64

+ RequestCount int64

+ Service string

+ type Signal uint8

+ const SignalLog

+ const SignalMetric

+ const SignalServiceEdge

+ const SignalTraceOp

+ const SignalUnspecified

+ func (s Signal) String() string

+ func (s Signal) Valid() bool

+ type Sketch struct

+ func DecodeSketch(data []byte) (*Sketch, error)

+ func NewSketch() *Sketch

+ func NewSketchAtScale(scale uint8) (*Sketch, error)

+ func NewSketchAtScaleUnchecked(scale uint8) *Sketch

+ func (s *Sketch) AppendTo(dst []byte) []byte

+ func (s *Sketch) Collapsed() bool

+ func (s *Sketch) Count() uint64

+ func (s *Sketch) Downscale(target uint8) error

+ func (s *Sketch) Encode() []byte

+ func (s *Sketch) Merge(other *Sketch)

+ func (s *Sketch) Observe(value float64)

+ func (s *Sketch) ObserveBucket(index int32, n uint64)

+ func (s *Sketch) ObserveN(value float64, n uint64)

+ func (s *Sketch) ObserveZero(n uint64)

+ func (s *Sketch) PopulatedBins() int

+ func (s *Sketch) Quantile(q float64) float64

+ func (s *Sketch) RelativeError() float64

+ func (s *Sketch) Saturations() uint64

+ func (s *Sketch) Scale() uint8

+ func (s *Sketch) Sum() float64

+ func (s *Sketch) ZeroCount() uint64

+ type SketchDropReason uint8

+ const SketchDropNegativeObservations

+ const SketchDropNoFiniteBoundaries

+ const SketchDropNone

+ const SketchDropScaleOutOfRange

+ func (r SketchDropReason) String() string

+ type Snapshot struct

+ ActiveBySignal map[Signal]int

+ ActiveSeries int

+ ClosedWindows int

+ ClosedWindowsForced uint64

+ Overflow map[OverflowReason]uint64

+ Revision uint64

+ SeriesDiscarded uint64

+ Windows []WindowSnapshot

+ WindowsDiscarded uint64

+ func (s Snapshot) String() string

+ func (s Snapshot) Totals(signal Signal) (count, errors uint64)

+ type SnapshotEdge struct

+ Callee string

+ Caller string

+ FirstSeen time.Time

+ LastSeen time.Time

+ Windows []TopologyWindow

+ type SpanInput struct

+ DurationMicros float64

+ HTTPRoute string

+ HTTPStatusCode int

+ Method string

+ Root bool

+ Service string

+ SpanKind int32

+ SpanName string

+ StatusCode int32

+ Tenant string

+ Timestamp time.Time

+ URLPath string

+ type StatusClass uint8

+ const SeverityTierDebug

+ const SeverityTierError

+ const SeverityTierFatal

+ const SeverityTierInfo

+ const SeverityTierTrace

+ const SeverityTierUnspecified

+ const SeverityTierWarn

+ const StatusError

+ const StatusOK

+ const StatusUnset

+ func SeverityTier(text string, number int32) StatusClass

+ func SeverityTierFromNumber(sev int32) StatusClass

+ func TraceStatusFromCode(code int32) StatusClass

+ type Store interface

+ Backlog func() (BacklogStats, error)

+ Close func() error

+ CommitGroup func(b *GroupBatch) error

+ FinalizableWindows func(cutoff int64, limit int) ([]int64, error)

+ FinalizeWindow func(windowStart int64) (FinalizeStats, error)

+ LoadBaselines func(max int) ([]BaselineRow, error)

+ LoadDict func(max int) ([]DictRow, error)

+ LoadSeries func(max int) ([]SeriesRow, error)

+ PurgeBefore func(cutoff int64) (PurgeStats, error)

+ ReadBuckets func(ctx context.Context, sel Selector) (BucketPage, error)

+ ReadFinalizedSince func(since int64, signals []Signal, limit int) (FinalizedPage, error)

+ ReplayMutable func(since int64) ([]DeltaRow, error)

+ ResolveSeries func(ids []SeriesID) ([]SeriesInfo, error)

+ SumBuckets func(ctx context.Context, sel Selector, by GroupBy) ([]SumRow, error)

+ VisitSketches func(ctx context.Context, sel Selector, ...) error

+ type StoreConfig struct

+ AllowRebuild bool

+ CacheSizeKB int

+ Metrics StoreMetrics

+ Path string

+ ReadPoolSize int

+ Synchronous string

+ type StoreInspection struct

+ ActualSchemaVersion int

+ ActualSeriesVersion int

+ ActualSketchVersion int

+ Detail string

+ ExpectedSchemaVersion int

+ ExpectedSeriesVersion int

+ ExpectedSketchVersion int

+ MigrationResult string

+ State string

+ StoreUUID string

+ func InspectSQLiteStore(path string) (StoreInspection, error)

+ func (s StoreInspection) Description() string

+ func (s StoreInspection) Usable() bool

+ type StoreMetrics interface

+ RecordAdmissionRejected func(bound string)

+ RecordCommit func(d time.Duration, deltas int, bytes int64, err error)

+ RecordFinalize func(stats FinalizeStats, err error)

+ RecordGC func(stats GCStats, err error)

+ RecordPurge func(stats PurgeStats, err error)

+ RecordRecovery func(stats RecoveryStats)

+ SetBacklog func(rows int64, ageSeconds float64)

+ func NewPrometheusStoreMetrics(m *telemetry.Metrics) StoreMetrics

+ type SumRow struct

+ Count uint64

+ DurationCount uint64

+ DurationSum float64

+ ErrorCount uint64

+ ErrorRequestCount uint64

+ LogCount uint64

+ NameID uint32

+ RequestCount uint64

+ ServiceID uint32

+ Signal Signal

+ WindowStart int64

+ type SweepStats struct

+ Dict int64

+ Duration time.Duration

+ Series int64

+ Templates int64

+ type TemplateFact struct

+ IsOther bool

+ Service string

+ Severity string

+ Template string

+ TemplateID uint32

+ Tenant string

+ Timestamp time.Time

+ type TemplateMiner struct

+ func NewTemplateMiner(cfg TemplateMinerConfig) *TemplateMiner

+ func (m *TemplateMiner) Committed(rows []TemplateRow)

+ func (m *TemplateMiner) DrainDirtyStats() []TemplateStatRow

+ func (m *TemplateMiner) DrainPending() []TemplateRow

+ func (m *TemplateMiner) Mine(tenant, service, severity, body string) (id uint32, isOther bool)

+ func (m *TemplateMiner) MineAt(tenant, service, severity, body string, at time.Time) (id uint32, isOther bool)

+ func (m *TemplateMiner) PartitionStats(tenant, service string) (TemplatePartitionStats, bool)

+ func (m *TemplateMiner) PendingCount() int

+ func (m *TemplateMiner) Restore(rows []TemplateRow)

+ func (m *TemplateMiner) Roots() map[uint32]struct{}

+ func (m *TemplateMiner) SetFactSink(fn func(TemplateFact))

+ func (m *TemplateMiner) Stats() []TemplatePartitionStats

+ func (m *TemplateMiner) TemplateText(id uint32) (string, bool)

+ type TemplateMinerConfig struct

+ Depth int

+ MaxChildren int

+ MaxTemplatesPerService int

+ MaxTokens int

+ OnFact func(TemplateFact)

+ Registrar TemplateRegistrar

+ SimilarityThreshold float64

+ type TemplatePartitionStats struct

+ Converged uint64

+ OtherID uint32

+ Overflow uint64

+ RegistrarFailures uint64

+ Service string

+ Templates int

+ Tenant string

+ type TemplateRegistrar interface

+ RegisterTemplate func(TemplateRegistration) (uint32, error)

+ func NewInMemoryTemplateRegistrar() TemplateRegistrar

+ type TemplateRegistrarFunc func(TemplateRegistration) (uint32, error)

+ func (f TemplateRegistrarFunc) RegisterTemplate(r TemplateRegistration) (uint32, error)

+ type TemplateRegistration struct

+ IsOther bool

+ Service string

+ Template string

+ Tenant string

+ type TemplateRow struct

+ AliasOf uint32

+ Count uint64

+ FirstSeen int64

+ ID uint32

+ IsOther bool

+ LastSeen int64

+ PatternVersion uint32

+ Seq uint64

+ Service string

+ Tenant string

+ Tokens string

+ type TemplateStatRow struct

+ Count uint64

+ FirstSeen int64

+ ID uint32

+ LastSeen int64

+ type Temporality uint8

+ const TemporalityCumulative

+ const TemporalityDelta

+ const TemporalityUnspecified

+ type TopologyConfig struct

+ Horizon time.Duration

+ MaxEdges int

+ MaxMetrics int

+ MaxOperationsPerService int

+ MaxServices int

+ type TopologyEdge struct

+ AvgLatencyMs float64

+ CallCount int64

+ ErrorRate float64

+ Source string

+ Target string

+ type TopologyMetric struct

+ FirstSeen time.Time

+ LastSeen time.Time

+ Metric string

+ Service string

+ Windows []TopologyWindow

+ type TopologyOperation struct

+ FirstSeen time.Time

+ LastSeen time.Time

+ Operation string

+ Service string

+ Windows []TopologyWindow

+ type TopologyResult struct

+ Coverage Coverage

+ Edges []TopologyEdge

+ Epoch string

+ Nodes []ServiceStat

+ Revision uint64

+ type TopologyService struct

+ FirstSeen time.Time

+ LastSeen time.Time

+ Name string

+ Windows []TopologyWindow

+ type TopologySnapshot struct

+ DroppedEdges uint64

+ DroppedMetrics uint64

+ DroppedOperations uint64

+ DroppedServices uint64

+ Edges []SnapshotEdge

+ Epoch uint64

+ Horizon time.Duration

+ Metrics []TopologyMetric

+ Now time.Time

+ Operations []TopologyOperation

+ Revision uint64

+ Services []TopologyService

+ Tenant string

+ func (s TopologySnapshot) Empty() bool

+ func (s TopologySnapshot) Truncated() bool

+ type TopologyWindow struct

+ Closed bool

+ Count uint64

+ DurationCount uint64

+ DurationMaxMicros float64

+ DurationMinMicros float64

+ DurationSumMicros float64

+ Elapsed time.Duration

+ End time.Time

+ ErrorCount uint64

+ Final bool

+ LatencyProvenance *latency.Provenance

+ P95Micros float64

+ P99Micros float64

+ Start time.Time

+ ValueCount uint64

+ ValueMax float64

+ ValueMin float64

+ ValueSum float64

+ func (w TopologyWindow) AvgLatencyMs() float64

+ func (w TopologyWindow) ErrorRate() float64

+ func (w TopologyWindow) Mean() float64

+ type TrafficPoint struct

+ ErrorRequestCount int64

+ RequestCount int64

+ SpanCount int64

+ SpanErrorCount int64

+ WindowStart time.Time

+ type Variant uint8

+ const SpanKindClient

+ const SpanKindConsumer

+ const SpanKindInternal

+ const SpanKindProducer

+ const SpanKindServer

+ const SpanKindUnspecified

+ func VariantFromSpanKind(kind int32) Variant

+ type VersionError struct

+ Got uint8

+ Want uint8

+ func (e *VersionError) Error() string

+ type WatermarkStore interface

+ Watermarks func() (uint32, SeriesID, error)

+ type WindowSnapshot struct

+ Series map[SeriesKey]*AggregateDelta

+ Start time.Time

+ type Writer struct

+ func NewWriter(cfg WriterConfig) (*Writer, error)

+ func (w *Writer) Apply(m DeltaMap) uint64

+ func (w *Writer) ApplyErr(m DeltaMap) (uint64, error)

+ func (w *Writer) CollectIdentities() (GCStats, error)

+ func (w *Writer) FinalizeDue(now time.Time) int

+ func (w *Writer) RunBarrier(fn func()) error

+ func (w *Writer) SaveTemplateStats() error

+ func (w *Writer) SeriesID(key SeriesKey) SeriesID

+ func (w *Writer) SeriesKeyByID(id SeriesID) (SeriesKey, bool)

+ func (w *Writer) Shutdown(ctx context.Context) error

+ func (w *Writer) Start()

+ func (w *Writer) Stats() WriterStats

+ func (w *Writer) Stop()

+ type WriterConfig struct

+ CoalesceWindow time.Duration

+ Engine *Engine

+ FinalizeInterval time.Duration

+ MaxBatchBytes int64

+ MaxBatchDeltas int

+ MaxPendingBytes int64

+ MaxPendingDeltas int

+ MaxWaiters int

+ Metrics StoreMetrics

+ Now func() time.Time

+ Registrar *DurableRegistrar

+ Store Store

+ type WriterStats struct

+ BacklogSampledAt time.Time

+ CommitErrors uint64

+ CommitFailureStreak uint64

+ Commits uint64

+ DeltaLogAgeSeconds float64

+ DeltaLogRows int64

+ Deltas uint64

+ FinalizeErrors uint64

+ FinalizeFailureStreak uint64

+ Finalized uint64

+ MaxPendingBytes int64

+ MaxPendingDeltas int

+ MaxWaiters int

+ PendingBytes int64

+ PendingDeltas int

+ Rejections uint64

+ Waiters int

+ func (s WriterStats) AdmissionRatio() float64

+ func (s WriterStats) DeltaLogAge(now time.Time) float64

v0.5.0-rc.3

Sep 4, 2026

v0.5.0-rc.2

Sep 4, 2026

v0.5.0-rc.1

Sep 4, 2026

v0.4.0-rc.3

Sep 3, 2026

v0.4.0-rc.2

Sep 3, 2026

v0.4.0-rc.1

Sep 3, 2026

v0.4.0-beta.2

Aug 24, 2026

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