zipkintracer

package module

Go to main page

Versions in this module

v0

v0.5.0

Oct 11, 2022

v0.4.5

Dec 2, 2019

v0.4.4

Oct 30, 2019

v0.4.3

Aug 31, 2019

v0.4.2

Aug 16, 2019

v0.4.1

Aug 16, 2019

v0.4.0

Aug 15, 2019

Changes in this version

+ func Wrap(tr *zipkin.Tracer, opts ...TracerOption) opentracing.Tracer

+ type B3InjectOption int

+ const B3InjectBoth

+ const B3InjectSingle

+ const B3InjectStandard

+ type FinisherWithDuration interface

+ FinishedWithDuration func(d time.Duration)

type TracerOption

+ func WithB3InjectOption(b3InjectOption B3InjectOption) TracerOption

v0.3.5

Dec 19, 2018

v0.3.4

Mar 13, 2018

v0.3.3

Feb 7, 2018

v0.3.2

Nov 8, 2017

v0.3.1

Sep 18, 2017

v0.3.0

Jul 25, 2017

Changes in this version

type TracerOption

+ func WithObserver(observer otobserver.Observer) TracerOption

v0.2.4

Jun 21, 2017

Changes in this version

type HTTPOption

+ func HTTPClient(client *http.Client) HTTPOption

+ func HTTPRequestCallback(rc RequestCallback) HTTPOption

+ type RequestCallback func(*http.Request)

v0.2.3

Feb 3, 2017

Changes in this version

type HTTPOption

+ func HTTPMaxBacklog(n int) HTTPOption

type ScribeOption

+ func ScribeMaxBacklog(n int) ScribeOption

v0.2.2

Dec 20, 2016

Changes in this version

+ func MaterializeWithLogFmt(logFields []log.Field) ([]byte, error)

+ func StrictZipkinMaterializer(logFields []log.Field) ([]byte, error)

+ type RecorderOption func(r *Recorder)

+ func WithJSONMaterializer() RecorderOption

+ func WithLogFmtMaterializer() RecorderOption

+ func WithStrictMaterializer() RecorderOption

type TracerOption

+ func WithMaxLogsPerSpan(limit int) TracerOption

v0.2.1

Nov 2, 2016

Changes in this version

type SpanContext

+ Owner bool

v0.2.0

Oct 26, 2016

Changes in this version

type TracerOption

+ func TraceID128Bit(val bool) TracerOption

v0.1.0

Oct 5, 2016

Changes in this version

+ var Delegator delegatorType

+ var ErrInvalidEndpoint = errors.New("Invalid Endpoint. Please check hostPort parameter")

+ var ErrMissingValue = errors.New("(MISSING)")

+ var NetTraceIntegrator = func() func(SpanEvent)

+ var SpanKindResource = otext.SpanKindEnum("resource")

+ func MaterializeWithJSON(logFields []log.Field) ([]byte, error)

+ func NewTracer(recorder SpanRecorder, options ...TracerOption) (opentracing.Tracer, 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, spanID uint64, parentSpanID *uint64, sampled bool, flags flag.Flags)

+ State func() (traceID, spanID uint64, parentSpanID *uint64, sampled bool, flags flag.Flags)

+ 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 HTTPLogger(logger Logger) 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 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

+ type Span interface

+ Operation func() string

+ Start func() time.Time

+ type SpanContext struct

+ Baggage map[string]string

+ Flags flag.Flags

+ ParentSpanID *uint64

+ Sampled bool

+ SpanID uint64

+ TraceID uint64

+ 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 TrimUnsampledSpans(trim bool) TracerOption

+ func WithLogger(logger Logger) TracerOption

+ func WithSampler(sampler Sampler) TracerOption

+ type TracerOptions struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL