stats

type Collector interface {
	Collect(point *Point)
}

type CounterMonoid uint64

type EventAggregator struct {
	Executor  Executor
	Collector Collector
}

type Executor func(func(ctx context.Context))

type MapMonoid map[interface{}]Monoid

type Monoid interface {
	Add(that Monoid)
	Export() float64
}

type Point struct {
	Event     string
	Timestamp time.Time
	Dimension []string
	Value     float64
}

type State interface {
	logger.EventHandler
	GetWindow() *Window
}

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