tchannel

Documentation

Index

• func AddFlags(flags *flag.FlagSet)
• type Builder
  • func NewBuilder() *Builder
  • func (b *Builder) CreateReporter(mFactory metrics.Factory, 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) GetManager() httpserver.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(mFactory metrics.Factory, 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) GetManager

func (b ProxyBuilder) GetManager() httpserver.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,
	mFactory metrics.Factory,
	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