processortest

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL