Documentation ¶
Index ¶
- Constants
- Variables
- func MetricViews(level telemetry.Level) []*view.View
- func NewQueuedSpanProcessor(sender consumer.TraceConsumer, opts ...Option) consumer.TraceConsumer
- type Config
- type Factory
- func (f *Factory) CreateDefaultConfig() configmodels.Processor
- func (f *Factory) CreateMetricsProcessor(logger *zap.Logger, nextConsumer consumer.MetricsConsumer, ...) (processor.MetricsProcessor, error)
- func (f *Factory) CreateTraceProcessor(logger *zap.Logger, nextConsumer consumer.TraceConsumer, ...) (processor.TraceProcessor, error)
- func (f *Factory) Type() string
- type Option
Constants ¶
View Source
const ( // DefaultNumWorkers is the default number of workers consuming from the processor queue DefaultNumWorkers = 10 // DefaultQueueSize is the default maximum number of span batches allowed in the processor's queue DefaultQueueSize = 1000 )
Variables ¶
View Source
var Options options
Options is a factory for all available Option's
Functions ¶
func MetricViews ¶
MetricViews return the metrics views according to given telemetry level.
func NewQueuedSpanProcessor ¶
func NewQueuedSpanProcessor(sender consumer.TraceConsumer, opts ...Option) consumer.TraceConsumer
NewQueuedSpanProcessor returns a span processor that maintains a bounded in-memory queue of span batches, and sends out span batches using the provided sender
Types ¶
type Config ¶
type Config struct { configmodels.ProcessorSettings `mapstructure:",squash"` // NumWorkers is the number of queue workers that dequeue batches and send them out. NumWorkers int `mapstructure:"num-workers"` // QueueSize is the maximum number of batches allowed in queue at a given time. QueueSize int `mapstructure:"queue-size"` // Retry indicates whether queue processor should retry span batches in case of processing failure. RetryOnFailure bool `mapstructure:"retry-on-failure"` // BackoffDelay is the amount of time a worker waits after a failed send before retrying. BackoffDelay time.Duration `mapstructure:"backoff-delay"` }
Config defines configuration for Attributes processor.
type Factory ¶
type Factory struct { }
Factory is the factory for OpenCensus exporter.
func (*Factory) CreateDefaultConfig ¶
func (f *Factory) CreateDefaultConfig() configmodels.Processor
CreateDefaultConfig creates the default configuration for exporter.
func (*Factory) CreateMetricsProcessor ¶
func (f *Factory) CreateMetricsProcessor( logger *zap.Logger, nextConsumer consumer.MetricsConsumer, cfg configmodels.Processor, ) (processor.MetricsProcessor, error)
CreateMetricsProcessor creates a metrics processor based on this config.
func (*Factory) CreateTraceProcessor ¶
func (f *Factory) CreateTraceProcessor( logger *zap.Logger, nextConsumer consumer.TraceConsumer, cfg configmodels.Processor, ) (processor.TraceProcessor, error)
CreateTraceProcessor creates a trace processor based on this config.
Click to show internal directories.
Click to hide internal directories.