internalconsumertest

package
Version: v0.37.0 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ErrOrSinkConsumer

type ErrOrSinkConsumer struct {
	*consumertest.TracesSink
	*consumertest.MetricsSink
	// contains filtered or unexported fields
}

func (*ErrOrSinkConsumer) Capabilities added in v0.27.0

func (esc *ErrOrSinkConsumer) Capabilities() consumer.Capabilities

func (*ErrOrSinkConsumer) ConsumeMetrics

func (esc *ErrOrSinkConsumer) ConsumeMetrics(ctx context.Context, md pdata.Metrics) error

ConsumeMetrics stores metrics to this sink.

func (*ErrOrSinkConsumer) ConsumeTraces

func (esc *ErrOrSinkConsumer) ConsumeTraces(ctx context.Context, td pdata.Traces) error

ConsumeTraces stores traces to this sink.

func (*ErrOrSinkConsumer) Reset

func (esc *ErrOrSinkConsumer) Reset()

Reset deletes any stored in the sinks, resets error to nil.

func (*ErrOrSinkConsumer) SetConsumeError

func (esc *ErrOrSinkConsumer) SetConsumeError(err error)

SetConsumeError sets an error that will be returned by the Consume function.

Jump to

Keyboard shortcuts

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