aggregator

Documentation

Overview

Package aggregator contains the data structures responsible for aggregating payloads recevied by the server.

Index

• type Aggregator
  • func NewAggregator() *Aggregator
  • func (a *Aggregator) PrintHealthMetrics()
  • func (a *Aggregator) Process(project string, payload *payload.Payload)
  • func (a *Aggregator) ProjectNames() []string
  • func (a *Aggregator) SendHourlyMetrics(handler MetricHandler)
  • func (a *Aggregator) SendMetrics(handler MetricHandler)
• type MetricHandler
• type Project

Types

type Aggregator

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

Aggregator holds all Projects

func NewAggregator

func NewAggregator() *Aggregator

NewAggregator creates a new aggregator

func (*Aggregator) PrintHealthMetrics

func (a *Aggregator) PrintHealthMetrics()

PrintHealthMetrics renders some simple health metrics

func (*Aggregator) Process

func (a *Aggregator) Process(project string, payload *payload.Payload)

Process aggreates a payload

func (*Aggregator) ProjectNames

func (a *Aggregator) ProjectNames() []string

ProjectNames returns a list of projects that currently exist

func (*Aggregator) SendHourlyMetrics

func (a *Aggregator) SendHourlyMetrics(handler MetricHandler)

SendHourlyMetrics passes all metrics to MetricHandler

func (*Aggregator) SendMetrics

func (a *Aggregator) SendMetrics(handler MetricHandler)

SendMetrics passes all metrics to MetricHandler

type MetricHandler

type MetricHandler func(name string, value float64)

A MetricHandler takes care of sending metrics to somewhere

type Project

type Project struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

A Project aggregates metrics for a entire project.