tchannel

type Builder ¶

type Builder struct {
	// collector server静态服务端口列表
	CollectorHostPorts []string `yaml:"collectorHostPorts"`

	// 用于连接collector servers实例的数量，默认为3个。
	//
	// 这个说明collector servers至少有三个实例
	DiscoveryMinPeers int `yaml:"minPeers"`

	// collector服务名称
	CollectorServiceName string `yaml:"collectorServiceName"`

	// 连接的超时时间设置
	ConnCheckTimeout time.Duration
	// contains filtered or unexported fields
}

Builder类似于Agent Builder，用于构建一个或者多个服务，组装服务所需要的各个组件，如：Processor server需要配置、需要创建Processor实例，并且把相关实例参数写入到Builder中

这个Builder主要用于Collector server的静态服务列表，或者动态服务发现的配置、实例相关构建

func NewBuilder() *Builder

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

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 Reporter ¶

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

Reporter forwards received spans to central collector tier over TChannel. Reporter用于把processor从channel队列上接收trace, 通过tchannel发送到collector servers 因为Reporter实现了Reporter interface：EmitZipkinBatch和EmitBatch方法 前者用于zipkin数据格式进行rpc调用，后者用于jaeger数据格式进行rpc调用

func New(
	collectorServiceName string,
	channel *tchannel.Channel,
	peerListMgr *peerlistmgr.PeerListManager,
	mFactory metrics.Factory,
	zlogger *zap.Logger,
) *Reporter

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

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

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