testcomponents

Documentation

Index

• Variables
• type ExampleConnector
  • func (c *ExampleConnector) Capabilities() consumer.Capabilities
  • func (cs *ExampleConnector) Shutdown(_ context.Context) error
  • func (cs *ExampleConnector) Start(_ context.Context, _ component.Host) error
  • func (cs *ExampleConnector) Started() bool
  • func (cs *ExampleConnector) Stopped() bool
• 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 (cs *ExampleExporter) Shutdown(_ context.Context) error
  • func (cs *ExampleExporter) Start(_ context.Context, _ component.Host) error
  • func (cs *ExampleExporter) Started() bool
  • func (cs *ExampleExporter) Stopped() bool
• type ExampleProcessor
  • func (ep *ExampleProcessor) Capabilities() consumer.Capabilities
  • func (cs *ExampleProcessor) Shutdown(_ context.Context) error
  • func (cs *ExampleProcessor) Start(_ context.Context, _ component.Host) error
  • func (cs *ExampleProcessor) Started() bool
  • func (cs *ExampleProcessor) Stopped() bool
• type ExampleReceiver
  • func (cs *ExampleReceiver) Shutdown(_ context.Context) error
  • func (cs *ExampleReceiver) Start(_ context.Context, _ component.Host) error
  • func (cs *ExampleReceiver) Started() bool
  • func (cs *ExampleReceiver) Stopped() bool

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
	// contains filtered or unexported fields
}

func (*ExampleConnector) Capabilities

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

func (*ExampleConnector) Shutdown

func (cs *ExampleConnector) Shutdown(_ context.Context) error

func (*ExampleConnector) Start

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

func (*ExampleConnector) Started

func (cs *ExampleConnector) Started() bool

func (*ExampleConnector) Stopped

func (cs *ExampleConnector) Stopped() bool

type ExampleExporter

type ExampleExporter struct {
	Traces  []ptrace.Traces
	Metrics []pmetric.Metrics
	Logs    []plog.Logs
	// contains filtered or unexported fields
}

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

ConsumeLogs receives plog.Logs for processing by the Logs.

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 (cs *ExampleExporter) Shutdown(_ context.Context) error

func (*ExampleExporter) Start

func (cs *ExampleExporter) Start(_ context.Context, _ component.Host) error

func (*ExampleExporter) Started

func (cs *ExampleExporter) Started() bool

func (*ExampleExporter) Stopped

func (cs *ExampleExporter) Stopped() bool

type ExampleProcessor

type ExampleProcessor struct {
	consumer.ConsumeTracesFunc
	consumer.ConsumeMetricsFunc
	consumer.ConsumeLogsFunc
	// contains filtered or unexported fields
}

func (*ExampleProcessor) Capabilities

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

func (*ExampleProcessor) Shutdown

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

func (*ExampleProcessor) Start

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

func (*ExampleProcessor) Started

func (cs *ExampleProcessor) Started() bool

func (*ExampleProcessor) Stopped

func (cs *ExampleProcessor) Stopped() bool

type ExampleReceiver

type ExampleReceiver struct {
	consumer.ConsumeTracesFunc
	consumer.ConsumeMetricsFunc
	consumer.ConsumeLogsFunc
	// contains filtered or unexported fields
}

ExampleReceiver allows producing traces and metrics for testing purposes.

func (*ExampleReceiver) Shutdown

func (cs *ExampleReceiver) Shutdown(_ context.Context) error

func (*ExampleReceiver) Start

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

func (*ExampleReceiver) Started

func (cs *ExampleReceiver) Started() bool

func (*ExampleReceiver) Stopped

func (cs *ExampleReceiver) Stopped() bool