aggregator

Documentation

Index

• type Aggregator
  • func New(t ReadTable, publisher Publisher, schema *schema.Schema, limit limits.Limits) *Aggregator
  • func (a *Aggregator) Run(ctx context.Context, aggregationTicker <-chan time.Time, ...)
• type PriorityTable
• type Publisher
• type ReadTable

Types

type Aggregator

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

Aggregator is responsible for collection and aggregation in timed manner samples gathered from StagingTable. Aggregator is driven by two timers which determine aggregation and publication periods.

func New

func New(t ReadTable, publisher Publisher, schema *schema.Schema, limit limits.Limits) *Aggregator

func (*Aggregator) Run

func (a *Aggregator) Run(ctx context.Context, aggregationTicker <-chan time.Time, publishTicker <-chan time.Time)

type PriorityTable

type PriorityTable interface {
	Samples() map[string]*sample.Sample
}

type Publisher

type Publisher interface {
	Publish(context.Context, tables.LookupSet, PriorityTable) error
}

type ReadTable

type ReadTable interface {
	ReadSnapshot(resetLookups bool) (tables.SamplesView, tables.LookupSet)
}