dptest

Documentation

Index

• func DP() *datapoint.Datapoint
• type BasicSink
  • func NewBasicSink() *BasicSink
  • func (f *BasicSink) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error
  • func (f *BasicSink) Next() *datapoint.Datapoint
  • func (f *BasicSink) Resize(size int)
  • func (f *BasicSink) RetError(err error)
• type DatapointSource
  • func (d *DatapointSource) Next() *datapoint.Datapoint

Functions

func DP

func DP() *datapoint.Datapoint

DP generates and returns a unique datapoint to use for testing purposes

Types

type BasicSink

type BasicSink struct {
	RetErr     error
	PointsChan chan []*datapoint.Datapoint
	// contains filtered or unexported fields
}

BasicSink is a pure testing sink that blocks forwarded points onto a channel

func NewBasicSink

func NewBasicSink() *BasicSink

NewBasicSink creates a BasicSink with an unbuffered chan. Note, calls to AddDatapoints will then block until you drain the PointsChan.

func (*BasicSink) AddDatapoints

func (f *BasicSink) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error

AddDatapoints buffers the point on an internal chan or returns errors if RetErr is set

func (*BasicSink) Next

func (f *BasicSink) Next() *datapoint.Datapoint

Next returns a single datapoint from the top of PointsChan and panics if the top doesn't contain only one point

func (*BasicSink) Resize

func (f *BasicSink) Resize(size int)

Resize the internal chan of points sent here

func (*BasicSink) RetError

func (f *BasicSink) RetError(err error)

RetError sets an error that is returned on AddDatapoints calls

type DatapointSource

type DatapointSource struct {
	CurrentIndex int64
	Metric       string
	Dims         map[string]string
	Dptype       datapoint.MetricType
	TimeSource   func() time.Time
	// contains filtered or unexported fields
}

DatapointSource is a simple way to generate throw away datapoints

func (*DatapointSource) Next

func (d *DatapointSource) Next() *datapoint.Datapoint

Next returns a unique datapoint