processors

Documentation

Index

• type AgentProcessor
• type Processor
• type ThriftProcessor
  • func NewThriftProcessor(server servers.Server, numProcessors int, mFactory metrics.Factory, ...) (*ThriftProcessor, error)
  • func (s *ThriftProcessor) IsServing() bool
  • func (s *ThriftProcessor) Serve()
  • func (s *ThriftProcessor) Stop()

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