dptest

package
Version: v2.5.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 4, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

func ExactlyOne

func ExactlyOne(dps []*datapoint.Datapoint, metricName string) *datapoint.Datapoint

ExactlyOne returns the datapoint with metricName and panics if there is not exactly one in dps

func ExactlyOneDims

func ExactlyOneDims(dps []*datapoint.Datapoint, metricName string, dims map[string]string) *datapoint.Datapoint

ExactlyOneDims returns the datapoint with metricName and dims, and panics if there is not exactly one

func S

func S() *trace.Span

S generates and returns a unique span to use for testing purposes

Types

type BasicSink

type BasicSink struct {
	RetErr     error
	PointsChan chan []*datapoint.Datapoint
	EventsChan chan []*event.Event
	TracesChan chan []*trace.Span
	// 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) AddSpans added in v1.1.5

func (f *BasicSink) AddSpans(ctx context.Context, points []*trace.Span) error

AddSpans buffers the trace 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) NextSpan

func (f *BasicSink) NextSpan() *trace.Span

NextSpan returns a single span from the top of TracesChan and panics if the top doesn't contain only one span

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
	Category     event.Category
	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

type SpanSource

type SpanSource struct {
	TimeSource   func() int64
	Name         string
	CurrentIndex int64
	// contains filtered or unexported fields
}

SpanSource is a simple way to generate throw away spans

func (*SpanSource) Next

func (d *SpanSource) Next() *trace.Span

Next return a unique span

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL