Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 Changes in this version + const BinaryType + const BoolType + const ChildOf + const DebugFlag + const FirehoseFlag + const Float64Type + const FollowsFrom + const Int64Type + const JaegerDependencyLinkSource + const SampledFlag + const StringType + var ErrIntOverflowModel = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthModel = fmt.Errorf("proto: negative length found during unmarshaling") + var SpanRefType_name = map[int32]string + var SpanRefType_value = map[string]int32 + var ValueType_name = map[int32]string + var ValueType_value = map[string]int32 + func DurationAsMicroseconds(d time.Duration) uint64 + func EpochMicrosecondsAsTime(ts uint64) time.Time + func HashCode(o Hashable) (uint64, error) + func MicrosecondsAsDuration(v uint64) time.Duration + func SortSpan(span *Span) + func SortTrace(trace *Trace) + func SortTraceIDs(traceIDs []*TraceID) + func SortTraces(traces []*Trace) + func TimeAsEpochMicroseconds(t time.Time) uint64 + type Batch struct + Process *Process + Spans []*Span + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Batch) Descriptor() ([]byte, []int) + func (*Batch) ProtoMessage() + func (m *Batch) GetProcess() *Process + func (m *Batch) GetSpans() []*Span + func (m *Batch) Marshal() (dAtA []byte, err error) + func (m *Batch) MarshalTo(dAtA []byte) (int, error) + func (m *Batch) Reset() + func (m *Batch) Size() (n int) + func (m *Batch) String() string + func (m *Batch) Unmarshal(dAtA []byte) error + func (m *Batch) XXX_DiscardUnknown() + func (m *Batch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Batch) XXX_Merge(src proto.Message) + func (m *Batch) XXX_Size() int + func (m *Batch) XXX_Unmarshal(b []byte) error + type DependencyLink struct + CallCount uint64 + Child string + Parent string + Source string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DependencyLink) Descriptor() ([]byte, []int) + func (*DependencyLink) ProtoMessage() + func (d DependencyLink) ApplyDefaults() DependencyLink + func (m *DependencyLink) GetCallCount() uint64 + func (m *DependencyLink) GetChild() string + func (m *DependencyLink) GetParent() string + func (m *DependencyLink) GetSource() string + func (m *DependencyLink) Marshal() (dAtA []byte, err error) + func (m *DependencyLink) MarshalTo(dAtA []byte) (int, error) + func (m *DependencyLink) Reset() + func (m *DependencyLink) Size() (n int) + func (m *DependencyLink) String() string + func (m *DependencyLink) Unmarshal(dAtA []byte) error + func (m *DependencyLink) XXX_DiscardUnknown() + func (m *DependencyLink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DependencyLink) XXX_Merge(src proto.Message) + func (m *DependencyLink) XXX_Size() int + func (m *DependencyLink) XXX_Unmarshal(b []byte) error + type Flags uint32 + func (f *Flags) SetDebug() + func (f *Flags) SetFirehose() + func (f *Flags) SetSampled() + func (f Flags) IsDebug() bool + func (f Flags) IsFirehoseEnabled() bool + func (f Flags) IsSampled() bool + type Hashable interface + Hash func(w io.Writer) error + type KeyValue struct + Key string + VBinary []byte + VBool bool + VFloat64 float64 + VInt64 int64 + VStr string + VType ValueType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func Binary(key string, value []byte) KeyValue + func Bool(key string, value bool) KeyValue + func Float64(key string, value float64) KeyValue + func Int64(key string, value int64) KeyValue + func String(key string, value string) KeyValue + func (*KeyValue) Descriptor() ([]byte, []int) + func (*KeyValue) ProtoMessage() + func (kv *KeyValue) AsString() string + func (kv *KeyValue) Binary() []byte + func (kv *KeyValue) Bool() bool + func (kv *KeyValue) Float64() float64 + func (kv *KeyValue) Int64() int64 + func (kv *KeyValue) IsLess(two *KeyValue) bool + func (kv *KeyValue) Value() interface{} + func (kv KeyValue) Hash(w io.Writer) error + func (m *KeyValue) GetKey() string + func (m *KeyValue) GetVBinary() []byte + func (m *KeyValue) GetVBool() bool + func (m *KeyValue) GetVFloat64() float64 + func (m *KeyValue) GetVInt64() int64 + func (m *KeyValue) GetVStr() string + func (m *KeyValue) GetVType() ValueType + func (m *KeyValue) Marshal() (dAtA []byte, err error) + func (m *KeyValue) MarshalTo(dAtA []byte) (int, error) + func (m *KeyValue) Reset() + func (m *KeyValue) Size() (n int) + func (m *KeyValue) String() string + func (m *KeyValue) Unmarshal(dAtA []byte) error + func (m *KeyValue) XXX_DiscardUnknown() + func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyValue) XXX_Merge(src proto.Message) + func (m *KeyValue) XXX_Size() int + func (m *KeyValue) XXX_Unmarshal(b []byte) error + func (this *KeyValue) Compare(that interface{}) int + func (this *KeyValue) Equal(that interface{}) bool + type KeyValues []KeyValue + func (kvs KeyValues) Equal(other KeyValues) bool + func (kvs KeyValues) FindByKey(key string) (KeyValue, bool) + func (kvs KeyValues) Hash(w io.Writer) error + func (kvs KeyValues) Len() int + func (kvs KeyValues) Less(i, j int) bool + func (kvs KeyValues) Sort() + func (kvs KeyValues) Swap(i, j int) + type Log struct + Fields []KeyValue + Timestamp time.Time + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Log) Descriptor() ([]byte, []int) + func (*Log) ProtoMessage() + func (m *Log) GetFields() []KeyValue + func (m *Log) GetTimestamp() time.Time + func (m *Log) Marshal() (dAtA []byte, err error) + func (m *Log) MarshalTo(dAtA []byte) (int, error) + func (m *Log) Reset() + func (m *Log) Size() (n int) + func (m *Log) String() string + func (m *Log) Unmarshal(dAtA []byte) error + func (m *Log) XXX_DiscardUnknown() + func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Log) XXX_Merge(src proto.Message) + func (m *Log) XXX_Size() int + func (m *Log) XXX_Unmarshal(b []byte) error + type Process struct + ServiceName string + Tags []KeyValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewProcess(serviceName string, tags []KeyValue) *Process + func (*Process) Descriptor() ([]byte, []int) + func (*Process) ProtoMessage() + func (m *Process) GetServiceName() string + func (m *Process) GetTags() []KeyValue + func (m *Process) Marshal() (dAtA []byte, err error) + func (m *Process) MarshalTo(dAtA []byte) (int, error) + func (m *Process) Reset() + func (m *Process) Size() (n int) + func (m *Process) String() string + func (m *Process) Unmarshal(dAtA []byte) error + func (m *Process) XXX_DiscardUnknown() + func (m *Process) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Process) XXX_Merge(src proto.Message) + func (m *Process) XXX_Size() int + func (m *Process) XXX_Unmarshal(b []byte) error + func (p *Process) Equal(other *Process) bool + func (p *Process) Hash(w io.Writer) (err error) + type Span struct + Duration time.Duration + Flags Flags + Logs []Log + OperationName string + Process *Process + ProcessID string + References []SpanRef + SpanID SpanID + StartTime time.Time + Tags []KeyValue + TraceID TraceID + Warnings []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Span) Descriptor() ([]byte, []int) + func (*Span) ProtoMessage() + func (m *Span) GetDuration() time.Duration + func (m *Span) GetLogs() []Log + func (m *Span) GetOperationName() string + func (m *Span) GetProcess() *Process + func (m *Span) GetProcessID() string + func (m *Span) GetReferences() []SpanRef + func (m *Span) GetStartTime() time.Time + func (m *Span) GetTags() []KeyValue + func (m *Span) GetWarnings() []string + func (m *Span) Marshal() (dAtA []byte, err error) + func (m *Span) MarshalTo(dAtA []byte) (int, error) + func (m *Span) Reset() + func (m *Span) Size() (n int) + func (m *Span) String() string + func (m *Span) Unmarshal(dAtA []byte) error + func (m *Span) XXX_DiscardUnknown() + func (m *Span) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Span) XXX_Merge(src proto.Message) + func (m *Span) XXX_Size() int + func (m *Span) XXX_Unmarshal(b []byte) error + func (s *Span) GetSamplerType() string + func (s *Span) HasSpanKind(kind ext.SpanKindEnum) bool + func (s *Span) Hash(w io.Writer) (err error) + func (s *Span) IsRPCClient() bool + func (s *Span) IsRPCServer() bool + func (s *Span) NormalizeTimestamps() + func (s *Span) ParentSpanID() SpanID + func (s *Span) ReplaceParentID(newParentID SpanID) + type SpanID uint64 + func NewSpanID(v uint64) SpanID + func SpanIDFromBytes(data []byte) (SpanID, error) + func SpanIDFromString(s string) (SpanID, error) + func (s *SpanID) MarshalTo(data []byte) (n int, err error) + func (s *SpanID) Size() int + func (s *SpanID) Unmarshal(data []byte) error + func (s *SpanID) UnmarshalJSON(data []byte) error + func (s *SpanID) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error + func (s *SpanID) UnmarshalText(text []byte) error + func (s SpanID) MarshalJSON() ([]byte, error) + func (s SpanID) MarshalText() ([]byte, error) + func (s SpanID) String() string + type SpanRef struct + RefType SpanRefType + SpanID SpanID + TraceID TraceID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func MaybeAddParentSpanID(traceID TraceID, parentSpanID SpanID, refs []SpanRef) []SpanRef + func NewChildOfRef(traceID TraceID, spanID SpanID) SpanRef + func NewFollowsFromRef(traceID TraceID, spanID SpanID) SpanRef + func (*SpanRef) Descriptor() ([]byte, []int) + func (*SpanRef) ProtoMessage() + func (m *SpanRef) GetRefType() SpanRefType + func (m *SpanRef) Marshal() (dAtA []byte, err error) + func (m *SpanRef) MarshalTo(dAtA []byte) (int, error) + func (m *SpanRef) Reset() + func (m *SpanRef) Size() (n int) + func (m *SpanRef) String() string + func (m *SpanRef) Unmarshal(dAtA []byte) error + func (m *SpanRef) XXX_DiscardUnknown() + func (m *SpanRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SpanRef) XXX_Merge(src proto.Message) + func (m *SpanRef) XXX_Size() int + func (m *SpanRef) XXX_Unmarshal(b []byte) error + type SpanRefType int32 + const SpanRefType_CHILD_OF + const SpanRefType_FOLLOWS_FROM + func (SpanRefType) EnumDescriptor() ([]byte, []int) + func (x SpanRefType) String() string + type Trace struct + ProcessMap []Trace_ProcessMapping + Spans []*Span + Warnings []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Trace) Descriptor() ([]byte, []int) + func (*Trace) ProtoMessage() + func (m *Trace) GetProcessMap() []Trace_ProcessMapping + func (m *Trace) GetSpans() []*Span + func (m *Trace) GetWarnings() []string + func (m *Trace) Marshal() (dAtA []byte, err error) + func (m *Trace) MarshalTo(dAtA []byte) (int, error) + func (m *Trace) Reset() + func (m *Trace) Size() (n int) + func (m *Trace) String() string + func (m *Trace) Unmarshal(dAtA []byte) error + func (m *Trace) XXX_DiscardUnknown() + func (m *Trace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Trace) XXX_Merge(src proto.Message) + func (m *Trace) XXX_Size() int + func (m *Trace) XXX_Unmarshal(b []byte) error + func (t *Trace) FindSpanByID(id SpanID) *Span + func (t *Trace) NormalizeTimestamps() + type TraceID struct + High uint64 + Low uint64 + func NewTraceID(high, low uint64) TraceID + func TraceIDFromBytes(data []byte) (TraceID, error) + func TraceIDFromString(s string) (TraceID, error) + func (t *TraceID) MarshalTo(data []byte) (n int, err error) + func (t *TraceID) Size() int + func (t *TraceID) Unmarshal(data []byte) error + func (t *TraceID) UnmarshalJSON(data []byte) error + func (t *TraceID) UnmarshalText(text []byte) error + func (t TraceID) MarshalJSON() ([]byte, error) + func (t TraceID) MarshalText() ([]byte, error) + func (t TraceID) String() string + type Trace_ProcessMapping struct + Process Process + ProcessID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Trace_ProcessMapping) Descriptor() ([]byte, []int) + func (*Trace_ProcessMapping) ProtoMessage() + func (m *Trace_ProcessMapping) GetProcess() Process + func (m *Trace_ProcessMapping) GetProcessID() string + func (m *Trace_ProcessMapping) Marshal() (dAtA []byte, err error) + func (m *Trace_ProcessMapping) MarshalTo(dAtA []byte) (int, error) + func (m *Trace_ProcessMapping) Reset() + func (m *Trace_ProcessMapping) Size() (n int) + func (m *Trace_ProcessMapping) String() string + func (m *Trace_ProcessMapping) Unmarshal(dAtA []byte) error + func (m *Trace_ProcessMapping) XXX_DiscardUnknown() + func (m *Trace_ProcessMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Trace_ProcessMapping) XXX_Merge(src proto.Message) + func (m *Trace_ProcessMapping) XXX_Size() int + func (m *Trace_ProcessMapping) XXX_Unmarshal(b []byte) error + type ValueType int32 + const ValueType_BINARY + const ValueType_BOOL + const ValueType_FLOAT64 + const ValueType_INT64 + const ValueType_STRING + func (ValueType) EnumDescriptor() ([]byte, []int) + func (x ValueType) String() string