statistics

Documentation

Index

• func IncrementCounter(registry metrics.Registry, key string, value int64)
• type AggregateLogger
• type Aggregator
  • func (instance *Aggregator) Initialize()
  • func (instance *Aggregator) Snapshot() AggregatorSnapShot
  • func (instance *Aggregator) Start()
  • func (instance *Aggregator) Stop()
• type AggregatorController
  • func CreateAggregatorController(registry metrics.Registry) *AggregatorController
  • func (instance *AggregatorController) Initialize()
  • func (instance *AggregatorController) Snapshot() AggregatorSnapShot
  • func (instance *AggregatorController) Start()
  • func (instance *AggregatorController) Stop()
• type AggregatorInterfaceToRenameLater
  • func NewAggregator(registry metrics.Registry) AggregatorInterfaceToRenameLater
• type AggregatorSnapShot
  • func NewAggregatorSnapShot() *AggregatorSnapShot
  • func (this *AggregatorSnapShot) CreateSummary() core.ExecutionSummary
  • func (instance *AggregatorSnapShot) Update(output AggregatorSnapShot)
• type Histogram

Functions

func IncrementCounter

func IncrementCounter(registry metrics.Registry, key string, value int64)

IncrementCounter ...

Types

type AggregateLogger

type AggregateLogger struct {
	LogCounter   func(name string, value int64)
	LogGuage     func(name string, value float64)
	LogTimer     func(name string, value metrics.Timer)
	LogHistogram func(name string, value metrics.Histogram)
	LogMeter     func(name string, value metrics.Meter)
}

type Aggregator

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

Aggregator ...

func (*Aggregator) Initialize

func (instance *Aggregator) Initialize()

Initialize ...

func (*Aggregator) Snapshot

func (instance *Aggregator) Snapshot() AggregatorSnapShot

Snapshot ...

func (*Aggregator) Start

func (instance *Aggregator) Start()

Start ...

func (*Aggregator) Stop

func (instance *Aggregator) Stop()

Stop ...

type AggregatorController

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

AggregatorController ...

func CreateAggregatorController

func CreateAggregatorController(registry metrics.Registry) *AggregatorController

CreateAggregatorController ...

func (*AggregatorController) Initialize

func (instance *AggregatorController) Initialize()

Initialize ...

func (*AggregatorController) Snapshot

func (instance *AggregatorController) Snapshot() AggregatorSnapShot

Snapshot ...

func (*AggregatorController) Start

func (instance *AggregatorController) Start()

Start ...

func (*AggregatorController) Stop

func (instance *AggregatorController) Stop()

Stop ...

type AggregatorInterfaceToRenameLater

type AggregatorInterfaceToRenameLater interface {
	Start()
	Stop()
	Initialize()
	Snapshot() AggregatorSnapShot
}

AggregatorInterfaceToRenameLater ...

func NewAggregator

func NewAggregator(registry metrics.Registry) AggregatorInterfaceToRenameLater

NewAggregator ...

type AggregatorSnapShot

type AggregatorSnapShot struct {
	Times      []int64                         `json:"times,omitempty"`
	Counters   map[string][]int64              `json:"counters,omitempty"`
	Gauges     map[string][]float64            `json:"gauges,omitempty"`
	Histograms Histogram                       `json:"histograms,omitempty"`
	Meters     map[string]map[string][]float64 `json:"meters,omitempty"`
	Timers     map[string]map[string][]float64 `json:"timers,omitempty"`
}

AggregatorSnapShot ...

func NewAggregatorSnapShot

func NewAggregatorSnapShot() *AggregatorSnapShot

NewAggregatorSnapShot ...

func (*AggregatorSnapShot) CreateSummary

func (this *AggregatorSnapShot) CreateSummary() core.ExecutionSummary

CreateSummary ...

func (*AggregatorSnapShot) Update

func (instance *AggregatorSnapShot) Update(output AggregatorSnapShot)

Update ...

type Histogram

type Histogram map[string]map[string][]int64