testcomponents

Documentation

Index

• Variables
• type ExampleConnector
  • func (c *ExampleConnector) Capabilities() consumer.Capabilities
  • func (c *ExampleConnector) Shutdown(context.Context) error
  • func (c *ExampleConnector) Start(_ context.Context, _ component.Host) error
• type ExampleExporter
  • func (exp *ExampleExporter) Capabilities() consumer.Capabilities
  • func (exp *ExampleExporter) ConsumeLogs(_ context.Context, ld plog.Logs) error
  • func (exp *ExampleExporter) ConsumeMetrics(_ context.Context, md pmetric.Metrics) error
  • func (exp *ExampleExporter) ConsumeTraces(_ context.Context, td ptrace.Traces) error
  • func (exp *ExampleExporter) Shutdown(context.Context) error
  • func (exp *ExampleExporter) Start(_ context.Context, _ component.Host) error
• type ExampleProcessor
  • func (ep *ExampleProcessor) Capabilities() consumer.Capabilities
  • func (ep *ExampleProcessor) Shutdown(_ context.Context) error
  • func (ep *ExampleProcessor) Start(_ context.Context, _ component.Host) error
• type ExampleReceiver
  • func (erp *ExampleReceiver) Shutdown(context.Context) error
  • func (erp *ExampleReceiver) Start(_ context.Context, _ component.Host) error

Variables

var ExampleConnectorFactory = connector.NewFactory(
	connType,
	createExampleConnectorDefaultConfig,

	connector.WithTracesToTraces(createExampleTracesToTraces, component.StabilityLevelDevelopment),
	connector.WithTracesToMetrics(createExampleTracesToMetrics, component.StabilityLevelDevelopment),
	connector.WithTracesToLogs(createExampleTracesToLogs, component.StabilityLevelDevelopment),

	connector.WithMetricsToTraces(createExampleMetricsToTraces, component.StabilityLevelDevelopment),
	connector.WithMetricsToMetrics(createExampleMetricsToMetrics, component.StabilityLevelDevelopment),
	connector.WithMetricsToLogs(createExampleMetricsToLogs, component.StabilityLevelDevelopment),

	connector.WithLogsToTraces(createExampleLogsToTraces, component.StabilityLevelDevelopment),
	connector.WithLogsToMetrics(createExampleLogsToMetrics, component.StabilityLevelDevelopment),
	connector.WithLogsToLogs(createExampleLogsToLogs, component.StabilityLevelDevelopment),
)

ExampleConnectorFactory is factory for ExampleConnector.

var ExampleExporterFactory = exporter.NewFactory(
	typeStr,
	createExporterDefaultConfig,
	exporter.WithTraces(createTracesExporter, stability),
	exporter.WithMetrics(createMetricsExporter, stability),
	exporter.WithLogs(createLogsExporter, stability),
)

ExampleExporterFactory is factory for ExampleExporter.

var ExampleProcessorFactory = processor.NewFactory(
	procType,
	createDefaultConfig,
	processor.WithTraces(createTracesProcessor, component.StabilityLevelDevelopment),
	processor.WithMetrics(createMetricsProcessor, component.StabilityLevelDevelopment),
	processor.WithLogs(createLogsProcessor, component.StabilityLevelDevelopment))

ExampleProcessorFactory is factory for ExampleProcessor.

var ExampleReceiverFactory = receiver.NewFactory(
	receiverType,
	createReceiverDefaultConfig,
	receiver.WithTraces(createTracesReceiver, component.StabilityLevelDevelopment),
	receiver.WithMetrics(createMetricsReceiver, component.StabilityLevelDevelopment),
	receiver.WithLogs(createLogsReceiver, component.StabilityLevelDevelopment))

ExampleReceiverFactory is factory for ExampleReceiver.

Types

type ExampleConnector

type ExampleConnector struct {
	consumer.ConsumeTracesFunc
	consumer.ConsumeMetricsFunc
	consumer.ConsumeLogsFunc
	Started bool
	Stopped bool
}

func (*ExampleConnector) Capabilities

func (c *ExampleConnector) Capabilities() consumer.Capabilities

func (*ExampleConnector) Shutdown

func (c *ExampleConnector) Shutdown(context.Context) error

Shutdown is invoked during shutdown.

func (*ExampleConnector) Start

func (c *ExampleConnector) Start(_ context.Context, _ component.Host) error

Start tells the Connector to start.

type ExampleExporter

type ExampleExporter struct {
	Traces  []ptrace.Traces
	Metrics []pmetric.Metrics
	Logs    []plog.Logs
	Started bool
	Stopped bool
}

ExampleExporter stores consumed traces and metrics for testing purposes.

func (*ExampleExporter) Capabilities

func (exp *ExampleExporter) Capabilities() consumer.Capabilities

func (*ExampleExporter) ConsumeLogs

func (exp *ExampleExporter) ConsumeLogs(_ context.Context, ld plog.Logs) error

func (*ExampleExporter) ConsumeMetrics

func (exp *ExampleExporter) ConsumeMetrics(_ context.Context, md pmetric.Metrics) error

ConsumeMetrics receives pmetric.Metrics for processing by the Metrics.

func (*ExampleExporter) ConsumeTraces

func (exp *ExampleExporter) ConsumeTraces(_ context.Context, td ptrace.Traces) error

ConsumeTraces receives ptrace.Traces for processing by the consumer.Traces.

func (*ExampleExporter) Shutdown

func (exp *ExampleExporter) Shutdown(context.Context) error

Shutdown is invoked during shutdown.

func (*ExampleExporter) Start

func (exp *ExampleExporter) 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 ExampleProcessor

type ExampleProcessor struct {
	consumer.Traces
	consumer.Metrics
	consumer.Logs
	Started bool
	Stopped bool
}

func (*ExampleProcessor) Capabilities

func (ep *ExampleProcessor) Capabilities() consumer.Capabilities

func (*ExampleProcessor) Shutdown

func (ep *ExampleProcessor) Shutdown(_ context.Context) error

func (*ExampleProcessor) Start

func (ep *ExampleProcessor) Start(_ context.Context, _ component.Host) error

type ExampleReceiver

type ExampleReceiver struct {
	consumer.Traces
	consumer.Metrics
	consumer.Logs
	Started bool
	Stopped bool
}

ExampleReceiver allows producing traces and metrics for testing purposes.

func (*ExampleReceiver) Shutdown

func (erp *ExampleReceiver) Shutdown(context.Context) error

Shutdown tells the receiver that should stop reception,

func (*ExampleReceiver) Start

func (erp *ExampleReceiver) Start(_ context.Context, _ component.Host) error

Start tells the receiver to start its processing.