testhelpers

Documentation

Index

• func NewPipelines(typestrs ...string) map[string]*PipelineMetadata
• func SeedAggregator(agg *status.Aggregator, instanceIDs []*componentstatus.InstanceID, ...)
• type PipelineMetadata
  • func NewPipelineMetadata(typestr string) *PipelineMetadata
  • func (p *PipelineMetadata) InstanceIDs() []*componentstatus.InstanceID

Functions

func NewPipelines

func NewPipelines(typestrs ...string) map[string]*PipelineMetadata

NewPipelines returns a map of hypothetical pipelines identified by their stringified typeVal.

func SeedAggregator

func SeedAggregator(
	agg *status.Aggregator,
	instanceIDs []*componentstatus.InstanceID,
	statuses ...componentstatus.Status,
)

SeedAggregator records a status event for each instanceID.

Types

type PipelineMetadata

type PipelineMetadata struct {
	PipelineID  pipeline.ID
	ReceiverID  *componentstatus.InstanceID
	ProcessorID *componentstatus.InstanceID
	ExporterID  *componentstatus.InstanceID
}

PipelineMetadata groups together component and instance IDs for a hypothetical pipeline used for testing purposes.

func NewPipelineMetadata

func NewPipelineMetadata(typestr string) *PipelineMetadata

NewPipelineMetadata returns a metadata for a hypothetical pipeline.

func (*PipelineMetadata) InstanceIDs

func (p *PipelineMetadata) InstanceIDs() []*componentstatus.InstanceID

InstanceIDs returns a slice of instanceIDs for components within the hypothetical pipeline.