exportertest

Documentation

Index

• func NewNopLogsExporter() component.LogsExporter
• func NewNopMetricsExporter() component.MetricsExporter
• func NewNopTraceExporter() component.TraceExporter
• type SinkLogsExporter
  • func (sle *SinkLogsExporter) AllLogs() []pdata.Logs
  • func (sle *SinkLogsExporter) ConsumeLogs(_ context.Context, ld pdata.Logs) error
  • func (sle *SinkLogsExporter) LogRecordsCount() int
  • func (sle *SinkLogsExporter) Reset()
  • func (sle *SinkLogsExporter) SetConsumeLogError(err error)
  • func (sle *SinkLogsExporter) Shutdown(context.Context) error
  • func (sle *SinkLogsExporter) Start(context.Context, component.Host) error
• type SinkMetricsExporter
  • func (sme *SinkMetricsExporter) AllMetrics() []pdata.Metrics
  • func (sme *SinkMetricsExporter) ConsumeMetrics(_ context.Context, md pdata.Metrics) error
  • func (sme *SinkMetricsExporter) MetricsCount() int
  • func (sme *SinkMetricsExporter) Reset()
  • func (sme *SinkMetricsExporter) SetConsumeMetricsError(err error)
  • func (sme *SinkMetricsExporter) Shutdown(context.Context) error
  • func (sme *SinkMetricsExporter) Start(context.Context, component.Host) error
• type SinkTraceExporter
  • func (ste *SinkTraceExporter) AllTraces() []pdata.Traces
  • func (ste *SinkTraceExporter) ConsumeTraces(_ context.Context, td pdata.Traces) error
  • func (ste *SinkTraceExporter) Reset()
  • func (ste *SinkTraceExporter) SetConsumeTraceError(err error)
  • func (ste *SinkTraceExporter) Shutdown(context.Context) error
  • func (ste *SinkTraceExporter) SpansCount() int
  • func (ste *SinkTraceExporter) Start(context.Context, component.Host) error

Functions

func NewNopLogsExporter

func NewNopLogsExporter() component.LogsExporter

NewNopLogsExporter creates an LogsExporter that just drops the received data.

func NewNopMetricsExporter

func NewNopMetricsExporter() component.MetricsExporter

NewNopMetricsExporter creates an MetricsExporter that just drops the received data.

func NewNopTraceExporter

func NewNopTraceExporter() component.TraceExporter

NewNopTraceExporter creates an TraceExporter that just drops the received data.

Types

type SinkLogsExporter

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

SinkLogsExporter acts as a metrics receiver for use in tests.

func (*SinkLogsExporter) AllLogs

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

AllLog returns the metrics sent to the test sink.

func (*SinkLogsExporter) ConsumeLogs

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

ConsumeLogData stores traces for tests.

func (*SinkLogsExporter) LogRecordsCount

func (sle *SinkLogsExporter) LogRecordsCount() int

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

func (*SinkLogsExporter) Reset

func (sle *SinkLogsExporter) Reset()

Reset deletes any existing logs.

func (*SinkLogsExporter) SetConsumeLogError

func (sle *SinkLogsExporter) SetConsumeLogError(err error)

SetConsumeLogError sets an error that will be returned by ConsumeLog

func (*SinkLogsExporter) Shutdown

func (sle *SinkLogsExporter) Shutdown(context.Context) error

Shutdown stops the exporter and is invoked during shutdown.

func (*SinkLogsExporter) Start

func (sle *SinkLogsExporter) Start(context.Context, component.Host) error

Start tells the exporter to start. The exporter may prepare for exporting by connecting to the endpoint. Host parameter can be used for communicating with the host after Start() has already returned.

type SinkMetricsExporter

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

SinkMetricsExporter acts as a metrics receiver for use in tests.

func (*SinkMetricsExporter) AllMetrics

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

AllMetrics returns the metrics sent to the test sink.

func (*SinkMetricsExporter) ConsumeMetrics

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

ConsumeMetricsData stores traces for tests.

func (*SinkMetricsExporter) MetricsCount

func (sme *SinkMetricsExporter) MetricsCount() int

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

func (*SinkMetricsExporter) Reset

func (sme *SinkMetricsExporter) Reset()

Reset deletes any existing metrics.

func (*SinkMetricsExporter) SetConsumeMetricsError

func (sme *SinkMetricsExporter) SetConsumeMetricsError(err error)

SetConsumeMetricsError sets an error that will be returned by ConsumeMetrics

func (*SinkMetricsExporter) Shutdown

func (sme *SinkMetricsExporter) Shutdown(context.Context) error

Shutdown stops the exporter and is invoked during shutdown.

func (*SinkMetricsExporter) Start

func (sme *SinkMetricsExporter) Start(context.Context, component.Host) error

Start tells the exporter to start. The exporter may prepare for exporting by connecting to the endpoint. Host parameter can be used for communicating with the host after Start() has already returned.

type SinkTraceExporter

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

SinkTraceExporter acts as a trace receiver for use in tests.

func (*SinkTraceExporter) AllTraces

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

AllTraces returns the traces sent to the test sink.

func (*SinkTraceExporter) ConsumeTraces

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

ConsumeTraceData stores traces for tests.

func (*SinkTraceExporter) Reset

func (ste *SinkTraceExporter) Reset()

Reset deletes any existing metrics.

func (*SinkTraceExporter) SetConsumeTraceError

func (ste *SinkTraceExporter) SetConsumeTraceError(err error)

SetConsumeTraceError sets an error that will be returned by ConsumeTraces

func (*SinkTraceExporter) Shutdown

func (ste *SinkTraceExporter) Shutdown(context.Context) error

Shutdown stops the exporter and is invoked during shutdown.

func (*SinkTraceExporter) SpansCount

func (ste *SinkTraceExporter) SpansCount() int

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

func (*SinkTraceExporter) Start

func (ste *SinkTraceExporter) Start(context.Context, component.Host) error

Start tells the exporter to start. The exporter may prepare for exporting by connecting to the endpoint. Host parameter can be used for communicating with the host after Start() has already returned.