processortest

Documentation

Index

• func CompareLogs(t *testing.T, expected, actual plog.Logs)
• func CompareMetrics(t *testing.T, expected, actual pmetric.Metrics)
• func CompareTraces(t *testing.T, expected, actual ptrace.Traces)
• func CreateTestLogs(logJson string) plog.Logs
• func CreateTestMetrics(metricJson string) pmetric.Metrics
• func CreateTestTraces(traceJson string) ptrace.Traces
• func TestRunProcessor(c ProcessorRunConfig)
• type ProcessorRunConfig
• type Signal
  • func NewLogSignal(inputJson string, expectedOutputJson string) Signal
  • func NewMetricSignal(inputJson string, expectedOutputJson string) Signal
  • func NewTraceSignal(inputJson string, expectedOutputJson string) Signal
  • func NewTraceToLogSignal(inputJson string, expectedOutputJson string) Signal
  • func NewTraceToMetricSignal(inputJson string, expectedOutputJson string) Signal

Functions

func CompareLogs

func CompareLogs(t *testing.T, expected, actual plog.Logs)

func CompareMetrics

func CompareMetrics(t *testing.T, expected, actual pmetric.Metrics)

func CompareTraces

func CompareTraces(t *testing.T, expected, actual ptrace.Traces)

func CreateTestLogs

func CreateTestLogs(logJson string) plog.Logs

logJson should match format from the protobuf definition: https://github.com/open-telemetry/opentelemetry-proto/blob/main/opentelemetry/proto/logs/v1/logs.proto

func CreateTestMetrics

func CreateTestMetrics(metricJson string) pmetric.Metrics

metricJson should match format from the protobuf definition: https://github.com/open-telemetry/opentelemetry-proto/blob/main/opentelemetry/proto/metrics/v1/metrics.proto

func CreateTestTraces

func CreateTestTraces(traceJson string) ptrace.Traces

traceJson should match format from the protobuf definition: https://github.com/open-telemetry/opentelemetry-proto/blob/main/opentelemetry/proto/trace/v1/trace.proto

func TestRunProcessor

func TestRunProcessor(c ProcessorRunConfig)

Types

type ProcessorRunConfig

type ProcessorRunConfig struct {
	Ctx        context.Context
	T          *testing.T
	Args       component.Arguments
	TestSignal Signal
	Ctrl       *componenttest.Controller
	L          log.Logger
}

type Signal

type Signal interface {
	MakeOutput() *otelcol.ConsumerArguments
	ConsumeInput(ctx context.Context, consumer otelcol.Consumer) error
	CheckOutput(t *testing.T)
}

func NewLogSignal

func NewLogSignal(inputJson string, expectedOutputJson string) Signal

func NewMetricSignal

func NewMetricSignal(inputJson string, expectedOutputJson string) Signal

func NewTraceSignal

func NewTraceSignal(inputJson string, expectedOutputJson string) Signal

func NewTraceToLogSignal

func NewTraceToLogSignal(inputJson string, expectedOutputJson string) Signal

func NewTraceToMetricSignal

func NewTraceToMetricSignal(inputJson string, expectedOutputJson string) Signal

Any timestamps inside expectedOutputJson should be set to 0.