wire

package
v2.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 29, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Package wire is used to serialize a trace.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBinary        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBinary          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBinary = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Field_FieldType_name = map[int32]string{
	0: "STRING",
	1: "BOOL",
	2: "INT_64",
	3: "UINT_64",
	4: "DURATION",
	6: "FLOAT_64",
}
View Source 
var Field_FieldType_value = map[string]int32{
	"STRING":   0,
	"BOOL":     1,
	"INT_64":   2,
	"UINT_64":  3,
	"DURATION": 4,
	"FLOAT_64": 6,
}

Functions

This section is empty.

Types

type Field 

type Field struct {
	Key       string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	FieldType Field_FieldType `protobuf:"varint,2,opt,name=field_type,json=fieldType,proto3,enum=wire.Field_FieldType" json:"field_type,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*Field_NumericVal
	//	*Field_StringVal
	Value isField_Value `protobuf_oneof:"value"`
}

func (*Field) Descriptor 

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

func (*Field) GetFieldType 

func (m *Field) GetFieldType() Field_FieldType

func (*Field) GetKey 

func (m *Field) GetKey() string

func (*Field) GetNumericVal 

func (m *Field) GetNumericVal() int64

func (*Field) GetStringVal 

func (m *Field) GetStringVal() string

func (*Field) GetValue 

func (m *Field) GetValue() isField_Value

func (*Field) Marshal 

func (m *Field) Marshal() (dAtA []byte, err error)

func (*Field) MarshalTo 

func (m *Field) MarshalTo(dAtA []byte) (int, error)

func (*Field) MarshalToSizedBuffer added in v2.0.5 

func (m *Field) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) Size 

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

func (*Field) String 

func (m *Field) String() string

func (*Field) Unmarshal 

func (m *Field) Unmarshal(dAtA []byte) error

func (*Field) XXX_DiscardUnknown added in v2.0.5 

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal added in v2.0.5 

func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Field) XXX_Merge added in v2.0.5 

func (m *Field) XXX_Merge(src proto.Message)

func (*Field) XXX_OneofWrappers added in v2.0.5 

func (*Field) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Field) XXX_Size added in v2.0.5 

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal added in v2.0.5 

func (m *Field) XXX_Unmarshal(b []byte) error

type Field_FieldType 

type Field_FieldType int32
const (
	FieldTypeString   Field_FieldType = 0
	FieldTypeBool     Field_FieldType = 1
	FieldTypeInt64    Field_FieldType = 2
	FieldTypeUint64   Field_FieldType = 3
	FieldTypeDuration Field_FieldType = 4
	FieldTypeFloat64  Field_FieldType = 6
)

func (Field_FieldType) EnumDescriptor 

func (Field_FieldType) EnumDescriptor() ([]byte, []int)

func (Field_FieldType) String 

func (x Field_FieldType) String() string

type Field_NumericVal 

type Field_NumericVal struct {
	NumericVal int64 `protobuf:"fixed64,3,opt,name=numeric_val,json=numericVal,proto3,oneof" json:"numeric_val,omitempty"`
}

func (*Field_NumericVal) MarshalTo 

func (m *Field_NumericVal) MarshalTo(dAtA []byte) (int, error)

func (*Field_NumericVal) MarshalToSizedBuffer added in v2.0.5 

func (m *Field_NumericVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Field_NumericVal) Size 

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

type Field_StringVal 

type Field_StringVal struct {
	StringVal string `protobuf:"bytes,4,opt,name=string_val,json=stringVal,proto3,oneof" json:"string_val,omitempty"`
}

func (*Field_StringVal) MarshalTo 

func (m *Field_StringVal) MarshalTo(dAtA []byte) (int, error)

func (*Field_StringVal) MarshalToSizedBuffer added in v2.0.5 

func (m *Field_StringVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Field_StringVal) Size 

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

type Span 

type Span struct {
	Context      SpanContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context"`
	ParentSpanID uint64      `protobuf:"varint,2,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"`
	Name         string      `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Start        time.Time   `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	Labels       []string    `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	Fields       []Field     `protobuf:"bytes,6,rep,name=fields,proto3" json:"fields"`
}

func (*Span) Descriptor 

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

func (*Span) GetContext 

func (m *Span) GetContext() SpanContext

func (*Span) GetFields 

func (m *Span) GetFields() []Field

func (*Span) GetLabels 

func (m *Span) GetLabels() []string

func (*Span) GetName 

func (m *Span) GetName() string

func (*Span) GetParentSpanID 

func (m *Span) GetParentSpanID() uint64

func (*Span) GetStart 

func (m *Span) GetStart() time.Time

func (*Span) Marshal 

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

func (*Span) MarshalTo 

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

func (*Span) MarshalToSizedBuffer added in v2.0.5 

func (m *Span) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) Reset 

func (m *Span) Reset()

func (*Span) Size 

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

func (*Span) String 

func (m *Span) String() string

func (*Span) Unmarshal 

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

func (*Span) XXX_DiscardUnknown added in v2.0.5 

func (m *Span) XXX_DiscardUnknown()

func (*Span) XXX_Marshal added in v2.0.5 

func (m *Span) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span) XXX_Merge added in v2.0.5 

func (m *Span) XXX_Merge(src proto.Message)

func (*Span) XXX_Size added in v2.0.5 

func (m *Span) XXX_Size() int

func (*Span) XXX_Unmarshal added in v2.0.5 

func (m *Span) XXX_Unmarshal(b []byte) error

type SpanContext 

type SpanContext 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"`
}

func (*SpanContext) Descriptor 

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

func (*SpanContext) GetSpanID 

func (m *SpanContext) GetSpanID() uint64

func (*SpanContext) GetTraceID 

func (m *SpanContext) GetTraceID() uint64

func (*SpanContext) Marshal 

func (m *SpanContext) Marshal() (dAtA []byte, err error)

func (*SpanContext) MarshalTo 

func (m *SpanContext) MarshalTo(dAtA []byte) (int, error)

func (*SpanContext) MarshalToSizedBuffer added in v2.0.5 

func (m *SpanContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SpanContext) ProtoMessage 

func (*SpanContext) ProtoMessage()

func (*SpanContext) Reset 

func (m *SpanContext) Reset()

func (*SpanContext) Size 

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

func (*SpanContext) String 

func (m *SpanContext) String() string

func (*SpanContext) Unmarshal 

func (m *SpanContext) Unmarshal(dAtA []byte) error

func (*SpanContext) XXX_DiscardUnknown added in v2.0.5 

func (m *SpanContext) XXX_DiscardUnknown()

func (*SpanContext) XXX_Marshal added in v2.0.5 

func (m *SpanContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpanContext) XXX_Merge added in v2.0.5 

func (m *SpanContext) XXX_Merge(src proto.Message)

func (*SpanContext) XXX_Size added in v2.0.5 

func (m *SpanContext) XXX_Size() int

func (*SpanContext) XXX_Unmarshal added in v2.0.5 

func (m *SpanContext) XXX_Unmarshal(b []byte) error

type Trace 

type Trace struct {
	Spans []*Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
}

func (*Trace) Descriptor 

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

func (*Trace) GetSpans 

func (m *Trace) GetSpans() []*Span

func (*Trace) Marshal 

func (m *Trace) Marshal() (dAtA []byte, err error)

func (*Trace) MarshalTo 

func (m *Trace) MarshalTo(dAtA []byte) (int, error)

func (*Trace) MarshalToSizedBuffer added in v2.0.5 

func (m *Trace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Trace) ProtoMessage 

func (*Trace) ProtoMessage()

func (*Trace) Reset 

func (m *Trace) Reset()

func (*Trace) Size 

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

func (*Trace) String 

func (m *Trace) String() string

func (*Trace) Unmarshal 

func (m *Trace) Unmarshal(dAtA []byte) error

func (*Trace) XXX_DiscardUnknown added in v2.0.5 

func (m *Trace) XXX_DiscardUnknown()

func (*Trace) XXX_Marshal added in v2.0.5 

func (m *Trace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Trace) XXX_Merge added in v2.0.5 

func (m *Trace) XXX_Merge(src proto.Message)

func (*Trace) XXX_Size added in v2.0.5 

func (m *Trace) XXX_Size() int

func (*Trace) XXX_Unmarshal added in v2.0.5 

func (m *Trace) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.