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(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
}

AgentProcessor handler used by the processor to process thrift and call the reporter with the deserialized struct. This interface is implemented directly by Thrift generated code, e.g. jaegerThrift.NewAgentProcessor(handler), where handler implements the Agent Thrift service interface, which is invoked with the deserialized struct.

type Processor

type Processor interface {
	Serve()
	Stop()
}

Processor processes metrics in multiple formats

type ThriftProcessor

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

ThriftProcessor is a server that processes spans using a TBuffered Server

func NewThriftProcessor

func NewThriftProcessor(
	server servers.Server,
	numProcessors int,
	mFactory metrics.Factory,
	factory thrift.TProtocolFactory,
	handler AgentProcessor,
	logger *zap.Logger,
) (*ThriftProcessor, error)

NewThriftProcessor creates a TBufferedServer backed 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 starts serving traffic

func (*ThriftProcessor) Stop

func (s *ThriftProcessor) Stop()

Stop stops the serving of traffic and waits until the queue is emptied by the readers