Versions in this module Expand all Collapse all v0 v0.2.5 Jul 24, 2017 Changes in this version + var Delegator delegatorType + var ErrInvalidEndpoint = errors.New("Invalid Endpoint. Please check hostPort parameter") + var ErrMissingValue = errors.New("(MISSING)") + var SpanKindResource = otext.SpanKindEnum("resource") + func MaterializeWithJSON(logFields []log.Field) ([]byte, error) + func MaterializeWithLogFmt(logFields []log.Field) ([]byte, error) + func NewTracer(recorder SpanRecorder, options ...TracerOption) (opentracing.Tracer, error) + func StrictZipkinMaterializer(logFields []log.Field) ([]byte, error) + type CollectionError interface + Error func() string + GetErrors func() []error + type Collector interface + Close func() error + Collect func(*zipkincore.Span) error + func NewHTTPCollector(url string, options ...HTTPOption) (Collector, error) + func NewKafkaCollector(addrs []string, options ...KafkaOption) (Collector, error) + func NewScribeCollector(addr string, timeout time.Duration, options ...ScribeOption) (Collector, error) + type DelegatingCarrier interface + GetBaggage func(func(key, value string)) + SetBaggageItem func(key, value string) + SetState func(traceID types.TraceID, spanID uint64, parentSpanID *uint64, sampled bool, ...) + State func() (traceID types.TraceID, spanID uint64, parentSpanID *uint64, sampled bool, ...) + type EventBaggage struct + Key string + Value string + type EventCreate struct + OperationName string + type EventFinish RawSpan + type EventLog opentracing.LogData + type EventLogFields opentracing.LogRecord + type EventTag struct + Key string + Value interface{} + type HTTPCollector struct + func (c *HTTPCollector) Close() error + func (c *HTTPCollector) Collect(s *zipkincore.Span) error + type HTTPOption func(c *HTTPCollector) + func HTTPBatchInterval(d time.Duration) HTTPOption + func HTTPBatchSize(n int) HTTPOption + func HTTPClient(client *http.Client) HTTPOption + func HTTPLogger(logger Logger) HTTPOption + func HTTPMaxBacklog(n int) HTTPOption + func HTTPRequestCallback(rc RequestCallback) HTTPOption + func HTTPTimeout(duration time.Duration) HTTPOption + type InMemorySpanRecorder struct + func NewInMemoryRecorder() *InMemorySpanRecorder + func (r *InMemorySpanRecorder) GetSampledSpans() []RawSpan + func (r *InMemorySpanRecorder) GetSpans() []RawSpan + func (r *InMemorySpanRecorder) RecordSpan(span RawSpan) + func (r *InMemorySpanRecorder) Reset() + type KafkaCollector struct + func (c *KafkaCollector) Close() error + func (c *KafkaCollector) Collect(s *zipkincore.Span) error + type KafkaOption func(c *KafkaCollector) + func KafkaLogger(logger Logger) KafkaOption + func KafkaProducer(p sarama.AsyncProducer) KafkaOption + func KafkaTopic(t string) KafkaOption + type Logger interface + Log func(keyvals ...interface{}) error + func LogWrapper(l *log.Logger) Logger + func NewNopLogger() Logger + type LoggerFunc func(...interface{}) error + func (f LoggerFunc) Log(keyvals ...interface{}) error + type MultiCollector []Collector + func (c MultiCollector) Close() error + func (c MultiCollector) Collect(s *zipkincore.Span) error + type NopCollector struct + func (NopCollector) Close() error + func (NopCollector) Collect(*zipkincore.Span) error + type RawSpan struct + Context SpanContext + Duration time.Duration + Logs []opentracing.LogRecord + Operation string + Start time.Time + Tags opentracing.Tags + type Recorder struct + func (r *Recorder) RecordSpan(sp RawSpan) + type RecorderOption func(r *Recorder) + func WithJSONMaterializer() RecorderOption + func WithLogFmtMaterializer() RecorderOption + func WithStrictMaterializer() RecorderOption + type RequestCallback func(*http.Request) + type Sampler func(id uint64) bool + func ModuloSampler(mod uint64) Sampler + func NewBoundarySampler(rate float64, salt int64) Sampler + func NewCountingSampler(rate float64) Sampler + type ScribeCollector struct + func (c *ScribeCollector) Close() error + func (c *ScribeCollector) Collect(s *zipkincore.Span) error + type ScribeOption func(s *ScribeCollector) + func ScribeBatchInterval(d time.Duration) ScribeOption + func ScribeBatchSize(n int) ScribeOption + func ScribeCategory(category string) ScribeOption + func ScribeLogger(logger Logger) ScribeOption + func ScribeMaxBacklog(n int) ScribeOption + type Span interface + Operation func() string + Start func() time.Time + type SpanContext struct + Baggage map[string]string + Flags flag.Flags + Owner bool + ParentSpanID *uint64 + Sampled bool + SpanID uint64 + TraceID types.TraceID + func (c SpanContext) ForeachBaggageItem(handler func(k, v string) bool) + func (c SpanContext) WithBaggageItem(key, val string) SpanContext + type SpanEvent interface + type SpanRecorder interface + RecordSpan func(span RawSpan) + func NewRecorder(c Collector, debug bool, hostPort, serviceName string, ...) SpanRecorder + type Tracer interface + Options func() TracerOptions + type TracerOption func(opts *TracerOptions) error + func ClientServerSameSpan(val bool) TracerOption + func DebugAssertSingleGoroutine(val bool) TracerOption + func DebugAssertUseAfterFinish(val bool) TracerOption + func DebugMode(val bool) TracerOption + func DropAllLogs(dropAllLogs bool) TracerOption + func EnableSpanPool(val bool) TracerOption + func NewSpanEventListener(f func() func(SpanEvent)) TracerOption + func TraceID128Bit(val bool) TracerOption + func TrimUnsampledSpans(trim bool) TracerOption + func WithLogger(logger Logger) TracerOption + func WithMaxLogsPerSpan(limit int) TracerOption + func WithObserver(observer otobserver.Observer) TracerOption + func WithSampler(sampler Sampler) TracerOption + type TracerOptions struct