tsdb

package

v0.0.8-beta Latest Latest Go to latest Published: Feb 22, 2026 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Aggregator struct {
	// contains filtered or unexported fields
}

Aggregator manages in-memory tumbling windows for metrics.

func NewAggregator(repo *storage.Repository, windowSize time.Duration) *Aggregator

NewAggregator creates a new TSDB aggregator.

func (a *Aggregator) Ingest(m RawMetric)

Ingest adds a raw metric point to the current aggregator window.

func (a *Aggregator) Start(ctx context.Context)

Start begins the aggregation background processes.

func (a *Aggregator) Stop()

Stop stops the aggregator.

type RawMetric struct {
	Name        string
	ServiceName string
	Value       float64
	Timestamp   time.Time
	Attributes  map[string]interface{}
}

RawMetric represents an incoming single metric data point before aggregation.