dptest

Documentation

Index

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

Functions

func DP

func DP() *datapoint.Datapoint

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

func E

func E() *event.Event

E generates and returns a unique event to use for testing purposes

Types

type BasicSink

type BasicSink struct {
	RetErr     error
	PointsChan chan []*datapoint.Datapoint
	EventsChan chan []*event.Event
	// 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) AddEvents

func (f *BasicSink) AddEvents(ctx context.Context, points []*event.Event) error

AddEvents buffers the event 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) NextEvent

func (f *BasicSink) NextEvent() *event.Event

NextEvent returns a single event from the top of EventsChan and panics if the top doesn't contain only one event

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

type EventSource

type EventSource struct {
	CurrentIndex int64
	EventType    string
	Dims         map[string]string
	Meta         map[string]interface{}
	TimeSource   func() time.Time
	// contains filtered or unexported fields
}

EventSource is a simple way to generate throw away events

func (*EventSource) Next

func (d *EventSource) Next() *event.Event

Next returns a unique event