zipkin

README

OpenCensus Go Zipkin Exporter

Provides OpenCensus exporter support for Zipkin.

Installation

$ go get -u contrib.go.opencensus.io/exporter/zipkin

Documentation

Overview

Package zipkin contains an trace exporter for Zipkin.

Index

• type Exporter
  • func NewExporter(reporter reporter.Reporter, localEndpoint *model.Endpoint) *Exporter
  • func (e *Exporter) ExportSpan(s *trace.SpanData)
• type ServerlessExporter
  • func NewExporterWithDiffTracing(reporter reporter.ServerlessReporter, localEndpoint *model.Endpoint, ...) *ServerlessExporter
  • func (e *ServerlessExporter) AggregateSpanFromHeader(w http.Header)
  • func (e *ServerlessExporter) ExportSpan(s *trace.SpanData)
  • func (e *ServerlessExporter) FilterSpan(s *trace.SpanData) trace.ErrorType

Types

type Exporter

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

Exporter is an implementation of trace.Exporter that uploads spans to a Zipkin server.

func NewExporter

func NewExporter(reporter reporter.Reporter, localEndpoint *model.Endpoint) *Exporter

NewExporter returns an implementation of trace.Exporter that uploads spans to a Zipkin server.

reporter is a Zipkin Reporter which will be used to send the spans. These can be created with the openzipkin library, using one of the packages under github.com/Yangfisher1/zipkin-go/reporter.

localEndpoint sets the local endpoint of exported spans. It can be constructed with github.com/Yangfisher1/zipkin-go.NewEndpoint, e.g.:

localEndpoint, err := NewEndpoint("my server", listener.Addr().String())

localEndpoint can be nil.

func (*Exporter) ExportSpan

func (e *Exporter) ExportSpan(s *trace.SpanData)

ExportSpan exports a span to a Zipkin server. Normal implementation

type ServerlessExporter

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

func NewExporterWithDiffTracing

func NewExporterWithDiffTracing(reporter reporter.ServerlessReporter, localEndpoint *model.Endpoint, diffEnabled bool) *ServerlessExporter

func (*ServerlessExporter) AggregateSpanFromHeader

func (e *ServerlessExporter) AggregateSpanFromHeader(w http.Header)

func (*ServerlessExporter) ExportSpan

func (e *ServerlessExporter) ExportSpan(s *trace.SpanData)

func (*ServerlessExporter) FilterSpan

func (e *ServerlessExporter) FilterSpan(s *trace.SpanData) trace.ErrorType