reporter

package
v1.15.0 Latest Latest
Warning

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

Go to latest
Published: Nov 7, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddFlags added in v1.9.0

func AddFlags(flags *flag.FlagSet)

AddFlags adds flags for Options.

Types

type MetricsReporter added in v1.9.0

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

MetricsReporter is reporter with metrics integration.

func WrapWithMetrics added in v1.9.0

func WrapWithMetrics(reporter Reporter, mFactory metrics.Factory) *MetricsReporter

WrapWithMetrics wraps Reporter and creates metrics for its invocations.

func (*MetricsReporter) EmitBatch added in v1.9.0

func (r *MetricsReporter) EmitBatch(batch *jaeger.Batch) error

EmitBatch emits batch to collector.

func (*MetricsReporter) EmitZipkinBatch added in v1.9.0

func (r *MetricsReporter) EmitZipkinBatch(spans []*zipkincore.Span) error

EmitZipkinBatch emits batch to collector.

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 Options added in v1.9.0

type Options struct {
	ReporterType Type
	AgentTags    map[string]string
}

Options holds generic reporter configuration.

func (*Options) InitFromViper added in v1.9.0

func (b *Options) InitFromViper(v *viper.Viper) *Options

InitFromViper initializes Options with properties retrieved from Viper.

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.

type Type added in v1.9.0

type Type string

Type defines type of reporter.

const (

	// TCHANNEL is name of tchannel reporter.
	TCHANNEL Type = "tchannel"
	// GRPC is name of gRPC reporter.
	GRPC Type = "grpc"
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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