Documentation
¶
Overview ¶
Package sender contains specialized senders to different backends. Unlike exporters they do not buffer or attempt to resend that failed batches, all of that is delegated to the users of the senders.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPOption ¶
type HTTPOption func(s *JaegerThriftHTTPSender)
HTTPOption sets a parameter for the HttpCollector
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 JaegerThriftHTTPSender ¶
type JaegerThriftHTTPSender struct {
// contains filtered or unexported fields
}
JaegerThriftHTTPSender forwards spans encoded in the jaeger thrift format to a http server
func NewJaegerThriftHTTPSender ¶
func NewJaegerThriftHTTPSender( url string, headers map[string]string, zlogger *zap.Logger, options ...HTTPOption, ) *JaegerThriftHTTPSender
NewJaegerThriftHTTPSender returns a new HTTP-backend span sender. url should be an http url of the collector to handle POST request, typically something like:
http://hostname:14268/api/traces?format=jaeger.thrift
func (*JaegerThriftHTTPSender) ProcessSpans ¶
func (s *JaegerThriftHTTPSender) ProcessSpans(batch *agenttracepb.ExportTraceServiceRequest, spanFormat string) (uint64, error)
ProcessSpans sends the received data to the configured Jaeger Thrift end-point.
type JaegerThriftTChannelSender ¶
type JaegerThriftTChannelSender struct {
// contains filtered or unexported fields
}
JaegerThriftTChannelSender takes span batches and sends them out on tchannel in thrift encoding
func NewJaegerThriftTChannelSender ¶
func NewJaegerThriftTChannelSender( reporter reporter.Reporter, zlogger *zap.Logger, ) *JaegerThriftTChannelSender
NewJaegerThriftTChannelSender creates new TChannel-based sender.
func (*JaegerThriftTChannelSender) ProcessSpans ¶
func (s *JaegerThriftTChannelSender) ProcessSpans(batch *agenttracepb.ExportTraceServiceRequest, spanFormat string) (uint64, error)
ProcessSpans sends the received data to the configured Jaeger Thrift end-point.
Source Files