integration

Documentation

Index

• Constants
• func FilteringScenario(t *testing.T, dataProvider testbed.DataProvider, senderFunc SenderFunc, ...)
• func NewOTLPLogsDataSenderWrapper(host string, port int) testbed.DataSender
• func NewOTLPMetricDataSenderWrapper(host string, port int) testbed.DataSender
• func NewOTLPTraceDataSenderWrapper(host string, port int) testbed.DataSender
• func NewSampleConfigsLogsDataProvider(logs plog.Logs) testbed.DataProvider
• func NewSampleConfigsMetricsDataProvider(metrics pmetric.Metrics) testbed.DataProvider
• func NewSampleConfigsTraceDataProvider(traces ptrace.Traces) testbed.DataProvider
• func WithHiddenLogsValidationErrorMessages() func(validator *LogsValidator)
• func WithHiddenMetricsValidationErrorMessages() func(validator *MetricsValidator)
• func WithHiddenTracesValidationErrorMessages() func(*TraceValidator)
• type LogsValidator
  • func NewLogsValidator(t *testing.T, expectedLogs []plog.Logs, opts ...func(*LogsValidator)) *LogsValidator
  • func (v *LogsValidator) RecordResults(tc *testbed.TestCase)
  • func (v *LogsValidator) Validate(tc *testbed.TestCase)
• type MetricsValidator
  • func NewMetricValidator(t *testing.T, expectedMetrics []pmetric.Metrics, ...) *MetricsValidator
  • func (v *MetricsValidator) RecordResults(tc *testbed.TestCase)
  • func (v *MetricsValidator) Validate(tc *testbed.TestCase)
• type ReceiverFunc
• type SenderFunc
• type TraceValidator
  • func NewTraceValidator(t *testing.T, expectedTraces []ptrace.Traces, opts ...func(*TraceValidator)) *TraceValidator
  • func (v *TraceValidator) RecordResults(tc *testbed.TestCase)
  • func (v *TraceValidator) Validate(tc *testbed.TestCase)

Constants

const ConfigExamplesDir = "../../../config_examples"

Functions

func FilteringScenario

func FilteringScenario(
	t *testing.T,
	dataProvider testbed.DataProvider,
	senderFunc SenderFunc,
	receiverFunc ReceiverFunc,
	validator testbed.TestCaseValidator,
	configName string,
)

func NewOTLPLogsDataSenderWrapper

func NewOTLPLogsDataSenderWrapper(host string, port int) testbed.DataSender

func NewOTLPMetricDataSenderWrapper

func NewOTLPMetricDataSenderWrapper(host string, port int) testbed.DataSender

func NewOTLPTraceDataSenderWrapper

func NewOTLPTraceDataSenderWrapper(host string, port int) testbed.DataSender

func NewSampleConfigsLogsDataProvider

func NewSampleConfigsLogsDataProvider(logs plog.Logs) testbed.DataProvider

func NewSampleConfigsMetricsDataProvider

func NewSampleConfigsMetricsDataProvider(metrics pmetric.Metrics) testbed.DataProvider

func NewSampleConfigsTraceDataProvider

func NewSampleConfigsTraceDataProvider(traces ptrace.Traces) testbed.DataProvider

func WithHiddenLogsValidationErrorMessages

func WithHiddenLogsValidationErrorMessages() func(validator *LogsValidator)

func WithHiddenMetricsValidationErrorMessages

func WithHiddenMetricsValidationErrorMessages() func(validator *MetricsValidator)

func WithHiddenTracesValidationErrorMessages

func WithHiddenTracesValidationErrorMessages() func(*TraceValidator)

Types

type LogsValidator

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

func NewLogsValidator

func NewLogsValidator(t *testing.T, expectedLogs []plog.Logs, opts ...func(*LogsValidator)) *LogsValidator

NewLogsValidator ensures expected logs are present in the output.

func (*LogsValidator) RecordResults

func (v *LogsValidator) RecordResults(tc *testbed.TestCase)

func (*LogsValidator) Validate

func (v *LogsValidator) Validate(tc *testbed.TestCase)

type MetricsValidator

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

func NewMetricValidator

func NewMetricValidator(t *testing.T, expectedMetrics []pmetric.Metrics, opts ...func(validator *MetricsValidator)) *MetricsValidator

func (*MetricsValidator) RecordResults

func (v *MetricsValidator) RecordResults(tc *testbed.TestCase)

func (*MetricsValidator) Validate

func (v *MetricsValidator) Validate(tc *testbed.TestCase)

type ReceiverFunc

type ReceiverFunc func(port int) *testbed.BaseOTLPDataReceiver

type SenderFunc

type SenderFunc func(host string, port int) testbed.DataSender

type TraceValidator

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

func NewTraceValidator

func NewTraceValidator(t *testing.T, expectedTraces []ptrace.Traces, opts ...func(*TraceValidator)) *TraceValidator

func (*TraceValidator) RecordResults

func (v *TraceValidator) RecordResults(tc *testbed.TestCase)

func (*TraceValidator) Validate

func (v *TraceValidator) Validate(tc *testbed.TestCase)