tchannel

Documentation

Index

• func AddFlags(flags *flag.FlagSet)
• type Builder
  • func NewBuilder() *Builder
  • func (b *Builder) CreateReporter(logger *zap.Logger) (*Reporter, error)
  • func (b *Builder) InitFromViper(v *viper.Viper, logger *zap.Logger) *Builder
  • func (b *Builder) WithChannel(c *tchannel.Channel) *Builder
  • func (b *Builder) WithCollectorServiceName(s string) *Builder
  • func (b *Builder) WithDiscoverer(d discovery.Discoverer) *Builder
  • func (b *Builder) WithDiscoveryNotifier(n discovery.Notifier) *Builder
• type ProxyBuilder
  • func NewCollectorProxy(builder *Builder, mFactory metrics.Factory, logger *zap.Logger) (*ProxyBuilder, error)
  • func (b ProxyBuilder) Close() error
  • func (b ProxyBuilder) GetManager() configmanager.ClientConfigManager
  • func (b ProxyBuilder) GetReporter() reporter.Reporter
• type Reporter
  • func New(collectorServiceName string, channel *tchannel.Channel, ...) *Reporter
  • func (r *Reporter) Channel() *tchannel.Channel
  • func (r *Reporter) CollectorServiceName() string
  • func (r *Reporter) EmitBatch(batch *jaeger.Batch) error
  • func (r *Reporter) EmitZipkinBatch(spans []*zipkincore.Span) error

Functions

func AddFlags

func AddFlags(flags *flag.FlagSet)

AddFlags adds flags for Builder.

Types

type Builder

type Builder struct {
	// CollectorHostPorts are host:ports of a static list of Jaeger Collectors.
	CollectorHostPorts []string `yaml:"collectorHostPorts"`

	// MinPeers is the min number of servers we want the agent to connect to.
	// If zero, defaults to min(3, number of peers returned by service discovery)
	DiscoveryMinPeers int `yaml:"minPeers"`

	// CollectorServiceName is the name that Jaeger Collector's TChannel server
	// responds to.
	CollectorServiceName string `yaml:"collectorServiceName"`

	// ConnCheckTimeout is the timeout used when establishing new connections.
	ConnCheckTimeout time.Duration

	// ReportTimeout is the timeout used when reporting span batches.
	ReportTimeout time.Duration
	// contains filtered or unexported fields
}

Builder Struct to hold configurations

func NewBuilder

func NewBuilder() *Builder

NewBuilder creates a new reporter builder.

func (*Builder) CreateReporter

func (b *Builder) CreateReporter(logger *zap.Logger) (*Reporter, error)

CreateReporter creates the TChannel-based Reporter

func (*Builder) InitFromViper

func (b *Builder) InitFromViper(v *viper.Viper, logger *zap.Logger) *Builder

InitFromViper initializes Builder with properties retrieved from Viper.

func (*Builder) WithChannel

func (b *Builder) WithChannel(c *tchannel.Channel) *Builder

WithChannel sets tchannel channel

func (*Builder) WithCollectorServiceName

func (b *Builder) WithCollectorServiceName(s string) *Builder

WithCollectorServiceName sets collector service name

func (*Builder) WithDiscoverer

func (b *Builder) WithDiscoverer(d discovery.Discoverer) *Builder

WithDiscoverer sets service discovery

func (*Builder) WithDiscoveryNotifier

func (b *Builder) WithDiscoveryNotifier(n discovery.Notifier) *Builder

WithDiscoveryNotifier sets service discovery notifier

type ProxyBuilder

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

ProxyBuilder holds objects communicating with collector

func NewCollectorProxy

func NewCollectorProxy(builder *Builder, 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() reporter.Reporter

GetReporter returns Reporter

type Reporter

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

Reporter forwards received spans to central collector tier over TChannel.

func New

func New(
	collectorServiceName string,
	channel *tchannel.Channel,
	reportTimeout time.Duration,
	peerListMgr *peerlistmgr.PeerListManager,
	zlogger *zap.Logger,
) *Reporter

New creates new TChannel-based Reporter.

func (*Reporter) Channel

func (r *Reporter) Channel() *tchannel.Channel

Channel returns the TChannel used by the reporter.

func (*Reporter) CollectorServiceName

func (r *Reporter) CollectorServiceName() string

CollectorServiceName returns collector service name.

func (*Reporter) EmitBatch

func (r *Reporter) EmitBatch(batch *jaeger.Batch) error

EmitBatch implements EmitBatch() of Reporter

func (*Reporter) EmitZipkinBatch

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

EmitZipkinBatch implements EmitZipkinBatch() of Reporter