grpc

Sep 2, 2019

Changes in this version

type ConnBuilder

+ TLSCert string

+ TLSKey string

Jun 27, 2019

Changes in this version

type ProxyBuilder

+ func (b ProxyBuilder) GetConn() *grpc.ClientConn

May 16, 2019

Changes in this version

+ type ConnBuilder struct

+ CollectorHostPorts []string

+ Discoverer discovery.Discoverer

+ DiscoveryMinPeers int

+ MaxRetry uint

+ Notifier discovery.Notifier

+ TLS bool

+ TLSCA string

+ TLSServerName string

+ func NewConnBuilder() *ConnBuilder

+ func (b *ConnBuilder) CreateConnection(logger *zap.Logger) (*grpc.ClientConn, error)

+ func (b *ConnBuilder) InitFromViper(v *viper.Viper) *ConnBuilder

Mar 7, 2019

Changes in this version

type Options

+ MaxRetry uint

+ TLS bool

+ TLSCA string

+ TLSServerName string

Jan 21, 2019

Changes in this version

+ func AddFlags(flags *flag.FlagSet)

+ type Options struct

+ CollectorHostPort []string

+ func (o *Options) InitFromViper(v *viper.Viper) *Options

+ type ProxyBuilder struct

+ func NewCollectorProxy(o *Options, mFactory metrics.Factory, logger *zap.Logger) (*ProxyBuilder, error)

+ func (b ProxyBuilder) Close() error

+ func (b ProxyBuilder) GetManager() configmanager.ClientConfigManager

+ func (b ProxyBuilder) GetReporter() aReporter.Reporter

+ type Reporter struct

+ func NewReporter(conn *grpc.ClientConn, logger *zap.Logger) *Reporter

+ func (r *Reporter) EmitBatch(b *thrift.Batch) error

+ func (r *Reporter) EmitZipkinBatch(zSpans []*zipkincore.Span) error