Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgentProcessor ¶
type AgentProcessor interface {
Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
}
AgentProcessor interface用于发送trace包到collector server
type Processor ¶
type Processor interface {
Serve()
Stop()
}
Processor processes metrics in multiple formats
type ThriftProcessor ¶
type ThriftProcessor struct {
// contains filtered or unexported fields
}
ThriftProcessor用于指定thrift协议的processor服务, 这个processor server提供udp端口服务，获取业务微服务的trace，并通过processor workers作为消费者抢占channel队列上的trace包，并发送到collector servers上(通过channel获取collector peers)
func NewThriftProcessor ¶
func NewThriftProcessor( server servers.Server, numProcessors int, mFactory metrics.Factory, factory thrift.TProtocolFactory, handler AgentProcessor, logger *zap.Logger, ) (*ThriftProcessor, error)
NewThriftProcessor方法创建一个ThriftProcessor实例
func (*ThriftProcessor) IsServing ¶
func (s *ThriftProcessor) IsServing() bool
IsServing indicates whether the server is currently serving traffic
func (*ThriftProcessor) Serve ¶
func (s *ThriftProcessor) Serve()
Serve方法: 1. 启动多个消费者workers，用于抢占channel队列上的trace包 2. 启动http server服务，用于给业务微服务提供采样策略和Baggage携带信息字段列表
func (*ThriftProcessor) Stop ¶
func (s *ThriftProcessor) Stop()
Stop方法停止监控metrics相关指标，http server停止，消费者服务列表停止 emptied by the readers
Source Files
Click to show internal directories.
Click to hide internal directories.