Versions in this module Expand all Collapse all v0 v0.0.2 Sep 12, 2019 Changes in this version type Exporters + func (exps Exporters) ShutdownAll() v0.0.1 Aug 8, 2019 Changes in this version + const InvalidSenderType + const ProtoGRPCSenderType + const ThriftHTTPSenderType + const ThriftTChannelSenderType + func Flags(flags *flag.FlagSet) + func GetConfigFile(v *viper.Viper) string + func MemBallastSize(v *viper.Viper) int + type AttributesCfg struct + KeyReplacements []attributekeyprocessor.KeyReplacement + Overwrite bool + Values map[string]interface{} + type BatchingConfig struct + Enable bool + NumTickers int + RemoveAfterTicks *int + SendBatchSize *int + TickTime *time.Duration + Timeout *time.Duration + type Exporters map[configmodels.Exporter]*builtExporter + func (exps Exporters) StopAll() + type ExportersBuilder struct + func NewExportersBuilder(logger *zap.Logger, config *configmodels.Config, ...) *ExportersBuilder + func (eb *ExportersBuilder) Build() (Exporters, error) + type GlobalProcessorCfg struct + Attributes *AttributesCfg + type JaegerProtoGRPCSenderCfg struct + CollectorEndpoint string + func NewJaegerProtoGRPCSenderCfg() *JaegerProtoGRPCSenderCfg + type JaegerThriftHTTPSenderCfg struct + CollectorEndpoint string + Headers map[string]string + Timeout time.Duration + func NewJaegerThriftHTTPSenderCfg() *JaegerThriftHTTPSenderCfg + type JaegerThriftTChannelSenderCfg struct + CollectorHostPorts []string + DiscoveryConnCheckTimeout time.Duration + DiscoveryMinPeers int + func NewJaegerThriftTChannelSenderCfg() *JaegerThriftTChannelSenderCfg + type MultiSpanProcessorCfg struct + Global *GlobalProcessorCfg + Processors []*QueuedSpanProcessorCfg + func NewDefaultMultiSpanProcessorCfg() *MultiSpanProcessorCfg + func (mOpts *MultiSpanProcessorCfg) InitFromViper(v *viper.Viper) *MultiSpanProcessorCfg + type PipelineProcessors map[*configmodels.Pipeline]*builtProcessor + type PipelinesBuilder struct + func NewPipelinesBuilder(logger *zap.Logger, config *configmodels.Config, exporters Exporters, ...) *PipelinesBuilder + func (pb *PipelinesBuilder) Build() (PipelineProcessors, error) + type QueuedSpanProcessorCfg struct + BackoffDelay time.Duration + BatchingConfig BatchingConfig + Name string + NumWorkers int + QueueSize int + RawConfig *viper.Viper + RetryOnFailure bool + SenderConfig interface{} + SenderType SenderType + func NewDefaultQueuedSpanProcessorCfg() *QueuedSpanProcessorCfg + func (qOpts *QueuedSpanProcessorCfg) InitFromViper(v *viper.Viper) *QueuedSpanProcessorCfg + type Receivers map[configmodels.Receiver]*builtReceiver + func (rcvs Receivers) StartAll(logger *zap.Logger, host receiver.Host) error + func (rcvs Receivers) StopAll() + type ReceiversBuilder struct + func NewReceiversBuilder(logger *zap.Logger, config *configmodels.Config, ...) *ReceiversBuilder + func (rb *ReceiversBuilder) Build() (Receivers, error) + type SenderType string