consumertest

Documentation

Index

• func NewLogsNop() consumer.LogsConsumer
• func NewMetricsNop() consumer.MetricsConsumer
• func NewTracesNop() consumer.TracesConsumer
• type LogsSink
  • func (sle *LogsSink) AllLogs() []pdata.Logs
  • func (sle *LogsSink) ConsumeLogs(_ context.Context, ld pdata.Logs) error
  • func (sle *LogsSink) LogRecordsCount() int
  • func (sle *LogsSink) Reset()
  • func (bec *LogsSink) SetConsumeError(err error)
• type MetricsSink
  • func (sme *MetricsSink) AllMetrics() []pdata.Metrics
  • func (sme *MetricsSink) ConsumeMetrics(_ context.Context, md pdata.Metrics) error
  • func (sme *MetricsSink) MetricsCount() int
  • func (sme *MetricsSink) Reset()
  • func (bec *MetricsSink) SetConsumeError(err error)
• type TracesSink
  • func (ste *TracesSink) AllTraces() []pdata.Traces
  • func (ste *TracesSink) ConsumeTraces(_ context.Context, td pdata.Traces) error
  • func (ste *TracesSink) Reset()
  • func (bec *TracesSink) SetConsumeError(err error)
  • func (ste *TracesSink) SpansCount() int

Functions

func NewLogsNop

func NewLogsNop() consumer.LogsConsumer

NewLogsNop creates an LogsConsumer that just drops the received data.

func NewMetricsNop

func NewMetricsNop() consumer.MetricsConsumer

NewMetricsNop creates an MetricsConsumer that just drops the received data.

func NewTracesNop

func NewTracesNop() consumer.TracesConsumer

NewTracesNop creates an TraceConsumer that just drops the received data.

Types

type LogsSink

type LogsSink struct {
	// contains filtered or unexported fields
}

LogsSink acts as a metrics receiver for use in tests.

func (*LogsSink) AllLogs

func (sle *LogsSink) AllLogs() []pdata.Logs

AllLog returns the metrics sent to the test sink.

func (*LogsSink) ConsumeLogs

func (sle *LogsSink) ConsumeLogs(_ context.Context, ld pdata.Logs) error

ConsumeLogData stores traces for tests.

func (*LogsSink) LogRecordsCount

func (sle *LogsSink) LogRecordsCount() int

LogRecordsCount return the number of log records sent to the test sing.

func (*LogsSink) Reset

func (sle *LogsSink) Reset()

Reset deletes any existing logs.

func (*LogsSink) SetConsumeError

func (bec *LogsSink) SetConsumeError(err error)

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

type MetricsSink

type MetricsSink struct {
	// contains filtered or unexported fields
}

MetricsSink acts as a metrics receiver for use in tests.

func (*MetricsSink) AllMetrics

func (sme *MetricsSink) AllMetrics() []pdata.Metrics

AllMetrics returns the metrics sent to the test sink.

func (*MetricsSink) ConsumeMetrics

func (sme *MetricsSink) ConsumeMetrics(_ context.Context, md pdata.Metrics) error

ConsumeMetricsData stores traces for tests.

func (*MetricsSink) MetricsCount

func (sme *MetricsSink) MetricsCount() int

MetricsCount return the number of metrics sent to the test sing.

func (*MetricsSink) Reset

func (sme *MetricsSink) Reset()

Reset deletes any existing metrics.

func (*MetricsSink) SetConsumeError

func (bec *MetricsSink) SetConsumeError(err error)

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

type TracesSink

type TracesSink struct {
	// contains filtered or unexported fields
}

TracesSink acts as a trace receiver for use in tests.

func (*TracesSink) AllTraces

func (ste *TracesSink) AllTraces() []pdata.Traces

AllTraces returns the traces sent to the test sink.

func (*TracesSink) ConsumeTraces

func (ste *TracesSink) ConsumeTraces(_ context.Context, td pdata.Traces) error

ConsumeTraceData stores traces for tests.

func (*TracesSink) Reset

func (ste *TracesSink) Reset()

Reset deletes any existing metrics.

func (*TracesSink) SetConsumeError

func (bec *TracesSink) SetConsumeError(err error)

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

func (*TracesSink) SpansCount

func (ste *TracesSink) SpansCount() int

SpansCount return the number of spans sent to the test sing.