local

Documentation

Index

• type Processor
  • func New(msgBufSize, msgProcRoutines int, exporters []trace.Exporter, logger log.Logger) *Processor
  • func (p *Processor) Close() error
  • func (p *Processor) Process(m *daemon.Message) bool
  • func (p *Processor) Run() error

Types

type Processor

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

Processor implementation for converting incoming Daemon messages into stats and spanData objects. This processor uses the OpenCensus Go stats implementation to handle the PHP stats and converts the PHP span data into Go's spanData objects. This allows PHP to have the same featureset as Go applications without doing much processing in the critical path and reuse Go's OpenCensus Agent Exporter for Stats and Traces.

func New

func New(msgBufSize, msgProcRoutines int, exporters []trace.Exporter, logger log.Logger) *Processor

New returns a new Processor.

func (*Processor) Close

func (p *Processor) Close() error

Close shuts down our Processor.

func (*Processor) Process

func (p *Processor) Process(m *daemon.Message) bool

Process sends our Message on the internal channel to be processed. Returns true on successful ingestion, false on high water mark.

func (*Processor) Run

func (p *Processor) Run() error

Run starts our message processor.