internalconsumertest

Documentation

Index

• type ErrOrSinkConsumer
  • func (esc *ErrOrSinkConsumer) Capabilities() consumer.Capabilities
  • func (esc *ErrOrSinkConsumer) ConsumeMetrics(ctx context.Context, md pdata.Metrics) error
  • func (esc *ErrOrSinkConsumer) ConsumeTraces(ctx context.Context, td pdata.Traces) error
  • func (esc *ErrOrSinkConsumer) Reset()
  • func (esc *ErrOrSinkConsumer) SetConsumeError(err error)

Types

type ErrOrSinkConsumer

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

func (*ErrOrSinkConsumer) Capabilities

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.