package wire

import "github.com/opentracing/basictracer-go/wire"

Package wire is a generated protocol buffer package.

It is generated from these files:

wire.proto

It has these top-level messages:

TracerState

Index ¶

• Variables
• type ProtobufCarrier
• func (p *ProtobufCarrier) GetBaggage(f func(k, v string))
• func (p *ProtobufCarrier) SetBaggageItem(key, value string)
• func (p *ProtobufCarrier) SetState(traceID, spanID uint64, sampled bool)
• func (p *ProtobufCarrier) State() (traceID, spanID uint64, sampled bool)
• type TracerState
• func (*TracerState) Descriptor() ([]byte, []int)
• func (m *TracerState) GetBaggageItems() map[string]string
• func (m *TracerState) Marshal() (data []byte, err error)
• func (m *TracerState) MarshalTo(data []byte) (int, error)
• func (*TracerState) ProtoMessage()
• func (m *TracerState) Reset()
• func (m *TracerState) Size() (n int)
• func (m *TracerState) String() string
• func (m *TracerState) Unmarshal(data []byte) error

Variables ¶

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

Types ¶

type ProtobufCarrier ¶

type ProtobufCarrier TracerState

ProtobufCarrier is a DelegatingCarrier that uses protocol buffers as the the underlying datastructure. The reason for implementing DelagatingCarrier is to allow for end users to serialize the underlying protocol buffers using jsonpb or any other serialization forms they want.

func (*ProtobufCarrier) GetBaggage ¶

func (p *ProtobufCarrier) GetBaggage(f func(k, v string))

GetBaggage iterates over each baggage item and executes the callback with the key:value pair.

func (*ProtobufCarrier) SetBaggageItem ¶

func (p *ProtobufCarrier) SetBaggageItem(key, value string)

SetBaggageItem sets a baggage item.

func (*ProtobufCarrier) SetState ¶

func (p *ProtobufCarrier) SetState(traceID, spanID uint64, sampled bool)

SetState set's the tracer state.

func (*ProtobufCarrier) State ¶

func (p *ProtobufCarrier) State() (traceID, spanID uint64, sampled bool)

State returns the tracer state.

type TracerState ¶

type TracerState struct {
	TraceId      uint64            `protobuf:"fixed64,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId       uint64            `protobuf:"fixed64,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	Sampled      bool              `protobuf:"varint,3,opt,name=sampled,proto3" json:"sampled,omitempty"`
	BaggageItems map[string]string `protobuf:"bytes,4,rep,name=baggage_items,json=baggageItems" json:"baggage_items,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

func (*TracerState) Descriptor ¶

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

func (*TracerState) GetBaggageItems ¶

func (m *TracerState) GetBaggageItems() map[string]string

func (*TracerState) Marshal ¶

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

func (*TracerState) MarshalTo ¶

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

func (*TracerState) ProtoMessage ¶

func (*TracerState) ProtoMessage()

func (*TracerState) Reset ¶

func (m *TracerState) Reset()

func (*TracerState) Size ¶

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

func (*TracerState) String ¶

func (m *TracerState) String() string

func (*TracerState) Unmarshal ¶

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

Source Files ¶

carrier.go gen.go wire.pb.go