package processortest

import "go.opentelemetry.io/otel/sdk/metric/processor/processortest"

Index ¶

• func AggregatorSelector() export.AggregatorSelector
• func MultiInstrumentationLibraryReader(records map[instrumentation.Library][]export.Record) export.InstrumentationLibraryReader
• func NewCheckpointer(p *Processor) export.Checkpointer
• func NewCheckpointerFactory(selector export.AggregatorSelector, encoder attribute.Encoder) export.CheckpointerFactory
• func OneInstrumentationLibraryReader(l instrumentation.Library, r export.Reader) export.InstrumentationLibraryReader
• type Exporter
• func New(selector aggregation.TemporalitySelector, encoder attribute.Encoder) *Exporter
• func (e *Exporter) Export(_ context.Context, res *resource.Resource, ckpt export.InstrumentationLibraryReader) error
• func (e *Exporter) ExportCount() int
• func (e *Exporter) Reset()
• func (e *Exporter) Values() map[string]float64
• type Output
• func NewOutput(attrEncoder attribute.Encoder) *Output
• func (o *Output) AddAccumulation(acc export.Accumulation) error
• func (o *Output) AddInstrumentationLibraryRecord(_ instrumentation.Library, rec export.Record) error
• func (o *Output) AddRecord(rec export.Record) error
• func (o *Output) AddRecordWithResource(rec export.Record, res *resource.Resource) error
• func (o *Output) ForEach(_ aggregation.TemporalitySelector, ff func(export.Record) error) error
• func (o *Output) Map() map[string]float64
• func (o *Output) Reset()
• type Processor
• func NewProcessor(selector export.AggregatorSelector, encoder attribute.Encoder) *Processor
• func (p *Processor) Process(accum export.Accumulation) error
• func (p *Processor) Reset()
• func (p *Processor) Values() map[string]float64

Functions ¶

func AggregatorSelector ¶

func AggregatorSelector() export.AggregatorSelector

AggregatorSelector returns a policy that is consistent with the test descriptors above. I.e., it returns sum.New() for counter instruments and lastvalue.New() for lastValue instruments.

func MultiInstrumentationLibraryReader ¶

func MultiInstrumentationLibraryReader(records map[instrumentation.Library][]export.Record) export.InstrumentationLibraryReader

MultiInstrumentationLibraryReader returns an InstrumentationLibraryReader for a group of records that came from multiple instrumentation libraries.

func NewCheckpointer ¶

func NewCheckpointer(p *Processor) export.Checkpointer

NewCheckpointer returns a new Checkpointer for Processor p.

func NewCheckpointerFactory ¶

func NewCheckpointerFactory(selector export.AggregatorSelector, encoder attribute.Encoder) export.CheckpointerFactory

NewCheckpointerFactory returns a new CheckpointerFactory for the selector and encoder pair.

func OneInstrumentationLibraryReader ¶

func OneInstrumentationLibraryReader(l instrumentation.Library, r export.Reader) export.InstrumentationLibraryReader

OneInstrumentationLibraryReader returns an InstrumentationLibraryReader for a single instrumentation library.

Types ¶

type Exporter ¶

type Exporter struct {
	aggregation.TemporalitySelector

	// InjectErr supports returning conditional errors from
	// the Export() routine.  This must be set before the
	// Exporter is first used.
	InjectErr func(export.Record) error
	// contains filtered or unexported fields
}

Exporter is a testing implementation of export.Exporter that assembles its results as a map[string]float64.

func New ¶

func New(selector aggregation.TemporalitySelector, encoder attribute.Encoder) *Exporter

New returns a new testing Exporter implementation. Verify exporter outputs using Values(), e.g.,:

require.EqualValues(t, map[string]float64{
    "counter.sum/A=1,B=2/R=V": 100,
}, exporter.Values())

Where in the example A=1,B=2 is the encoded attributes and R=V is the encoded resource value.

func (*Exporter) Export ¶

func (e *Exporter) Export(_ context.Context, res *resource.Resource, ckpt export.InstrumentationLibraryReader) error

Export records all the measurements aggregated in ckpt for res.

func (*Exporter) ExportCount ¶

func (e *Exporter) ExportCount() int

ExportCount returns the number of times Export() has been called since the last Reset().

func (*Exporter) Reset ¶

func (e *Exporter) Reset()

Reset sets the exporter's output to the initial, empty state and resets the export count to zero.

func (*Exporter) Values ¶

func (e *Exporter) Values() map[string]float64

Values returns the mapping from attribute set to point values for the accumulations that were processed. Point values are chosen as either the Sum or the LastValue, whichever is implemented. (All the built-in Aggregators implement one of these interfaces.)

type Output ¶

type Output struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Output implements export.Reader.

func NewOutput ¶

func NewOutput(attrEncoder attribute.Encoder) *Output

NewOutput is a helper for testing an expected set of Accumulations (from an Accumulator) or an expected set of Records (from a Processor). If testing with an Accumulator, it may be simpler to use the test Processor in this package.

func (*Output) AddAccumulation ¶

func (o *Output) AddAccumulation(acc export.Accumulation) error

AddAccumulation adds a string representation of the exported metric data to a map for use in testing. The value taken from the accumulation is either the Sum() or the LastValue() of its Aggregator().Aggregation(), whichever is defined.

func (*Output) AddInstrumentationLibraryRecord ¶

func (o *Output) AddInstrumentationLibraryRecord(_ instrumentation.Library, rec export.Record) error

AddRecordWithResource merges rec into this Output.

func (*Output) AddRecord ¶

func (o *Output) AddRecord(rec export.Record) error

AddRecord adds a string representation of the exported metric data to a map for use in testing. The value taken from the record is either the Sum() or the LastValue() of its Aggregation(), whichever is defined. Record timestamps are ignored.

func (*Output) AddRecordWithResource ¶

func (o *Output) AddRecordWithResource(rec export.Record, res *resource.Resource) error

AddRecordWithResource merges rec into this Output scoping it with res.

func (*Output) ForEach ¶

func (o *Output) ForEach(_ aggregation.TemporalitySelector, ff func(export.Record) error) error

ForEach implements export.Reader.

func (*Output) Map ¶

func (o *Output) Map() map[string]float64

Map returns the calculated values for test validation from a set of Accumulations or a set of Records. When mapping records or accumulations into floating point values, the Sum() or LastValue() is chosen, whichever is implemented by the underlying Aggregator.

func (*Output) Reset ¶

func (o *Output) Reset()

Reset restores the Output to its initial state, with no accumulated metric data.

type Processor ¶

type Processor struct {
	export.AggregatorSelector
	// contains filtered or unexported fields
}

Processor is a testing implementation of export.Processor that assembles its results as a map[string]float64.

func NewProcessor ¶

func NewProcessor(selector export.AggregatorSelector, encoder attribute.Encoder) *Processor

NewProcessor returns a new testing Processor implementation. Verify expected outputs using Values(), e.g.:

require.EqualValues(t, map[string]float64{
    "counter.sum/A=1,B=2/R=V": 100,
}, processor.Values())

Where in the example A=1,B=2 is the encoded attributes and R=V is the encoded resource value.

func (*Processor) Process ¶

func (p *Processor) Process(accum export.Accumulation) error

Process implements export.Processor.

func (*Processor) Reset ¶

func (p *Processor) Reset()

Reset clears the state of this test processor.

func (*Processor) Values ¶

func (p *Processor) Values() map[string]float64

Values returns the mapping from attribute set to point values for the accumulations that were processed. Point values are chosen as either the Sum or the LastValue, whichever is implemented. (All the built-in Aggregators implement one of these interfaces.)

Source Files ¶

test.go