processors

package
v1.34.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 16, 2022 License: Apache-2.0 Imports: 8 Imported by: 34

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL