zipkintracer

package module

Go to main page

Versions in this module

v0

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