cockroach: github.com/abhinavdahiya/cockroach/util/tracing Index | Files

package tracing

import "github.com/abhinavdahiya/cockroach/util/tracing"

Package tracing is a generated protocol buffer package.

It is generated from these files:

cockroach/util/tracing/span.proto

It has these top-level messages:

Span

Index

Package Files

annotate.go span.go span.pb.go tracer.go

Constants

const Snowball = "sb"

Snowball is set as Baggage on traces which are used for snowball tracing.

Variables

var (
    ErrInvalidLengthSpan = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowSpan   = fmt.Errorf("proto: integer overflow")
)

func AnnotateTrace Uses

func AnnotateTrace()

AnnotateTrace adds an annotation to the golang executation tracer by calling a no-op cgo function.

func DecodeRawSpan Uses

func DecodeRawSpan(enc []byte, dest *basictracer.RawSpan) error

DecodeRawSpan unmarshals into the given RawSpan.

func Disable Uses

func Disable() func()

Disable is for benchmarking use and causes all future tracers to deal in no-ops. Calling the returned closure undoes this effect. There is no synchronization, so no moving parts are allowed while Disable and the closure are called.

func EncodeRawSpan Uses

func EncodeRawSpan(rawSpan *basictracer.RawSpan, dest []byte) ([]byte, error)

EncodeRawSpan encodes a raw span into bytes, using the given dest slice as a buffer.

func EnsureContext Uses

func EnsureContext(ctx context.Context, tracer opentracing.Tracer) (context.Context, func())

EnsureContext checks whether the given context.Context contains a Span. If not, it creates one using the provided Tracer and wraps it in the returned Span. The returned closure must be called after the request has been fully processed.

func JoinOrNew Uses

func JoinOrNew(tr opentracing.Tracer, carrier *Span, opName string) (opentracing.Span, error)

JoinOrNew creates a new Span joined to the provided DelegatingCarrier or creates Span from the given tracer.

func JoinOrNewSnowball Uses

func JoinOrNewSnowball(opName string, carrier *Span, callback func(sp basictracer.RawSpan)) (opentracing.Span, error)

JoinOrNewSnowball returns a Span which records directly via the specified callback. If the given DelegatingCarrier is nil, a new Span is created. otherwise, the created Span is a child.

func NewTracer Uses

func NewTracer() opentracing.Tracer

NewTracer creates a Tracer which records to the net/trace endpoint.

type CallbackRecorder Uses

type CallbackRecorder func(sp basictracer.RawSpan)

A CallbackRecorder immediately invokes itself on received trace spans.

func (CallbackRecorder) RecordSpan Uses

func (cr CallbackRecorder) RecordSpan(sp basictracer.RawSpan)

RecordSpan implements basictracer.SpanRecorder.

type Span Uses

type Span struct {
    TraceID uint64            `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
    SpanID  uint64            `protobuf:"varint,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
    Sampled bool              `protobuf:"varint,3,opt,name=sampled,proto3" json:"sampled,omitempty"`
    Baggage map[string]string `protobuf:"bytes,4,rep,name=baggage" json:"baggage,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

A Span message holds metadata of a (potentially ongoing) span of a distributed trace as per the OpenTracing specification. See http://opentracing.io/spec/ for details.

func (*Span) Descriptor Uses

func (*Span) Descriptor() ([]byte, []int)

func (*Span) GetBaggage Uses

func (sp *Span) GetBaggage(fn func(key, value string))

GetBaggage implements basictracer.DelegatingCarrier.

func (*Span) Marshal Uses

func (m *Span) Marshal() (data []byte, err error)

func (*Span) MarshalTo Uses

func (m *Span) MarshalTo(data []byte) (int, error)

func (*Span) ProtoMessage Uses

func (*Span) ProtoMessage()

func (*Span) Reset Uses

func (m *Span) Reset()

func (*Span) SetBaggageItem Uses

func (sp *Span) SetBaggageItem(key, value string)

SetBaggageItem implements basictracer.DelegatingCarrier.

func (*Span) SetState Uses

func (sp *Span) SetState(traceID, spanID uint64, sampled bool)

SetState implements basictracer.DelegatingCarrier.

func (*Span) Size Uses

func (m *Span) Size() (n int)

func (*Span) State Uses

func (sp *Span) State() (traceID, spanID uint64, sampled bool)

State implements basictracer.DelegatingCarrier.

func (*Span) String Uses

func (m *Span) String() string

func (*Span) Unmarshal Uses

func (m *Span) Unmarshal(data []byte) error

Package tracing imports 16 packages (graph). Updated 2017-03-13. Refresh now. Tools for package owners. This is a dead-end fork (no commits since the fork).