Documentation ¶
Overview ¶
Package jaeger contains an OpenCensus tracing exporter for Jaeger.
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EmitZipkinBatch ¶
func EmitZipkinBatch(spans []*zipkincore.Span) (err error)
EmitZipkinBatch implements EmitZipkinBatch() of Agent interface.
Types ¶
type Exporter ¶
type Exporter struct {
// contains filtered or unexported fields
}
Exporter is an implementation of trace.Exporter that uploads spans to Jaeger.
func NewExporter ¶
NewExporter returns a trace.Exporter implementation that exports the collected spans to Jaeger.
Example (Agent) ¶
package main import ( "log" jaeger "github.com/teal-finance/opencensus-go-exporter-jaeger" "go.opencensus.io/trace" ) func main() { // Register the Jaeger exporter to be able to retrieve // the collected spans. exporter, err := jaeger.NewExporter(jaeger.Options{ AgentEndpoint: "localhost:6831", Process: jaeger.Process{ ServiceName: "trace-demo", }, }) if err != nil { log.Fatal(err) } trace.RegisterExporter(exporter) }
Output:
Example (Collector) ¶
package main import ( "log" jaeger "github.com/teal-finance/opencensus-go-exporter-jaeger" "go.opencensus.io/trace" ) func main() { // Register the Jaeger exporter to be able to retrieve // the collected spans. exporter, err := jaeger.NewExporter(jaeger.Options{ Endpoint: "http://localhost:14268", Process: jaeger.Process{ ServiceName: "trace-demo", }, }) if err != nil { log.Fatal(err) } trace.RegisterExporter(exporter) }
Output:
Example (ProcessTags) ¶
ExampleNewExporter_processTags shows how to set ProcessTags on a Jaeger exporter. These tags will be added to the exported Jaeger process.
package main import ( "log" jaeger "github.com/teal-finance/opencensus-go-exporter-jaeger" "go.opencensus.io/trace" ) func main() { // Register the Jaeger exporter to be able to retrieve // the collected spans. exporter, err := jaeger.NewExporter(jaeger.Options{ AgentEndpoint: "localhost:6831", Process: jaeger.Process{ ServiceName: "trace-demo", Tags: []jaeger.Tag{ jaeger.StringTag("ip", "127.0.0.1"), jaeger.BoolTag("demo", true), }, }, }) if err != nil { log.Fatal(err) } trace.RegisterExporter(exporter) }
Output:
func (*Exporter) ExportSpan ¶
ExportSpan exports a SpanData to Jaeger.
type Options ¶
type Options struct { // Endpoint is the Jaeger HTTP Thrift endpoint. // For example, http://localhost:14268. // // Deprecated: Use CollectorEndpoint instead. Endpoint string // CollectorEndpoint is the full url to the Jaeger HTTP Thrift collector. // For example, http://localhost:14268/api/traces CollectorEndpoint string // AgentEndpoint instructs exporter to send spans to jaeger-agent at this address. // For example, localhost:6831. AgentEndpoint string // OnError is the hook to be called when there is // an error occurred when uploading the stats data. // If no custom hook is set, errors are logged. // Optional. OnError func(err error) // Username to be used if basic auth is required. // Optional. Username string // Password to be used if basic auth is required. // Optional. Password string // ServiceName is the Jaeger service name. // Deprecated: Specify Process instead. ServiceName string // Process contains the information about the exporting process. Process Process // BufferMaxCount defines the total number of traces that can be buffered in memory BufferMaxCount int }
Options are the options to be used when initializing a Jaeger exporter.
type Process ¶
type Process struct { // ServiceName is the Jaeger service name. ServiceName string // Tags are added to Jaeger Process exports Tags []Tag }
Process contains the information exported to jaeger about the source of the trace data.
type Tag ¶
type Tag struct {
// contains filtered or unexported fields
}
Tag defines a key-value pair It is limited to the possible conversions to *jaeger.Tag by attributeToTag.
Directories ¶
Path | Synopsis |
---|---|
Command jaeger is an example program that creates spans and uploads to Jaeger.
|
Command jaeger is an example program that creates spans and uploads to Jaeger. |
Package propagation implement uber-trace-id header propagation used by Jaeger.
|
Package propagation implement uber-trace-id header propagation used by Jaeger. |