reporter

Documentation

Index

• type MultiReporter
  • func NewMultiReporter(reps ...Reporter) MultiReporter
  • func (mr MultiReporter) EmitBatch(batch *jaeger.Batch) error
  • func (mr MultiReporter) EmitZipkinBatch(spans []*zipkincore.Span) error
• type Reporter
  • func NewTChannelReporter(svc string, channel *tchannel.Channel, mFactory metrics.Factory, ...) Reporter

Types

type MultiReporter

type MultiReporter []Reporter

MultiReporter provides serial span emission to one or more reporters. If more than one expensive reporter are needed, one or more of them should be wrapped and hidden behind a channel.

func NewMultiReporter

func NewMultiReporter(reps ...Reporter) MultiReporter

NewMultiReporter creates a MultiReporter from the variadic list of passed Reporters.

func (MultiReporter) EmitBatch

func (mr MultiReporter) EmitBatch(batch *jaeger.Batch) error

EmitBatch calls each EmitBatch, returning the first error.

func (MultiReporter) EmitZipkinBatch

func (mr MultiReporter) EmitZipkinBatch(spans []*zipkincore.Span) error

EmitZipkinBatch calls each EmitZipkinBatch, returning the first error.

type Reporter

type Reporter interface {
	EmitZipkinBatch(spans []*zipkincore.Span) (err error)
	EmitBatch(batch *jaeger.Batch) (err error)
}

Reporter handles spans received by Processor and forwards them to central collectors.

func NewTChannelReporter

func NewTChannelReporter(svc string, channel *tchannel.Channel, mFactory metrics.Factory, zlogger *zap.Logger) Reporter

NewTChannelReporter creates new tchannelReporter