wrap

Documentation

Index

• Variables
• func RegisterAccumulationHandler(handlers ...AccumulationHandlerFunc)
• func WithAccumulationHandler(handlers ...AccumulationHandlerFunc) func(os *FactoryConfig) error
• func WithDefaultLabels(kvs ...attribute.KeyValue) func(os *FactoryConfig) error
• type AccumulationHandlerFunc
• type Factory
  • func NewFactory(checkpointerFactory export.CheckpointerFactory, opts ...FactoryConfigFunc) *Factory
  • func (f *Factory) NewCheckpointer() export.Checkpointer
• type FactoryConfig
  • func (fc *FactoryConfig) ApplyOptions(configs ...FactoryConfigFunc) error
• type FactoryConfigFunc
• type Processor
  • func New(ckpter export.Checkpointer, opts ...FactoryConfigFunc) *Processor
  • func (p *Processor) Process(accum export.Accumulation) error

Variables

var AccumulationHandler []AccumulationHandlerFunc

Functions

func RegisterAccumulationHandler

func RegisterAccumulationHandler(handlers ...AccumulationHandlerFunc)

func WithAccumulationHandler

func WithAccumulationHandler(handlers ...AccumulationHandlerFunc) func(os *FactoryConfig) error

WithAccumulationHandler sets the middleware of Processor.

func WithDefaultLabels

func WithDefaultLabels(kvs ...attribute.KeyValue) func(os *FactoryConfig) error

WithDefaultLabels add default label set to Accumulation, as prepared by an Accumulator for the Processor. WithDefaultLabels set default attributes to all started spans. Duplicate keys are eliminated by taking the last value.

Types

type AccumulationHandlerFunc

type AccumulationHandlerFunc func(accum export.Accumulation) export.Accumulation

type Factory

type Factory struct {
	export.CheckpointerFactory
	// contains filtered or unexported fields
}

func NewFactory

func NewFactory(checkpointerFactory export.CheckpointerFactory, opts ...FactoryConfigFunc) *Factory

NewFactory returns a dimensionality-reset Processor Factory that passes data to the next stage in an export pipeline.

func (*Factory) NewCheckpointer

func (f *Factory) NewCheckpointer() export.Checkpointer

type FactoryConfig

type FactoryConfig struct {
	// Handlers acts like a middleware of Processor.
	Handlers []AccumulationHandlerFunc
}

func (*FactoryConfig) ApplyOptions

func (fc *FactoryConfig) ApplyOptions(configs ...FactoryConfigFunc) error

type FactoryConfigFunc

type FactoryConfigFunc func(os *FactoryConfig) error

FactoryConfigFunc is an alias for a function that will take in a pointer to an FactoryConfig and modify it

type Processor

type Processor struct {
	Handlers []AccumulationHandlerFunc
	export.Checkpointer
}

Processor is a wrapped SpanProcessor.

func New

func New(ckpter export.Checkpointer, opts ...FactoryConfigFunc) *Processor

New returns a dimensionality-reset Processor that passes data to the next stage in an export pipeline.

func (*Processor) Process

func (p *Processor) Process(accum export.Accumulation) error

Process implements export.Processor.