package zipkin

import "github.com/uber/jaeger-client-go/transport/zipkin"

Package zipkin provides various Transports that can be used with RemoteReporter for submitting traces to Zipkin backend.

Index ¶

• type HTTPBasicAuthCredentials
• type HTTPOption
• func HTTPBasicAuth(username string, password string) HTTPOption
• func HTTPBatchSize(n int) HTTPOption
• func HTTPLogger(logger jaeger.Logger) HTTPOption
• func HTTPRoundTripper(transport http.RoundTripper) HTTPOption
• func HTTPTimeout(duration time.Duration) HTTPOption
• type HTTPTransport
• func NewHTTPTransport(url string, options ...HTTPOption) (*HTTPTransport, error)
• func (c *HTTPTransport) Append(span *jaeger.Span) (int, error)
• func (c *HTTPTransport) Close() error
• func (c *HTTPTransport) Flush() (int, error)

Examples ¶

• NewHTTPTransport

Types ¶

type HTTPBasicAuthCredentials ¶

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

HTTPBasicAuthCredentials stores credentials for HTTP basic auth.

type HTTPOption ¶

type HTTPOption func(c *HTTPTransport)

HTTPOption sets a parameter for the HttpCollector

func HTTPBasicAuth ¶

func HTTPBasicAuth(username string, password string) HTTPOption

HTTPBasicAuth sets the credentials required to perform HTTP basic auth

func HTTPBatchSize ¶

func HTTPBatchSize(n int) HTTPOption

HTTPBatchSize sets the maximum batch size, after which a collect will be triggered. The default batch size is 100 spans.

func HTTPLogger ¶

func HTTPLogger(logger jaeger.Logger) HTTPOption

HTTPLogger sets the logger used to report errors in the collection process. By default, a no-op logger is used, i.e. no errors are logged anywhere. It's important to set this option in a production service.

func HTTPRoundTripper ¶

func HTTPRoundTripper(transport http.RoundTripper) HTTPOption

HTTPRoundTripper configures the underlying Transport on the *http.Client that is used

func HTTPTimeout ¶

func HTTPTimeout(duration time.Duration) HTTPOption

HTTPTimeout sets maximum timeout for http request.

type HTTPTransport ¶

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

HTTPTransport implements Transport by forwarding spans to a http server.

func NewHTTPTransport ¶

func NewHTTPTransport(url string, options ...HTTPOption) (*HTTPTransport, error)

NewHTTPTransport returns a new HTTP-backend transport. url should be an http url to handle post request, typically something like:

http://hostname:9411/api/v1/spans

{
	// assume this is your main()

	transport, err := zipkin.NewHTTPTransport(
		"http://localhost:9411/api/v1/spans",
		zipkin.HTTPBatchSize(10),
		zipkin.HTTPLogger(jlog.StdLogger),
	)
	if err != nil {
		log.Fatalf("Cannot initialize Zipkin HTTP transport: %v", err)
	}
	tracer, closer := jaeger.NewTracer(
		"my-service-name",
		jaeger.NewConstSampler(true),
		jaeger.NewRemoteReporter(transport, nil),
	)
	defer closer.Close()
	opentracing.SetGlobalTracer(tracer)

	// initialize servers
}

func (*HTTPTransport) Append ¶

func (c *HTTPTransport) Append(span *jaeger.Span) (int, error)

Append implements Transport.

func (*HTTPTransport) Close ¶

func (c *HTTPTransport) Close() error

Close implements Transport.

func (*HTTPTransport) Flush ¶

func (c *HTTPTransport) Flush() (int, error)

Flush implements Transport.

Source Files ¶

doc.go http.go