accumulators

Documentation

Overview

Package accumulators ... count = Total = last sample value gauge = Total = last sample value counter = Total = sum of sample values

Index

• type Accumulator
  • func NewAccumulator(t ...string) Accumulator
  • func (a *Accumulator) Config() *config.Config
  • func (a Accumulator) Drain() []*entities.Entity
  • func (a *Accumulator) GetEntity(e *loggregator_v2.Envelope, attrs *attributes.Attributes) *entities.Entity
  • func (a Accumulator) Streams() []string
• type EnvelopeTypes
• type Interface

Types

type Accumulator

type Accumulator struct {
	Entities      *entities.Map
	EnvelopeTypes []string
	// contains filtered or unexported fields
}

Accumulator Universal handler for Firehose Envelopes

func NewAccumulator

func NewAccumulator(t ...string) Accumulator

NewAccumulator is generic and requires .Interface to be set func NewAccumulator(t ...events.Envelope_EventType) Accumulator {

func (*Accumulator) Config

func (a *Accumulator) Config() *config.Config

Config properties ...

func (Accumulator) Drain

func (a Accumulator) Drain() []*entities.Entity

Drain ...

func (*Accumulator) GetEntity

func (a *Accumulator) GetEntity(
	e *loggregator_v2.Envelope,
	attrs *attributes.Attributes,
) *entities.Entity

GetEntity ...

func (Accumulator) Streams

func (a Accumulator) Streams() []string

Streams ...

type EnvelopeTypes

type EnvelopeTypes []string

EnvelopeTypes ..

type Interface

type Interface interface {
	New() Interface
	Update(*loggregator_v2.Envelope)
	Streams() []string
	HarvestMetrics(*entities.Entity, *metrics.Metric)
	Drain() []*entities.Entity
}

Interface ensures Firehose Envelope consumption