aggregatortest

Documentation

Index

• Constants
• func CheckedMerge(t *testing.T, aggInto, aggFrom aggregator.Aggregator, ...)
• func CheckedUpdate(t *testing.T, agg aggregator.Aggregator, number number.Number, ...)
• func NewAggregatorTest(mkind sdkapi.InstrumentKind, nkind number.Kind) *sdkapi.Descriptor
• func RunProfiles(t *testing.T, f func(*testing.T, Profile))
• func SynchronizedMoveResetTest(t *testing.T, mkind sdkapi.InstrumentKind, ...)
• func TestMain(m *testing.M)
• type NoopAggregation
  • func (NoopAggregation) Kind() aggregation.Kind
• type NoopAggregator
  • func (NoopAggregator) Aggregation() aggregation.Aggregation
  • func (NoopAggregator) Merge(aggregator.Aggregator, *sdkapi.Descriptor) error
  • func (NoopAggregator) SynchronizedMove(aggregator.Aggregator, *sdkapi.Descriptor) error
  • func (NoopAggregator) Update(context.Context, number.Number, *sdkapi.Descriptor) error
• type Numbers
  • func NewNumbers(kind number.Kind) Numbers
  • func (n *Numbers) Append(v number.Number)
  • func (n *Numbers) Count() uint64
  • func (n *Numbers) Len() int
  • func (n *Numbers) Less(i, j int) bool
  • func (n *Numbers) Max() number.Number
  • func (n *Numbers) Min() number.Number
  • func (n *Numbers) Points() []number.Number
  • func (n *Numbers) Sort()
  • func (n *Numbers) Sum() number.Number
  • func (n *Numbers) Swap(i, j int)
• type Profile

Constants

const Magnitude = 1000

Functions

func CheckedMerge

func CheckedMerge(t *testing.T, aggInto, aggFrom aggregator.Aggregator, descriptor *sdkapi.Descriptor)

func CheckedUpdate

func CheckedUpdate(t *testing.T, agg aggregator.Aggregator, number number.Number, descriptor *sdkapi.Descriptor)

CheckedUpdate performs the same range test the SDK does on behalf of the aggregator.

func NewAggregatorTest

func NewAggregatorTest(mkind sdkapi.InstrumentKind, nkind number.Kind) *sdkapi.Descriptor

func RunProfiles

func RunProfiles(t *testing.T, f func(*testing.T, Profile))

func SynchronizedMoveResetTest

func SynchronizedMoveResetTest(t *testing.T, mkind sdkapi.InstrumentKind, nf func(*sdkapi.Descriptor) aggregator.Aggregator)

func TestMain

func TestMain(m *testing.M)

TestMain ensures local struct alignment prior to running tests.

Types

type NoopAggregation

type NoopAggregation struct{}

func (NoopAggregation) Kind

func (NoopAggregation) Kind() aggregation.Kind

type NoopAggregator

type NoopAggregator struct{}

func (NoopAggregator) Aggregation

func (NoopAggregator) Aggregation() aggregation.Aggregation

func (NoopAggregator) Merge

func (NoopAggregator) Merge(aggregator.Aggregator, *sdkapi.Descriptor) error

func (NoopAggregator) SynchronizedMove

func (NoopAggregator) SynchronizedMove(aggregator.Aggregator, *sdkapi.Descriptor) error

func (NoopAggregator) Update

func (NoopAggregator) Update(context.Context, number.Number, *sdkapi.Descriptor) error

type Numbers

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

func NewNumbers

func NewNumbers(kind number.Kind) Numbers

func (*Numbers) Append

func (n *Numbers) Append(v number.Number)

func (*Numbers) Count

func (n *Numbers) Count() uint64

func (*Numbers) Len

func (n *Numbers) Len() int

func (*Numbers) Less

func (n *Numbers) Less(i, j int) bool

func (*Numbers) Max

func (n *Numbers) Max() number.Number

func (*Numbers) Min

func (n *Numbers) Min() number.Number

func (*Numbers) Points

func (n *Numbers) Points() []number.Number

func (*Numbers) Sort

func (n *Numbers) Sort()

func (*Numbers) Sum

func (n *Numbers) Sum() number.Number

func (*Numbers) Swap

func (n *Numbers) Swap(i, j int)

type Profile

type Profile struct {
	NumberKind number.Kind
	Random     func(sign int) number.Number
}