grpc

Documentation

Index

• func AddFlags(flags *flag.FlagSet)
• type Options
  • func (o *Options) InitFromViper(v *viper.Viper) *Options
• type ProxyBuilder
  • 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
  • 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

Functions

func AddFlags

func AddFlags(flags *flag.FlagSet)

AddFlags adds flags for Options.

Types

type Options

type Options struct {
	// CollectorHostPort is list of host:port Jaeger Collectors.
	CollectorHostPort []string
	MaxRetry          uint
	TLS               bool
	TLSCA             string
	TLSServerName     string
}

Options Struct to hold configurations

func (*Options) InitFromViper

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

InitFromViper initializes Options with properties retrieved from Viper.

type ProxyBuilder

type ProxyBuilder struct {
	// contains filtered or unexported fields
}

ProxyBuilder holds objects communicating with collector

func NewCollectorProxy

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

NewCollectorProxy creates ProxyBuilder

func (ProxyBuilder) Close

func (b ProxyBuilder) Close() error

Close closes connections used by proxy.

func (ProxyBuilder) GetManager

func (b ProxyBuilder) GetManager() configmanager.ClientConfigManager

GetManager returns manager

func (ProxyBuilder) GetReporter

func (b ProxyBuilder) GetReporter() aReporter.Reporter

GetReporter returns Reporter

type Reporter

type Reporter struct {
	// contains filtered or unexported fields
}

Reporter reports data to collector over gRPC.

func NewReporter

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

NewReporter creates gRPC reporter.

func (*Reporter) EmitBatch

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

EmitBatch implements EmitBatch() of Reporter

func (*Reporter) EmitZipkinBatch

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

EmitZipkinBatch implements EmitZipkinBatch() of Reporter