pipelines

Documentation

Index

• func NewMetricsPipeline(c PipelineConfig) (func() error, error)
• func NewTracePipeline(c PipelineConfig) (func() error, error)
• type PipelineConfig
• type PipelineSetupFunc
• type Protocol

Functions

func NewMetricsPipeline

func NewMetricsPipeline(c PipelineConfig) (func() error, error)

NewMetricsPipeline takes a PipelineConfig and builds a metrics pipeline. It returns a shutdown function that should be called when terminating the pipeline.

func NewTracePipeline

func NewTracePipeline(c PipelineConfig) (func() error, error)

NewTracePipeline creates a new trace pipeline from a config. It returns a shutdown function that should be called when terminating the pipeline.

Types

type PipelineConfig

type PipelineConfig struct {
	Protocol        Protocol
	Endpoint        string
	Insecure        bool
	Headers         map[string]string
	Resource        *resource.Resource
	ReportingPeriod string
	Propagators     []string
	SpanProcessors  []trace.SpanProcessor
	Sampler         trace.Sampler
}

PipelineConfig contains config info for a Pipeline.

type PipelineSetupFunc

type PipelineSetupFunc func(PipelineConfig) (func() error, error)

PipelineSetupFunc defines the interface for a Pipeline Setup function.

type Protocol

type Protocol string

Protocol defines the possible values of the protocol field.

const (
	ProtocolGRPC         Protocol = "grpc"
	ProtocolHTTPProtobuf Protocol = "http/protobuf"
	ProtocolHTTPJSON     Protocol = "http/json"
)

These are the only possible values for Protocol.