Versions in this module Expand all Collapse all v0 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
Go to main page