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

Types

type MultiReporter

type MultiReporter []Reporter

MultiReporter用于trace包发送给多个collector server, 多个collector存储

func NewMultiReporter

func NewMultiReporter(reps ...Reporter) MultiReporter

NewMultiReporter方法用于创建一个MultiReporter实例，指定了多个Reporter，也就是collector clients

func (MultiReporter) EmitBatch

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

EmitBatch方法用于批量调用EmitBatch， 对于每个Reporter都有自己的实现

func (MultiReporter) EmitZipkinBatch

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

EmitZipkinBatch方法用于批量调用EmitZipkinBatch, 对于每一个Reporter传输的实现，都可以使用自己的方式

type Reporter

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

Reporter处理有processor接收的trace包，并通过processor的handler把trace包发送给collector server 至于EmitZipkinBatch与EmitBatch方法的区别，一个是Zipkin格式，一个是Jaeger自定义格式