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 returns a consumer.LogsConsumer that just drops all received data and returns no error.

func NewMetricsNop

func NewMetricsNop() consumer.MetricsConsumer

NewMetricsNop returns a consumer.MetricsConsumer that just drops all received data and returns no error.

func NewTracesNop

func NewTracesNop() consumer.TracesConsumer

NewTracesNop returns a consumer.TracesConsumer that just drops all received data and returns no error.

Types

type LogsSink

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

LogsSink is a consumer.LogsConsumer that acts like a sink that stores all logs and allows querying them for testing.

func (*LogsSink) AllLogs

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

AllLogs returns the logs stored by this sink since last Reset.

func (*LogsSink) ConsumeLogs

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

ConsumeLogs stores logs to this sink.

func (*LogsSink) LogRecordsCount

func (sle *LogsSink) LogRecordsCount() int

LogRecordsCount return the number of log records stored by this sink since last Reset.

func (*LogsSink) Reset

func (sle *LogsSink) Reset()

Reset deletes any stored data.

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 is a consumer.MetricsConsumer that acts like a sink that stores all metrics and allows querying them for testing.

func (*MetricsSink) AllMetrics

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

AllMetrics returns the metrics stored by this sink since last Reset.

func (*MetricsSink) ConsumeMetrics

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

ConsumeMetrics stores metrics to this sink.

func (*MetricsSink) MetricsCount

func (sme *MetricsSink) MetricsCount() int

MetricsCount return the number of metrics stored by this sink since last Reset.

func (*MetricsSink) Reset

func (sme *MetricsSink) Reset()

Reset deletes any stored data.

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 is a consumer.TracesConsumer that acts like a sink that stores all traces and allows querying them for testing.

func (*TracesSink) AllTraces

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

AllTraces returns the traces stored by this sink since last Reset.

func (*TracesSink) ConsumeTraces

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

ConsumeTraces stores traces to this sink.

func (*TracesSink) Reset

func (ste *TracesSink) Reset()

Reset deletes any stored data.

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 this sink.