processors

package
v1.6.0 Latest Latest
Warning

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

Go to latest
Published: Jul 10, 2018 License: Apache-2.0 Imports: 7 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(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

Jump to

Keyboard shortcuts

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