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 handler used by the processor to process thrift and call the reporter 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 initiates the readers and 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