aggregate

Documentation

Index

• type Accumulator
  • func Pipeline(ctx context.Context, in chan interface{}, newAccumulator func() Accumulator) Accumulator
• type Float64
  • func NewFloat64() Float64
  • func (a Float64) Add(key string, delta float64)
  • func (a Float64) Combine(b Float64)
  • func (a Float64) Keys() []string
  • func (a Float64) Ratio(numerator, denominator string) float64
  • func (a Float64) Total(key string) float64
• type Int
  • func NewInt() Int
  • func (a Int) Add(key string, delta int)
  • func (a Int) Combine(b Int)
  • func (a Int) Keys() []string
  • func (a Int) Ratio(numerator, denominator string) float64
  • func (a Int) Total(key string) int
• type Newest
  • func NewNewest() *Newest
  • func (a *Newest) Check(t time.Time)
  • func (a *Newest) Combine(t *Newest)
• type Oldest
  • func NewOldest() *Oldest
  • func (a *Oldest) Check(t time.Time)
  • func (a *Oldest) Combine(t *Oldest)

Types

type Accumulator

type Accumulator interface {
	Accumulate(context.Context, interface{})
	Combine(interface{})
}

Accumulator is an object that can accumulate statistics based on individual objects within a context.

func Pipeline

func Pipeline(
	ctx context.Context,
	in chan interface{},

	newAccumulator func() Accumulator,
) Accumulator

Pipeline runs a concurrent processing pipeline that executes a given function for every value read off of an input channel. The KeyValue object provided to the processor function is only accessable to one of the go routines within the pipeline.

type Float64

type Float64 map[string]float64

func NewFloat64

func NewFloat64() Float64

func (Float64) Add

func (a Float64) Add(key string, delta float64)

func (Float64) Combine

func (a Float64) Combine(b Float64)

func (Float64) Keys

func (a Float64) Keys() []string

func (Float64) Ratio

func (a Float64) Ratio(numerator, denominator string) float64

func (Float64) Total

func (a Float64) Total(key string) float64

type Int

type Int map[string]int

func NewInt

func NewInt() Int

func (Int) Add

func (a Int) Add(key string, delta int)

func (Int) Combine

func (a Int) Combine(b Int)

func (Int) Keys

func (a Int) Keys() []string

func (Int) Ratio

func (a Int) Ratio(numerator, denominator string) float64

func (Int) Total

func (a Int) Total(key string) int

type Newest

type Newest struct {
	Time  time.Time
	Valid bool
}

func NewNewest

func NewNewest() *Newest

func (*Newest) Check

func (a *Newest) Check(t time.Time)

func (*Newest) Combine

func (a *Newest) Combine(t *Newest)

type Oldest

type Oldest struct {
	Time  time.Time
	Valid bool
}

func NewOldest

func NewOldest() *Oldest

func (*Oldest) Check

func (a *Oldest) Check(t time.Time)

func (*Oldest) Combine

func (a *Oldest) Combine(t *Oldest)