grpc

package
v1.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 21, 2019 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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
}

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL