Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 Changes in this version + func AddFlags(flags *flag.FlagSet) + type ConnBuilder struct + CollectorHostPorts []string + Discoverer discovery.Discoverer + DiscoveryMinPeers int + MaxRetry uint + Notifier discovery.Notifier + TLS tlscfg.Options + func NewConnBuilder() *ConnBuilder + func (b *ConnBuilder) CreateConnection(logger *zap.Logger) (*grpc.ClientConn, error) + func (b *ConnBuilder) InitFromViper(v *viper.Viper) *ConnBuilder + type ProxyBuilder struct + func NewCollectorProxy(builder *ConnBuilder, agentTags map[string]string, mFactory metrics.Factory, ...) (*ProxyBuilder, error) + func (b ProxyBuilder) Close() error + func (b ProxyBuilder) GetConn() *grpc.ClientConn + func (b ProxyBuilder) GetManager() configmanager.ClientConfigManager + func (b ProxyBuilder) GetReporter() aReporter.Reporter + type Reporter struct + func NewReporter(conn *grpc.ClientConn, agentTags map[string]string, logger *zap.Logger) *Reporter + func (r *Reporter) EmitBatch(b *thrift.Batch) error + func (r *Reporter) EmitZipkinBatch(zSpans []*zipkincore.Span) error
Go to main page