stats

package

v0.0.0-...-e5f9aec Latest Latest Go to latest Published: Oct 28, 2022 License: Apache-2.0 Imports: 8 Imported by: 1

Details

This section is empty.

This section is empty.

func DefaultExecutor(handler func(ctx context.Context))

type Collector interface {
	Collect(point *Point)
}

type CounterMonoid uint64

func (monoid *CounterMonoid) Add(that Monoid)

func (monoid *CounterMonoid) Export() float64

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

func NewEventAggregator(cfg EventAggregatorConfig) *EventAggregator

func (aggregator *EventAggregator) HandlerOf(site *spi.LogSite) spi.EventHandler

type EventAggregatorConfig struct {
	Executor  Executor
	Collector Collector
}

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

type MapMonoid map[interface{}]Monoid

func (monoid MapMonoid) Add(that MapMonoid)

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

func NewCounterMonoid() Monoid

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

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

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

func (window *Window) Export(now time.Time)

func (window *Window) Mutate() (*sync.Mutex, MapMonoid)