correctnesstests

Documentation

Index

• func ConstructConnector(t *testing.T, connector string, receiverType string) testbed.DataConnector
• func ConstructMetricsSender(t *testing.T, receiver string) testbed.MetricDataSender
• func ConstructReceiver(t *testing.T, exporter string) testbed.DataReceiver
• func ConstructTraceSender(t *testing.T, receiver string) testbed.DataSender
• func CreateConfigYaml(t testing.TB, sender testbed.DataSender, receiver testbed.DataReceiver, ...) string
• type PipelineDef
  • func LoadPictOutputPipelineDefs(fileName string) ([]PipelineDef, error)
• type ProcessorNameAndConfigBody

Functions

func ConstructConnector

func ConstructConnector(t *testing.T, connector string, receiverType string) testbed.DataConnector

func ConstructMetricsSender

func ConstructMetricsSender(t *testing.T, receiver string) testbed.MetricDataSender

ConstructMetricsSender creates a testbed metrics sender from the passed-in metrics sender identifier.

func ConstructReceiver

func ConstructReceiver(t *testing.T, exporter string) testbed.DataReceiver

ConstructReceiver creates a testbed receiver from the passed-in recevier identifier.

func ConstructTraceSender

func ConstructTraceSender(t *testing.T, receiver string) testbed.DataSender

ConstructTraceSender creates a testbed trace sender from the passed-in trace sender identifier.

func CreateConfigYaml

func CreateConfigYaml(
	t testing.TB,
	sender testbed.DataSender,
	receiver testbed.DataReceiver,
	connector testbed.DataConnector,
	processors []ProcessorNameAndConfigBody,
) string

CreateConfigYaml creates a yaml config for an otel collector given a testbed sender, testbed receiver, any processors, and a pipeline type. A collector created from the resulting yaml string should be able to talk the specified sender and receiver.

Types

type PipelineDef

type PipelineDef struct {
	Receiver      string
	Exporter      string
	Connector     string
	TestName      string
	DataSender    testbed.DataSender
	DataReceiver  testbed.DataReceiver
	DataConnector testbed.DataConnector
	ResourceSpec  testbed.ResourceSpec
}

PipelineDef holds the information necessary to run a single testbed configuration.

func LoadPictOutputPipelineDefs

func LoadPictOutputPipelineDefs(fileName string) ([]PipelineDef, error)

LoadPictOutputPipelineDefs generates a slice of PipelineDefs from the passed-in generated PICT file. The result should be a set of PipelineDefs that covers all possible pipeline configurations.

type ProcessorNameAndConfigBody

type ProcessorNameAndConfigBody struct {
	Name string
	Body string
}