Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 Changes in this version + const DefaultNumWorkers + const DefaultQueueSize + const UnableToReadBodyErrFormat + var Options options + func NormalizeServiceName(serviceName string) string + type APIHandler struct + func NewAPIHandler(jaegerBatchesHandler JaegerBatchesHandler) *APIHandler + func (aH *APIHandler) RegisterRoutes(router *mux.Router) + type FilterSpan func(span *model.Span) bool + type GRPCHandler struct + func NewGRPCHandler(logger *zap.Logger, spanProcessor SpanProcessor) *GRPCHandler + func (g *GRPCHandler) PostSpans(ctx context.Context, r *api_v2.PostSpansRequest) (*api_v2.PostSpansResponse, error) + type InboundTransport string + const GRPCTransport + const HTTPTransport + const TChannelTransport + const UnknownTransport + type JaegerBatchesHandler interface + SubmitBatches func(batches []*jaeger.Batch, options SubmitBatchOptions) ([]*jaeger.BatchSubmitResponse, error) + func NewJaegerSpanHandler(logger *zap.Logger, modelProcessor SpanProcessor) JaegerBatchesHandler + type Option func(c *options) + type ProcessSpan func(span *model.Span) + func ChainedProcessSpan(spanProcessors ...ProcessSpan) ProcessSpan + type ProcessSpans func(spans []*model.Span) + type ProcessSpansOptions struct + InboundTransport InboundTransport + SpanFormat SpanFormat + type SpanCounts struct + ReceivedBySvc metricsBySvc + RejectedBySvc metricsBySvc + type SpanCountsByFormat map[SpanFormat]SpanCountsByTransport + type SpanCountsByTransport map[InboundTransport]SpanCounts + type SpanFormat string + const JaegerSpanFormat + const ProtoSpanFormat + const UnknownSpanFormat + const ZipkinSpanFormat + type SpanProcessor interface + ProcessSpans func(mSpans []*model.Span, options ProcessSpansOptions) ([]bool, error) + func NewSpanProcessor(spanWriter spanstore.Writer, opts ...Option) SpanProcessor + type SpanProcessorMetrics struct + BatchSize metrics.Gauge + InQueueLatency metrics.Timer + QueueLength metrics.Gauge + SaveLatency metrics.Timer + SavedErrBySvc metricsBySvc + SavedOkBySvc metricsBySvc + SpansDropped metrics.Counter + func NewSpanProcessorMetrics(serviceMetrics metrics.Factory, hostMetrics metrics.Factory, ...) *SpanProcessorMetrics + func (m *SpanProcessorMetrics) GetCountsForFormat(spanFormat SpanFormat, transport InboundTransport) SpanCounts + type SubmitBatchOptions struct + InboundTransport InboundTransport + type TChannelHandler struct + func NewTChannelHandler(jaegerHandler JaegerBatchesHandler, zipkinHandler ZipkinSpansHandler) *TChannelHandler + func (h *TChannelHandler) SubmitBatches(_ thrift.Context, batches []*jaeger.Batch) ([]*jaeger.BatchSubmitResponse, error) + func (h *TChannelHandler) SubmitZipkinBatch(_ thrift.Context, spans []*zipkincore.Span) ([]*zipkincore.Response, error) + type ZipkinSpansHandler interface + SubmitZipkinBatch func(spans []*zipkincore.Span, options SubmitBatchOptions) ([]*zipkincore.Response, error) + func NewZipkinSpanHandler(logger *zap.Logger, modelHandler SpanProcessor, sanitizer zipkinS.Sanitizer) ZipkinSpansHandler
Go to main page