aggregate

Documentation

Index

• func NewDiscard() core.Aggregator
• func NewLog() core.Aggregator
• type Test
  • func NewTest() *Test
  • func (t *Test) GetSamples() []core.Sample
  • func (t *Test) Report(s core.Sample)
  • func (t *Test) Run(ctx context.Context) error

Functions

func NewDiscard

func NewDiscard() core.Aggregator

NewDiscard returns Aggregator that just throws reported ammo away.

func NewLog

func NewLog() core.Aggregator

Types

type Test

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

func NewTest

func NewTest() *Test

func (*Test) GetSamples

func (t *Test) GetSamples() []core.Sample

func (*Test) Report

func (t *Test) Report(s core.Sample)

func (*Test) Run

func (t *Test) Run(ctx context.Context) error