Documentation
¶
Overview ¶
Package trace defines the types and functions to encode/decode traces.
Index ¶
- Variables
- type AgentPayload
- func (*AgentPayload) Descriptor() ([]byte, []int)deprecated
- func (x *AgentPayload) GetAgentVersion() string
- func (x *AgentPayload) GetEnv() string
- func (x *AgentPayload) GetErrorTPS() float64
- func (x *AgentPayload) GetHostName() string
- func (x *AgentPayload) GetIdxTracerPayloads() []*idx.TracerPayload
- func (x *AgentPayload) GetRareSamplerEnabled() bool
- func (x *AgentPayload) GetTags() map[string]string
- func (x *AgentPayload) GetTargetTPS() float64
- func (x *AgentPayload) GetTracerPayloads() []*TracerPayload
- func (z *AgentPayload) MarshalMsg(b []byte) (o []byte, err error)
- func (m *AgentPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AgentPayload) MarshalToVT(dAtA []byte) (int, error)
- func (m *AgentPayload) MarshalVT() (dAtA []byte, err error)
- func (z *AgentPayload) Msgsize() (s int)
- func (*AgentPayload) ProtoMessage()
- func (x *AgentPayload) ProtoReflect() protoreflect.Message
- func (x *AgentPayload) Reset()
- func (m *AgentPayload) SizeVT() (n int)
- func (x *AgentPayload) String() string
- func (z *AgentPayload) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *AgentPayload) UnmarshalVT(dAtA []byte) error
- type AttributeAnyValue
- func (*AttributeAnyValue) Descriptor() ([]byte, []int)deprecated
- func (x *AttributeAnyValue) GetArrayValue() *AttributeArray
- func (x *AttributeAnyValue) GetBoolValue() bool
- func (x *AttributeAnyValue) GetDoubleValue() float64
- func (x *AttributeAnyValue) GetIntValue() int64
- func (x *AttributeAnyValue) GetStringValue() string
- func (x *AttributeAnyValue) GetType() AttributeAnyValue_AttributeAnyValueType
- func (z *AttributeAnyValue) MarshalMsg(b []byte) (o []byte, err error)
- func (m *AttributeAnyValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AttributeAnyValue) MarshalToVT(dAtA []byte) (int, error)
- func (m *AttributeAnyValue) MarshalVT() (dAtA []byte, err error)
- func (z *AttributeAnyValue) Msgsize() (s int)
- func (*AttributeAnyValue) ProtoMessage()
- func (x *AttributeAnyValue) ProtoReflect() protoreflect.Message
- func (x *AttributeAnyValue) Reset()
- func (m *AttributeAnyValue) SizeVT() (n int)
- func (x *AttributeAnyValue) String() string
- func (z *AttributeAnyValue) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *AttributeAnyValue) UnmarshalVT(dAtA []byte) error
- type AttributeAnyValue_AttributeAnyValueType
- func (AttributeAnyValue_AttributeAnyValueType) Descriptor() protoreflect.EnumDescriptor
- func (x AttributeAnyValue_AttributeAnyValueType) Enum() *AttributeAnyValue_AttributeAnyValueType
- func (AttributeAnyValue_AttributeAnyValueType) EnumDescriptor() ([]byte, []int)deprecated
- func (z AttributeAnyValue_AttributeAnyValueType) MarshalMsg(b []byte) (o []byte, err error)
- func (z AttributeAnyValue_AttributeAnyValueType) Msgsize() (s int)
- func (x AttributeAnyValue_AttributeAnyValueType) Number() protoreflect.EnumNumber
- func (x AttributeAnyValue_AttributeAnyValueType) String() string
- func (AttributeAnyValue_AttributeAnyValueType) Type() protoreflect.EnumType
- func (z *AttributeAnyValue_AttributeAnyValueType) UnmarshalMsg(bts []byte) (o []byte, err error)
- type AttributeArray
- func (*AttributeArray) Descriptor() ([]byte, []int)deprecated
- func (x *AttributeArray) GetValues() []*AttributeArrayValue
- func (z *AttributeArray) MarshalMsg(b []byte) (o []byte, err error)
- func (m *AttributeArray) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AttributeArray) MarshalToVT(dAtA []byte) (int, error)
- func (m *AttributeArray) MarshalVT() (dAtA []byte, err error)
- func (z *AttributeArray) Msgsize() (s int)
- func (*AttributeArray) ProtoMessage()
- func (x *AttributeArray) ProtoReflect() protoreflect.Message
- func (x *AttributeArray) Reset()
- func (m *AttributeArray) SizeVT() (n int)
- func (x *AttributeArray) String() string
- func (z *AttributeArray) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *AttributeArray) UnmarshalVT(dAtA []byte) error
- type AttributeArrayValue
- func (*AttributeArrayValue) Descriptor() ([]byte, []int)deprecated
- func (x *AttributeArrayValue) GetBoolValue() bool
- func (x *AttributeArrayValue) GetDoubleValue() float64
- func (x *AttributeArrayValue) GetIntValue() int64
- func (x *AttributeArrayValue) GetStringValue() string
- func (x *AttributeArrayValue) GetType() AttributeArrayValue_AttributeArrayValueType
- func (z *AttributeArrayValue) MarshalMsg(b []byte) (o []byte, err error)
- func (m *AttributeArrayValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AttributeArrayValue) MarshalToVT(dAtA []byte) (int, error)
- func (m *AttributeArrayValue) MarshalVT() (dAtA []byte, err error)
- func (z *AttributeArrayValue) Msgsize() (s int)
- func (*AttributeArrayValue) ProtoMessage()
- func (x *AttributeArrayValue) ProtoReflect() protoreflect.Message
- func (x *AttributeArrayValue) Reset()
- func (m *AttributeArrayValue) SizeVT() (n int)
- func (x *AttributeArrayValue) String() string
- func (z *AttributeArrayValue) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *AttributeArrayValue) UnmarshalVT(dAtA []byte) error
- type AttributeArrayValue_AttributeArrayValueType
- func (AttributeArrayValue_AttributeArrayValueType) Descriptor() protoreflect.EnumDescriptor
- func (x AttributeArrayValue_AttributeArrayValueType) Enum() *AttributeArrayValue_AttributeArrayValueType
- func (AttributeArrayValue_AttributeArrayValueType) EnumDescriptor() ([]byte, []int)deprecated
- func (z AttributeArrayValue_AttributeArrayValueType) MarshalMsg(b []byte) (o []byte, err error)
- func (z AttributeArrayValue_AttributeArrayValueType) Msgsize() (s int)
- func (x AttributeArrayValue_AttributeArrayValueType) Number() protoreflect.EnumNumber
- func (x AttributeArrayValue_AttributeArrayValueType) String() string
- func (AttributeArrayValue_AttributeArrayValueType) Type() protoreflect.EnumType
- func (z *AttributeArrayValue_AttributeArrayValueType) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ClientGroupedStats
- func (z *ClientGroupedStats) DecodeMsg(dc *msgp.Reader) (err error)
- func (*ClientGroupedStats) Descriptor() ([]byte, []int)deprecated
- func (z *ClientGroupedStats) EncodeMsg(en *msgp.Writer) (err error)
- func (x *ClientGroupedStats) GetDBType() string
- func (x *ClientGroupedStats) GetDuration() uint64
- func (x *ClientGroupedStats) GetErrorSummary() []byte
- func (x *ClientGroupedStats) GetErrors() uint64
- func (x *ClientGroupedStats) GetGRPCStatusCode() string
- func (x *ClientGroupedStats) GetHTTPEndpoint() string
- func (x *ClientGroupedStats) GetHTTPMethod() string
- func (x *ClientGroupedStats) GetHTTPStatusCode() uint32
- func (x *ClientGroupedStats) GetHits() uint64
- func (x *ClientGroupedStats) GetIsTraceRoot() Trilean
- func (x *ClientGroupedStats) GetName() string
- func (x *ClientGroupedStats) GetOkSummary() []byte
- func (x *ClientGroupedStats) GetPeerTags() []string
- func (x *ClientGroupedStats) GetResource() string
- func (x *ClientGroupedStats) GetService() string
- func (x *ClientGroupedStats) GetSpanKind() string
- func (x *ClientGroupedStats) GetSynthetics() bool
- func (x *ClientGroupedStats) GetTopLevelHits() uint64
- func (x *ClientGroupedStats) GetType() string
- func (z *ClientGroupedStats) MarshalMsg(b []byte) (o []byte, err error)
- func (m *ClientGroupedStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ClientGroupedStats) MarshalToVT(dAtA []byte) (int, error)
- func (m *ClientGroupedStats) MarshalVT() (dAtA []byte, err error)
- func (z *ClientGroupedStats) Msgsize() (s int)
- func (*ClientGroupedStats) ProtoMessage()
- func (x *ClientGroupedStats) ProtoReflect() protoreflect.Message
- func (x *ClientGroupedStats) Reset()
- func (m *ClientGroupedStats) SizeVT() (n int)
- func (x *ClientGroupedStats) String() string
- func (z *ClientGroupedStats) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *ClientGroupedStats) UnmarshalVT(dAtA []byte) error
- type ClientStatsBucket
- func (z *ClientStatsBucket) DecodeMsg(dc *msgp.Reader) (err error)
- func (*ClientStatsBucket) Descriptor() ([]byte, []int)deprecated
- func (z *ClientStatsBucket) EncodeMsg(en *msgp.Writer) (err error)
- func (x *ClientStatsBucket) GetAgentTimeShift() int64
- func (x *ClientStatsBucket) GetDuration() uint64
- func (x *ClientStatsBucket) GetStart() uint64
- func (x *ClientStatsBucket) GetStats() []*ClientGroupedStats
- func (z *ClientStatsBucket) MarshalMsg(b []byte) (o []byte, err error)
- func (m *ClientStatsBucket) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ClientStatsBucket) MarshalToVT(dAtA []byte) (int, error)
- func (m *ClientStatsBucket) MarshalVT() (dAtA []byte, err error)
- func (z *ClientStatsBucket) Msgsize() (s int)
- func (*ClientStatsBucket) ProtoMessage()
- func (x *ClientStatsBucket) ProtoReflect() protoreflect.Message
- func (x *ClientStatsBucket) Reset()
- func (m *ClientStatsBucket) SizeVT() (n int)
- func (x *ClientStatsBucket) String() string
- func (z *ClientStatsBucket) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *ClientStatsBucket) UnmarshalVT(dAtA []byte) error
- type ClientStatsPayload
- func (z *ClientStatsPayload) DecodeMsg(dc *msgp.Reader) (err error)
- func (*ClientStatsPayload) Descriptor() ([]byte, []int)deprecated
- func (z *ClientStatsPayload) EncodeMsg(en *msgp.Writer) (err error)
- func (x *ClientStatsPayload) GetAgentAggregation() string
- func (x *ClientStatsPayload) GetContainerID() string
- func (x *ClientStatsPayload) GetEnv() string
- func (x *ClientStatsPayload) GetGitCommitSha() string
- func (x *ClientStatsPayload) GetHostname() string
- func (x *ClientStatsPayload) GetImageTag() string
- func (x *ClientStatsPayload) GetLang() string
- func (x *ClientStatsPayload) GetProcessTags() string
- func (x *ClientStatsPayload) GetProcessTagsHash() uint64
- func (x *ClientStatsPayload) GetRuntimeID() string
- func (x *ClientStatsPayload) GetSequence() uint64
- func (x *ClientStatsPayload) GetService() string
- func (x *ClientStatsPayload) GetStats() []*ClientStatsBucket
- func (x *ClientStatsPayload) GetTags() []string
- func (x *ClientStatsPayload) GetTracerVersion() string
- func (x *ClientStatsPayload) GetVersion() string
- func (z *ClientStatsPayload) MarshalMsg(b []byte) (o []byte, err error)
- func (m *ClientStatsPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ClientStatsPayload) MarshalToVT(dAtA []byte) (int, error)
- func (m *ClientStatsPayload) MarshalVT() (dAtA []byte, err error)
- func (z *ClientStatsPayload) Msgsize() (s int)
- func (*ClientStatsPayload) ProtoMessage()
- func (x *ClientStatsPayload) ProtoReflect() protoreflect.Message
- func (x *ClientStatsPayload) Reset()
- func (m *ClientStatsPayload) SizeVT() (n int)
- func (x *ClientStatsPayload) String() string
- func (z *ClientStatsPayload) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *ClientStatsPayload) UnmarshalVT(dAtA []byte) error
- type Span
- func (*Span) Descriptor() ([]byte, []int)deprecated
- func (s *Span) Get128BitTraceID() ([]byte, error)
- func (x *Span) GetDuration() int64
- func (x *Span) GetError() int32
- func (x *Span) GetMeta() map[string]string
- func (x *Span) GetMetaStruct() map[string][]byte
- func (x *Span) GetMetrics() map[string]float64
- func (x *Span) GetName() string
- func (x *Span) GetParentID() uint64
- func (x *Span) GetResource() string
- func (x *Span) GetService() string
- func (x *Span) GetSpanEvents() []*SpanEvent
- func (x *Span) GetSpanID() uint64
- func (x *Span) GetSpanLinks() []*SpanLink
- func (x *Span) GetStart() int64
- func (x *Span) GetTraceID() uint64
- func (x *Span) GetType() string
- func (z *Span) MarshalMsg(b []byte) (o []byte, err error)
- func (m *Span) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Span) MarshalToVT(dAtA []byte) (int, error)
- func (m *Span) MarshalVT() (dAtA []byte, err error)
- func (z *Span) Msgsize() (s int)
- func (*Span) ProtoMessage()
- func (x *Span) ProtoReflect() protoreflect.Message
- func (x *Span) Reset()
- func (s *Span) ShallowCopy() *Span
- func (m *Span) SizeVT() (n int)
- func (x *Span) String() string
- func (z *Span) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (z *Span) UnmarshalMsgDictionary(bts []byte, dict []string) ([]byte, error)
- func (m *Span) UnmarshalVT(dAtA []byte) error
- type SpanEvent
- func (*SpanEvent) Descriptor() ([]byte, []int)deprecated
- func (x *SpanEvent) GetAttributes() map[string]*AttributeAnyValue
- func (x *SpanEvent) GetName() string
- func (x *SpanEvent) GetTimeUnixNano() uint64
- func (z *SpanEvent) MarshalMsg(b []byte) (o []byte, err error)
- func (m *SpanEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SpanEvent) MarshalToVT(dAtA []byte) (int, error)
- func (m *SpanEvent) MarshalVT() (dAtA []byte, err error)
- func (z *SpanEvent) Msgsize() (s int)
- func (*SpanEvent) ProtoMessage()
- func (x *SpanEvent) ProtoReflect() protoreflect.Message
- func (x *SpanEvent) Reset()
- func (m *SpanEvent) SizeVT() (n int)
- func (x *SpanEvent) String() string
- func (z *SpanEvent) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *SpanEvent) UnmarshalVT(dAtA []byte) error
- type SpanLink
- func (*SpanLink) Descriptor() ([]byte, []int)deprecated
- func (x *SpanLink) GetAttributes() map[string]string
- func (x *SpanLink) GetFlags() uint32
- func (x *SpanLink) GetSpanID() uint64
- func (x *SpanLink) GetTraceID() uint64
- func (x *SpanLink) GetTraceIDHigh() uint64
- func (x *SpanLink) GetTracestate() string
- func (z *SpanLink) MarshalMsg(b []byte) (o []byte, err error)
- func (m *SpanLink) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SpanLink) MarshalToVT(dAtA []byte) (int, error)
- func (m *SpanLink) MarshalVT() (dAtA []byte, err error)
- func (z *SpanLink) Msgsize() (s int)
- func (*SpanLink) ProtoMessage()
- func (x *SpanLink) ProtoReflect() protoreflect.Message
- func (x *SpanLink) Reset()
- func (m *SpanLink) SizeVT() (n int)
- func (x *SpanLink) String() string
- func (z *SpanLink) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *SpanLink) UnmarshalVT(dAtA []byte) error
- type StatsPayload
- func (z *StatsPayload) DecodeMsg(dc *msgp.Reader) (err error)
- func (*StatsPayload) Descriptor() ([]byte, []int)deprecated
- func (z *StatsPayload) EncodeMsg(en *msgp.Writer) (err error)
- func (x *StatsPayload) GetAgentEnv() string
- func (x *StatsPayload) GetAgentHostname() string
- func (x *StatsPayload) GetAgentVersion() string
- func (x *StatsPayload) GetClientComputed() bool
- func (x *StatsPayload) GetSplitPayload() bool
- func (x *StatsPayload) GetStats() []*ClientStatsPayload
- func (z *StatsPayload) MarshalMsg(b []byte) (o []byte, err error)
- func (m *StatsPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StatsPayload) MarshalToVT(dAtA []byte) (int, error)
- func (m *StatsPayload) MarshalVT() (dAtA []byte, err error)
- func (z *StatsPayload) Msgsize() (s int)
- func (*StatsPayload) ProtoMessage()
- func (x *StatsPayload) ProtoReflect() protoreflect.Message
- func (x *StatsPayload) Reset()
- func (m *StatsPayload) SizeVT() (n int)
- func (x *StatsPayload) String() string
- func (z *StatsPayload) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *StatsPayload) UnmarshalVT(dAtA []byte) error
- type Trace
- type TraceChunk
- func (*TraceChunk) Descriptor() ([]byte, []int)deprecated
- func (x *TraceChunk) GetDroppedTrace() bool
- func (x *TraceChunk) GetOrigin() string
- func (x *TraceChunk) GetPriority() int32
- func (x *TraceChunk) GetSpans() []*Span
- func (x *TraceChunk) GetTags() map[string]string
- func (z *TraceChunk) MarshalMsg(b []byte) (o []byte, err error)
- func (m *TraceChunk) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TraceChunk) MarshalToVT(dAtA []byte) (int, error)
- func (m *TraceChunk) MarshalVT() (dAtA []byte, err error)
- func (z *TraceChunk) Msgsize() (s int)
- func (*TraceChunk) ProtoMessage()
- func (x *TraceChunk) ProtoReflect() protoreflect.Message
- func (x *TraceChunk) Reset()
- func (t *TraceChunk) ShallowCopy() *TraceChunk
- func (m *TraceChunk) SizeVT() (n int)
- func (x *TraceChunk) String() string
- func (z *TraceChunk) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *TraceChunk) UnmarshalVT(dAtA []byte) error
- type TraceRootFlag
- func (z *TraceRootFlag) DecodeMsg(dc *msgp.Reader) (err error)
- func (TraceRootFlag) Descriptor() protoreflect.EnumDescriptor
- func (z TraceRootFlag) EncodeMsg(en *msgp.Writer) (err error)
- func (x TraceRootFlag) Enum() *TraceRootFlag
- func (TraceRootFlag) EnumDescriptor() ([]byte, []int)deprecated
- func (z TraceRootFlag) MarshalMsg(b []byte) (o []byte, err error)
- func (z TraceRootFlag) Msgsize() (s int)
- func (x TraceRootFlag) Number() protoreflect.EnumNumber
- func (x TraceRootFlag) String() string
- func (TraceRootFlag) Type() protoreflect.EnumType
- func (z *TraceRootFlag) UnmarshalMsg(bts []byte) (o []byte, err error)
- type TracerPayload
- func (p *TracerPayload) Cut(i int) *TracerPayload
- func (*TracerPayload) Descriptor() ([]byte, []int)deprecated
- func (x *TracerPayload) GetAppVersion() string
- func (x *TracerPayload) GetChunks() []*TraceChunk
- func (x *TracerPayload) GetContainerID() string
- func (x *TracerPayload) GetEnv() string
- func (x *TracerPayload) GetHostname() string
- func (x *TracerPayload) GetLanguageName() string
- func (x *TracerPayload) GetLanguageVersion() string
- func (x *TracerPayload) GetRuntimeID() string
- func (x *TracerPayload) GetTags() map[string]string
- func (x *TracerPayload) GetTracerVersion() string
- func (z *TracerPayload) MarshalMsg(b []byte) (o []byte, err error)
- func (m *TracerPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TracerPayload) MarshalToVT(dAtA []byte) (int, error)
- func (m *TracerPayload) MarshalVT() (dAtA []byte, err error)
- func (z *TracerPayload) Msgsize() (s int)
- func (*TracerPayload) ProtoMessage()
- func (x *TracerPayload) ProtoReflect() protoreflect.Message
- func (p *TracerPayload) RemoveChunk(i int)
- func (x *TracerPayload) Reset()
- func (m *TracerPayload) SizeVT() (n int)
- func (x *TracerPayload) String() string
- func (z *TracerPayload) UnmarshalMsg(bts []byte) (o []byte, err error)
- func (m *TracerPayload) UnmarshalVT(dAtA []byte) error
- type Traces
- type Trilean
- func (z *Trilean) DecodeMsg(dc *msgp.Reader) (err error)
- func (Trilean) Descriptor() protoreflect.EnumDescriptor
- func (z Trilean) EncodeMsg(en *msgp.Writer) (err error)
- func (x Trilean) Enum() *Trilean
- func (Trilean) EnumDescriptor() ([]byte, []int)deprecated
- func (z Trilean) MarshalMsg(b []byte) (o []byte, err error)
- func (z Trilean) Msgsize() (s int)
- func (x Trilean) Number() protoreflect.EnumNumber
- func (x Trilean) String() string
- func (Trilean) Type() protoreflect.EnumType
- func (z *Trilean) UnmarshalMsg(bts []byte) (o []byte, err error)
Constants ¶
This section is empty.
Variables ¶
var ( AttributeAnyValue_AttributeAnyValueType_name = map[int32]string{ 0: "STRING_VALUE", 1: "BOOL_VALUE", 2: "INT_VALUE", 3: "DOUBLE_VALUE", 4: "ARRAY_VALUE", } AttributeAnyValue_AttributeAnyValueType_value = map[string]int32{ "STRING_VALUE": 0, "BOOL_VALUE": 1, "INT_VALUE": 2, "DOUBLE_VALUE": 3, "ARRAY_VALUE": 4, } )
Enum value maps for AttributeAnyValue_AttributeAnyValueType.
var ( AttributeArrayValue_AttributeArrayValueType_name = map[int32]string{ 0: "STRING_VALUE", 1: "BOOL_VALUE", 2: "INT_VALUE", 3: "DOUBLE_VALUE", } AttributeArrayValue_AttributeArrayValueType_value = map[string]int32{ "STRING_VALUE": 0, "BOOL_VALUE": 1, "INT_VALUE": 2, "DOUBLE_VALUE": 3, } )
Enum value maps for AttributeArrayValue_AttributeArrayValueType.
var ( Trilean_name = map[int32]string{ 0: "NOT_SET", 1: "TRUE", 2: "FALSE", } Trilean_value = map[string]int32{ "NOT_SET": 0, "TRUE": 1, "FALSE": 2, } )
Enum value maps for Trilean.
var ( TraceRootFlag_name = map[int32]string{ 0: "DEPRECATED_NOT_SET", 1: "DEPRECATED_TRUE", 2: "DEPRECATED_FALSE", } TraceRootFlag_value = map[string]int32{ "DEPRECATED_NOT_SET": 0, "DEPRECATED_TRUE": 1, "DEPRECATED_FALSE": 2, } )
Enum value maps for TraceRootFlag.
var File_datadog_trace_agent_payload_proto protoreflect.FileDescriptor
var File_datadog_trace_span_proto protoreflect.FileDescriptor
var File_datadog_trace_stats_proto protoreflect.FileDescriptor
var File_datadog_trace_tracer_payload_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AgentPayload ¶
type AgentPayload struct {
// hostName specifies hostname of where the agent is running.
HostName string `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"`
// env specifies `env` set in agent configuration.
Env string `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
// tracerPayloads specifies list of the payloads received from tracers.
TracerPayloads []*TracerPayload `protobuf:"bytes,5,rep,name=tracerPayloads,proto3" json:"tracerPayloads,omitempty"`
// tags specifies tags common in all `tracerPayloads`.
Tags map[string]string `` /* 135-byte string literal not displayed */
// agentVersion specifies version of the agent.
AgentVersion string `protobuf:"bytes,7,opt,name=agentVersion,proto3" json:"agentVersion,omitempty"`
// targetTPS holds `TargetTPS` value in AgentConfig.
TargetTPS float64 `protobuf:"fixed64,8,opt,name=targetTPS,proto3" json:"targetTPS,omitempty"`
// errorTPS holds `ErrorTPS` value in AgentConfig.
ErrorTPS float64 `protobuf:"fixed64,9,opt,name=errorTPS,proto3" json:"errorTPS,omitempty"`
// rareSamplerEnabled holds `RareSamplerEnabled` value in AgentConfig
RareSamplerEnabled bool `protobuf:"varint,10,opt,name=rareSamplerEnabled,proto3" json:"rareSamplerEnabled,omitempty"`
// idxTracerPayloads specifies list of the payloads received from tracers.
// @gotags: msg:"-"
IdxTracerPayloads []*idx.TracerPayload `protobuf:"bytes,11,rep,name=idxTracerPayloads,proto3" json:"idxTracerPayloads,omitempty" msg:"-"`
// contains filtered or unexported fields
}
AgentPayload represents payload the agent sends to the intake.
func (*AgentPayload) Descriptor
deprecated
func (*AgentPayload) Descriptor() ([]byte, []int)
Deprecated: Use AgentPayload.ProtoReflect.Descriptor instead.
func (*AgentPayload) GetAgentVersion ¶
func (x *AgentPayload) GetAgentVersion() string
func (*AgentPayload) GetEnv ¶
func (x *AgentPayload) GetEnv() string
func (*AgentPayload) GetErrorTPS ¶
func (x *AgentPayload) GetErrorTPS() float64
func (*AgentPayload) GetHostName ¶
func (x *AgentPayload) GetHostName() string
func (*AgentPayload) GetIdxTracerPayloads ¶ added in v0.66.0
func (x *AgentPayload) GetIdxTracerPayloads() []*idx.TracerPayload
func (*AgentPayload) GetRareSamplerEnabled ¶
func (x *AgentPayload) GetRareSamplerEnabled() bool
func (*AgentPayload) GetTags ¶
func (x *AgentPayload) GetTags() map[string]string
func (*AgentPayload) GetTargetTPS ¶
func (x *AgentPayload) GetTargetTPS() float64
func (*AgentPayload) GetTracerPayloads ¶
func (x *AgentPayload) GetTracerPayloads() []*TracerPayload
func (*AgentPayload) MarshalMsg ¶
func (z *AgentPayload) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*AgentPayload) MarshalToSizedBufferVT ¶
func (m *AgentPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AgentPayload) MarshalToVT ¶
func (m *AgentPayload) MarshalToVT(dAtA []byte) (int, error)
func (*AgentPayload) MarshalVT ¶
func (m *AgentPayload) MarshalVT() (dAtA []byte, err error)
func (*AgentPayload) Msgsize ¶
func (z *AgentPayload) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*AgentPayload) ProtoMessage ¶
func (*AgentPayload) ProtoMessage()
func (*AgentPayload) ProtoReflect ¶
func (x *AgentPayload) ProtoReflect() protoreflect.Message
func (*AgentPayload) Reset ¶
func (x *AgentPayload) Reset()
func (*AgentPayload) SizeVT ¶
func (m *AgentPayload) SizeVT() (n int)
func (*AgentPayload) String ¶
func (x *AgentPayload) String() string
func (*AgentPayload) UnmarshalMsg ¶
func (z *AgentPayload) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*AgentPayload) UnmarshalVT ¶
func (m *AgentPayload) UnmarshalVT(dAtA []byte) error
type AttributeAnyValue ¶ added in v0.63.0
type AttributeAnyValue struct {
// We implement a union manually here because Go's MessagePack generator does not support
// Protobuf `oneof` unions: https://github.com/tinylib/msgp/issues/184
// Despite this, the format represented here is binary compatible with `oneof`, if we choose
// to migrate to that in the future.
// @gotags: json:"type" msg:"type"
Type AttributeAnyValue_AttributeAnyValueType `protobuf:"varint,1,opt,name=type,proto3,enum=datadog.trace.AttributeAnyValue_AttributeAnyValueType" json:"type" msg:"type"`
// @gotags: json:"string_value" msg:"string_value"
StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3" json:"string_value" msg:"string_value"`
// @gotags: json:"bool_value" msg:"bool_value"
BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3" json:"bool_value" msg:"bool_value"`
// @gotags: json:"int_value" msg:"int_value"
IntValue int64 `protobuf:"varint,4,opt,name=int_value,json=intValue,proto3" json:"int_value" msg:"int_value"`
// @gotags: json:"double_value" msg:"double_value"
DoubleValue float64 `protobuf:"fixed64,5,opt,name=double_value,json=doubleValue,proto3" json:"double_value" msg:"double_value"`
// @gotags: json:"array_value" msg:"array_value"
ArrayValue *AttributeArray `protobuf:"bytes,6,opt,name=array_value,json=arrayValue,proto3" json:"array_value" msg:"array_value"`
// contains filtered or unexported fields
}
AttributeAnyValue is used to represent any type of attribute value. AttributeAnyValue may contain a primitive value such as a string or integer or it may contain an arbitrary nested object containing arrays, key-value lists and primitives.
func (*AttributeAnyValue) Descriptor
deprecated
added in
v0.63.0
func (*AttributeAnyValue) Descriptor() ([]byte, []int)
Deprecated: Use AttributeAnyValue.ProtoReflect.Descriptor instead.
func (*AttributeAnyValue) GetArrayValue ¶ added in v0.63.0
func (x *AttributeAnyValue) GetArrayValue() *AttributeArray
func (*AttributeAnyValue) GetBoolValue ¶ added in v0.63.0
func (x *AttributeAnyValue) GetBoolValue() bool
func (*AttributeAnyValue) GetDoubleValue ¶ added in v0.63.0
func (x *AttributeAnyValue) GetDoubleValue() float64
func (*AttributeAnyValue) GetIntValue ¶ added in v0.63.0
func (x *AttributeAnyValue) GetIntValue() int64
func (*AttributeAnyValue) GetStringValue ¶ added in v0.63.0
func (x *AttributeAnyValue) GetStringValue() string
func (*AttributeAnyValue) GetType ¶ added in v0.63.0
func (x *AttributeAnyValue) GetType() AttributeAnyValue_AttributeAnyValueType
func (*AttributeAnyValue) MarshalMsg ¶ added in v0.63.0
func (z *AttributeAnyValue) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*AttributeAnyValue) MarshalToSizedBufferVT ¶ added in v0.63.0
func (m *AttributeAnyValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AttributeAnyValue) MarshalToVT ¶ added in v0.63.0
func (m *AttributeAnyValue) MarshalToVT(dAtA []byte) (int, error)
func (*AttributeAnyValue) MarshalVT ¶ added in v0.63.0
func (m *AttributeAnyValue) MarshalVT() (dAtA []byte, err error)
func (*AttributeAnyValue) Msgsize ¶ added in v0.63.0
func (z *AttributeAnyValue) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*AttributeAnyValue) ProtoMessage ¶ added in v0.63.0
func (*AttributeAnyValue) ProtoMessage()
func (*AttributeAnyValue) ProtoReflect ¶ added in v0.63.0
func (x *AttributeAnyValue) ProtoReflect() protoreflect.Message
func (*AttributeAnyValue) Reset ¶ added in v0.63.0
func (x *AttributeAnyValue) Reset()
func (*AttributeAnyValue) SizeVT ¶ added in v0.63.0
func (m *AttributeAnyValue) SizeVT() (n int)
func (*AttributeAnyValue) String ¶ added in v0.63.0
func (x *AttributeAnyValue) String() string
func (*AttributeAnyValue) UnmarshalMsg ¶ added in v0.63.0
func (z *AttributeAnyValue) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*AttributeAnyValue) UnmarshalVT ¶ added in v0.63.0
func (m *AttributeAnyValue) UnmarshalVT(dAtA []byte) error
type AttributeAnyValue_AttributeAnyValueType ¶ added in v0.63.0
type AttributeAnyValue_AttributeAnyValueType int32
const ( AttributeAnyValue_STRING_VALUE AttributeAnyValue_AttributeAnyValueType = 0 AttributeAnyValue_BOOL_VALUE AttributeAnyValue_AttributeAnyValueType = 1 AttributeAnyValue_INT_VALUE AttributeAnyValue_AttributeAnyValueType = 2 AttributeAnyValue_DOUBLE_VALUE AttributeAnyValue_AttributeAnyValueType = 3 AttributeAnyValue_ARRAY_VALUE AttributeAnyValue_AttributeAnyValueType = 4 )
func (AttributeAnyValue_AttributeAnyValueType) Descriptor ¶ added in v0.63.0
func (AttributeAnyValue_AttributeAnyValueType) Descriptor() protoreflect.EnumDescriptor
func (AttributeAnyValue_AttributeAnyValueType) EnumDescriptor
deprecated
added in
v0.63.0
func (AttributeAnyValue_AttributeAnyValueType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AttributeAnyValue_AttributeAnyValueType.Descriptor instead.
func (AttributeAnyValue_AttributeAnyValueType) MarshalMsg ¶ added in v0.63.0
func (z AttributeAnyValue_AttributeAnyValueType) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (AttributeAnyValue_AttributeAnyValueType) Msgsize ¶ added in v0.63.0
func (z AttributeAnyValue_AttributeAnyValueType) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (AttributeAnyValue_AttributeAnyValueType) Number ¶ added in v0.63.0
func (x AttributeAnyValue_AttributeAnyValueType) Number() protoreflect.EnumNumber
func (AttributeAnyValue_AttributeAnyValueType) String ¶ added in v0.63.0
func (x AttributeAnyValue_AttributeAnyValueType) String() string
func (AttributeAnyValue_AttributeAnyValueType) Type ¶ added in v0.63.0
func (AttributeAnyValue_AttributeAnyValueType) Type() protoreflect.EnumType
func (*AttributeAnyValue_AttributeAnyValueType) UnmarshalMsg ¶ added in v0.63.0
func (z *AttributeAnyValue_AttributeAnyValueType) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type AttributeArray ¶ added in v0.63.0
type AttributeArray struct {
// Array of values. The array may be empty (contain 0 elements).
// @gotags: json:"values" msg:"values"
Values []*AttributeArrayValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values" msg:"values"`
// contains filtered or unexported fields
}
AttributeArray is a list of AttributeArrayValue messages. We need this as a message since `oneof` in AttributeAnyValue does not allow repeated fields.
func (*AttributeArray) Descriptor
deprecated
added in
v0.63.0
func (*AttributeArray) Descriptor() ([]byte, []int)
Deprecated: Use AttributeArray.ProtoReflect.Descriptor instead.
func (*AttributeArray) GetValues ¶ added in v0.63.0
func (x *AttributeArray) GetValues() []*AttributeArrayValue
func (*AttributeArray) MarshalMsg ¶ added in v0.63.0
func (z *AttributeArray) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*AttributeArray) MarshalToSizedBufferVT ¶ added in v0.63.0
func (m *AttributeArray) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AttributeArray) MarshalToVT ¶ added in v0.63.0
func (m *AttributeArray) MarshalToVT(dAtA []byte) (int, error)
func (*AttributeArray) MarshalVT ¶ added in v0.63.0
func (m *AttributeArray) MarshalVT() (dAtA []byte, err error)
func (*AttributeArray) Msgsize ¶ added in v0.63.0
func (z *AttributeArray) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*AttributeArray) ProtoMessage ¶ added in v0.63.0
func (*AttributeArray) ProtoMessage()
func (*AttributeArray) ProtoReflect ¶ added in v0.63.0
func (x *AttributeArray) ProtoReflect() protoreflect.Message
func (*AttributeArray) Reset ¶ added in v0.63.0
func (x *AttributeArray) Reset()
func (*AttributeArray) SizeVT ¶ added in v0.63.0
func (m *AttributeArray) SizeVT() (n int)
func (*AttributeArray) String ¶ added in v0.63.0
func (x *AttributeArray) String() string
func (*AttributeArray) UnmarshalMsg ¶ added in v0.63.0
func (z *AttributeArray) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*AttributeArray) UnmarshalVT ¶ added in v0.63.0
func (m *AttributeArray) UnmarshalVT(dAtA []byte) error
type AttributeArrayValue ¶ added in v0.63.0
type AttributeArrayValue struct {
// We implement a union manually here because Go's MessagePack generator does not support
// Protobuf `oneof` unions: https://github.com/tinylib/msgp/issues/184
// Despite this, the format represented here is binary compatible with `oneof`, if we choose
// to migrate to that in the future.
// @gotags: json:"type" msg:"type"
Type AttributeArrayValue_AttributeArrayValueType `` /* 126-byte string literal not displayed */
// @gotags: json:"string_value" msg:"string_value"
StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3" json:"string_value" msg:"string_value"`
// @gotags: json:"bool_value" msg:"bool_value"
BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3" json:"bool_value" msg:"bool_value"`
// @gotags: json:"int_value" msg:"int_value"
IntValue int64 `protobuf:"varint,4,opt,name=int_value,json=intValue,proto3" json:"int_value" msg:"int_value"`
// @gotags: json:"double_value" msg:"double_value"
DoubleValue float64 `protobuf:"fixed64,5,opt,name=double_value,json=doubleValue,proto3" json:"double_value" msg:"double_value"`
// contains filtered or unexported fields
}
An element in the homogeneous AttributeArray. Compared to AttributeAnyValue, it only supports scalar values.
func (*AttributeArrayValue) Descriptor
deprecated
added in
v0.63.0
func (*AttributeArrayValue) Descriptor() ([]byte, []int)
Deprecated: Use AttributeArrayValue.ProtoReflect.Descriptor instead.
func (*AttributeArrayValue) GetBoolValue ¶ added in v0.63.0
func (x *AttributeArrayValue) GetBoolValue() bool
func (*AttributeArrayValue) GetDoubleValue ¶ added in v0.63.0
func (x *AttributeArrayValue) GetDoubleValue() float64
func (*AttributeArrayValue) GetIntValue ¶ added in v0.63.0
func (x *AttributeArrayValue) GetIntValue() int64
func (*AttributeArrayValue) GetStringValue ¶ added in v0.63.0
func (x *AttributeArrayValue) GetStringValue() string
func (*AttributeArrayValue) GetType ¶ added in v0.63.0
func (x *AttributeArrayValue) GetType() AttributeArrayValue_AttributeArrayValueType
func (*AttributeArrayValue) MarshalMsg ¶ added in v0.63.0
func (z *AttributeArrayValue) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*AttributeArrayValue) MarshalToSizedBufferVT ¶ added in v0.63.0
func (m *AttributeArrayValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AttributeArrayValue) MarshalToVT ¶ added in v0.63.0
func (m *AttributeArrayValue) MarshalToVT(dAtA []byte) (int, error)
func (*AttributeArrayValue) MarshalVT ¶ added in v0.63.0
func (m *AttributeArrayValue) MarshalVT() (dAtA []byte, err error)
func (*AttributeArrayValue) Msgsize ¶ added in v0.63.0
func (z *AttributeArrayValue) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*AttributeArrayValue) ProtoMessage ¶ added in v0.63.0
func (*AttributeArrayValue) ProtoMessage()
func (*AttributeArrayValue) ProtoReflect ¶ added in v0.63.0
func (x *AttributeArrayValue) ProtoReflect() protoreflect.Message
func (*AttributeArrayValue) Reset ¶ added in v0.63.0
func (x *AttributeArrayValue) Reset()
func (*AttributeArrayValue) SizeVT ¶ added in v0.63.0
func (m *AttributeArrayValue) SizeVT() (n int)
func (*AttributeArrayValue) String ¶ added in v0.63.0
func (x *AttributeArrayValue) String() string
func (*AttributeArrayValue) UnmarshalMsg ¶ added in v0.63.0
func (z *AttributeArrayValue) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*AttributeArrayValue) UnmarshalVT ¶ added in v0.63.0
func (m *AttributeArrayValue) UnmarshalVT(dAtA []byte) error
type AttributeArrayValue_AttributeArrayValueType ¶ added in v0.63.0
type AttributeArrayValue_AttributeArrayValueType int32
const ( AttributeArrayValue_STRING_VALUE AttributeArrayValue_AttributeArrayValueType = 0 AttributeArrayValue_BOOL_VALUE AttributeArrayValue_AttributeArrayValueType = 1 AttributeArrayValue_INT_VALUE AttributeArrayValue_AttributeArrayValueType = 2 AttributeArrayValue_DOUBLE_VALUE AttributeArrayValue_AttributeArrayValueType = 3 )
func (AttributeArrayValue_AttributeArrayValueType) Descriptor ¶ added in v0.63.0
func (AttributeArrayValue_AttributeArrayValueType) Descriptor() protoreflect.EnumDescriptor
func (AttributeArrayValue_AttributeArrayValueType) EnumDescriptor
deprecated
added in
v0.63.0
func (AttributeArrayValue_AttributeArrayValueType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AttributeArrayValue_AttributeArrayValueType.Descriptor instead.
func (AttributeArrayValue_AttributeArrayValueType) MarshalMsg ¶ added in v0.63.0
func (z AttributeArrayValue_AttributeArrayValueType) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (AttributeArrayValue_AttributeArrayValueType) Msgsize ¶ added in v0.63.0
func (z AttributeArrayValue_AttributeArrayValueType) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (AttributeArrayValue_AttributeArrayValueType) Number ¶ added in v0.63.0
func (x AttributeArrayValue_AttributeArrayValueType) Number() protoreflect.EnumNumber
func (AttributeArrayValue_AttributeArrayValueType) String ¶ added in v0.63.0
func (x AttributeArrayValue_AttributeArrayValueType) String() string
func (AttributeArrayValue_AttributeArrayValueType) Type ¶ added in v0.63.0
func (AttributeArrayValue_AttributeArrayValueType) Type() protoreflect.EnumType
func (*AttributeArrayValue_AttributeArrayValueType) UnmarshalMsg ¶ added in v0.63.0
func (z *AttributeArrayValue_AttributeArrayValueType) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ClientGroupedStats ¶
type ClientGroupedStats struct {
Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
HTTPStatusCode uint32 `protobuf:"varint,4,opt,name=HTTP_status_code,json=HTTPStatusCode,proto3" json:"HTTP_status_code,omitempty"`
Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
DBType string `protobuf:"bytes,6,opt,name=DB_type,json=DBType,proto3" json:"DB_type,omitempty"` // db_type might be used in the future to help in the obfuscation step
Hits uint64 `protobuf:"varint,7,opt,name=hits,proto3" json:"hits,omitempty"` // count of all spans aggregated in the groupedstats
Errors uint64 `protobuf:"varint,8,opt,name=errors,proto3" json:"errors,omitempty"` // count of error spans aggregated in the groupedstats
Duration uint64 `protobuf:"varint,9,opt,name=duration,proto3" json:"duration,omitempty"` // total duration in nanoseconds of spans aggregated in the bucket
OkSummary []byte `protobuf:"bytes,10,opt,name=okSummary,proto3" json:"okSummary,omitempty"` // ddsketch summary of ok spans latencies encoded in protobuf
ErrorSummary []byte `protobuf:"bytes,11,opt,name=errorSummary,proto3" json:"errorSummary,omitempty"` // ddsketch summary of error spans latencies encoded in protobuf
Synthetics bool `protobuf:"varint,12,opt,name=synthetics,proto3" json:"synthetics,omitempty"` // set to true on spans generated by synthetics traffic
TopLevelHits uint64 `protobuf:"varint,13,opt,name=topLevelHits,proto3" json:"topLevelHits,omitempty"` // count of top level spans aggregated in the groupedstats
SpanKind string `protobuf:"bytes,15,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"` // value of the span.kind tag on the span
// peer_tags are supplementary tags that further describe a peer entity
// E.g., `grpc.target` to describe the name of a gRPC peer, or `db.hostname` to describe the name of peer DB
PeerTags []string `protobuf:"bytes,16,rep,name=peer_tags,json=peerTags,proto3" json:"peer_tags,omitempty"`
IsTraceRoot Trilean `protobuf:"varint,17,opt,name=is_trace_root,json=isTraceRoot,proto3,enum=datadog.trace.Trilean" json:"is_trace_root,omitempty"` // this field's value is equal to span's ParentID == 0.
GRPCStatusCode string `protobuf:"bytes,18,opt,name=GRPC_status_code,json=GRPCStatusCode,proto3" json:"GRPC_status_code,omitempty"`
HTTPMethod string `protobuf:"bytes,19,opt,name=HTTP_method,json=HTTPMethod,proto3" json:"HTTP_method,omitempty"` // HTTP method of the request
HTTPEndpoint string `protobuf:"bytes,20,opt,name=HTTP_endpoint,json=HTTPEndpoint,proto3" json:"HTTP_endpoint,omitempty"` // Http route or quantized/simplified URL path
// contains filtered or unexported fields
}
ClientGroupedStats aggregate stats on spans grouped by service, name, resource, status_code, type
func (*ClientGroupedStats) DecodeMsg ¶
func (z *ClientGroupedStats) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*ClientGroupedStats) Descriptor
deprecated
func (*ClientGroupedStats) Descriptor() ([]byte, []int)
Deprecated: Use ClientGroupedStats.ProtoReflect.Descriptor instead.
func (*ClientGroupedStats) EncodeMsg ¶
func (z *ClientGroupedStats) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*ClientGroupedStats) GetDBType ¶
func (x *ClientGroupedStats) GetDBType() string
func (*ClientGroupedStats) GetDuration ¶
func (x *ClientGroupedStats) GetDuration() uint64
func (*ClientGroupedStats) GetErrorSummary ¶
func (x *ClientGroupedStats) GetErrorSummary() []byte
func (*ClientGroupedStats) GetErrors ¶
func (x *ClientGroupedStats) GetErrors() uint64
func (*ClientGroupedStats) GetGRPCStatusCode ¶ added in v0.65.0
func (x *ClientGroupedStats) GetGRPCStatusCode() string
func (*ClientGroupedStats) GetHTTPEndpoint ¶ added in v0.71.0
func (x *ClientGroupedStats) GetHTTPEndpoint() string
func (*ClientGroupedStats) GetHTTPMethod ¶ added in v0.71.0
func (x *ClientGroupedStats) GetHTTPMethod() string
func (*ClientGroupedStats) GetHTTPStatusCode ¶
func (x *ClientGroupedStats) GetHTTPStatusCode() uint32
func (*ClientGroupedStats) GetHits ¶
func (x *ClientGroupedStats) GetHits() uint64
func (*ClientGroupedStats) GetIsTraceRoot ¶ added in v0.53.0
func (x *ClientGroupedStats) GetIsTraceRoot() Trilean
func (*ClientGroupedStats) GetName ¶
func (x *ClientGroupedStats) GetName() string
func (*ClientGroupedStats) GetOkSummary ¶
func (x *ClientGroupedStats) GetOkSummary() []byte
func (*ClientGroupedStats) GetPeerTags ¶ added in v0.49.0
func (x *ClientGroupedStats) GetPeerTags() []string
func (*ClientGroupedStats) GetResource ¶
func (x *ClientGroupedStats) GetResource() string
func (*ClientGroupedStats) GetService ¶
func (x *ClientGroupedStats) GetService() string
func (*ClientGroupedStats) GetSpanKind ¶
func (x *ClientGroupedStats) GetSpanKind() string
func (*ClientGroupedStats) GetSynthetics ¶
func (x *ClientGroupedStats) GetSynthetics() bool
func (*ClientGroupedStats) GetTopLevelHits ¶
func (x *ClientGroupedStats) GetTopLevelHits() uint64
func (*ClientGroupedStats) GetType ¶
func (x *ClientGroupedStats) GetType() string
func (*ClientGroupedStats) MarshalMsg ¶
func (z *ClientGroupedStats) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientGroupedStats) MarshalToSizedBufferVT ¶
func (m *ClientGroupedStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ClientGroupedStats) MarshalToVT ¶
func (m *ClientGroupedStats) MarshalToVT(dAtA []byte) (int, error)
func (*ClientGroupedStats) MarshalVT ¶
func (m *ClientGroupedStats) MarshalVT() (dAtA []byte, err error)
func (*ClientGroupedStats) Msgsize ¶
func (z *ClientGroupedStats) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ClientGroupedStats) ProtoMessage ¶
func (*ClientGroupedStats) ProtoMessage()
func (*ClientGroupedStats) ProtoReflect ¶
func (x *ClientGroupedStats) ProtoReflect() protoreflect.Message
func (*ClientGroupedStats) Reset ¶
func (x *ClientGroupedStats) Reset()
func (*ClientGroupedStats) SizeVT ¶
func (m *ClientGroupedStats) SizeVT() (n int)
func (*ClientGroupedStats) String ¶
func (x *ClientGroupedStats) String() string
func (*ClientGroupedStats) UnmarshalMsg ¶
func (z *ClientGroupedStats) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*ClientGroupedStats) UnmarshalVT ¶
func (m *ClientGroupedStats) UnmarshalVT(dAtA []byte) error
type ClientStatsBucket ¶
type ClientStatsBucket struct {
Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` // bucket start in nanoseconds
Duration uint64 `protobuf:"varint,2,opt,name=duration,proto3" json:"duration,omitempty"` // bucket duration in nanoseconds
// @gotags: json:"stats,omitempty" msg:"Stats,omitempty"
Stats []*ClientGroupedStats `protobuf:"bytes,3,rep,name=stats,proto3" json:"stats,omitempty" msg:"Stats,omitempty"`
// AgentTimeShift is the shift applied by the agent stats aggregator on bucket start
// when the received bucket start is outside of the agent aggregation window
AgentTimeShift int64 `protobuf:"varint,4,opt,name=agentTimeShift,proto3" json:"agentTimeShift,omitempty"`
// contains filtered or unexported fields
}
ClientStatsBucket is a time bucket containing aggregated stats.
func (*ClientStatsBucket) DecodeMsg ¶
func (z *ClientStatsBucket) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*ClientStatsBucket) Descriptor
deprecated
func (*ClientStatsBucket) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatsBucket.ProtoReflect.Descriptor instead.
func (*ClientStatsBucket) EncodeMsg ¶
func (z *ClientStatsBucket) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*ClientStatsBucket) GetAgentTimeShift ¶
func (x *ClientStatsBucket) GetAgentTimeShift() int64
func (*ClientStatsBucket) GetDuration ¶
func (x *ClientStatsBucket) GetDuration() uint64
func (*ClientStatsBucket) GetStart ¶
func (x *ClientStatsBucket) GetStart() uint64
func (*ClientStatsBucket) GetStats ¶
func (x *ClientStatsBucket) GetStats() []*ClientGroupedStats
func (*ClientStatsBucket) MarshalMsg ¶
func (z *ClientStatsBucket) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientStatsBucket) MarshalToSizedBufferVT ¶
func (m *ClientStatsBucket) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ClientStatsBucket) MarshalToVT ¶
func (m *ClientStatsBucket) MarshalToVT(dAtA []byte) (int, error)
func (*ClientStatsBucket) MarshalVT ¶
func (m *ClientStatsBucket) MarshalVT() (dAtA []byte, err error)
func (*ClientStatsBucket) Msgsize ¶
func (z *ClientStatsBucket) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ClientStatsBucket) ProtoMessage ¶
func (*ClientStatsBucket) ProtoMessage()
func (*ClientStatsBucket) ProtoReflect ¶
func (x *ClientStatsBucket) ProtoReflect() protoreflect.Message
func (*ClientStatsBucket) Reset ¶
func (x *ClientStatsBucket) Reset()
func (*ClientStatsBucket) SizeVT ¶
func (m *ClientStatsBucket) SizeVT() (n int)
func (*ClientStatsBucket) String ¶
func (x *ClientStatsBucket) String() string
func (*ClientStatsBucket) UnmarshalMsg ¶
func (z *ClientStatsBucket) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*ClientStatsBucket) UnmarshalVT ¶
func (m *ClientStatsBucket) UnmarshalVT(dAtA []byte) error
type ClientStatsPayload ¶
type ClientStatsPayload struct {
// Hostname is the tracer hostname. It's extracted from spans with "_dd.hostname" meta
// or set by tracer stats payload when hostname reporting is enabled.
Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
Env string `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"` // env tag set on spans or in the tracers, used for aggregation
Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` // version tag set on spans or in the tracers, used for aggregation
// @gotags: json:"stats,omitempty" msg:"Stats,omitempty"
Stats []*ClientStatsBucket `protobuf:"bytes,4,rep,name=stats,proto3" json:"stats,omitempty" msg:"Stats,omitempty"`
Lang string `protobuf:"bytes,5,opt,name=lang,proto3" json:"lang,omitempty"` // informative field not used for aggregation
TracerVersion string `protobuf:"bytes,6,opt,name=tracerVersion,proto3" json:"tracerVersion,omitempty"` // informative field not used for aggregation
RuntimeID string `protobuf:"bytes,7,opt,name=runtimeID,proto3" json:"runtimeID,omitempty"` // used on stats payloads sent by the tracer to identify uniquely a message
Sequence uint64 `protobuf:"varint,8,opt,name=sequence,proto3" json:"sequence,omitempty"` // used on stats payloads sent by the tracer to identify uniquely a message
// AgentAggregation is set by the agent on tracer payloads modified by the agent aggregation layer
// characterizes counts only and distributions only payloads
AgentAggregation string `protobuf:"bytes,9,opt,name=agentAggregation,proto3" json:"agentAggregation,omitempty"`
// Service is the main service of the tracer.
// It is part of unified tagging: https://docs.datadoghq.com/getting_started/tagging/unified_service_tagging
Service string `protobuf:"bytes,10,opt,name=service,proto3" json:"service,omitempty"`
// ContainerID specifies the origin container ID. It is meant to be populated by the client and may
// be enhanced by the agent to ensure it is unique.
ContainerID string `protobuf:"bytes,11,opt,name=containerID,proto3" json:"containerID,omitempty"`
// Tags specifies a set of tags obtained from the orchestrator (where applicable) using the specified containerID.
// This field should be left empty by the client. It only applies to some specific environment.
Tags []string `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"`
// The git commit SHA is obtained from a trace, where it may be set through a tracer <-> source code integration.
GitCommitSha string `protobuf:"bytes,13,opt,name=git_commit_sha,json=gitCommitSha,proto3" json:"git_commit_sha,omitempty"`
// The image tag is obtained from a container's set of tags.
ImageTag string `protobuf:"bytes,14,opt,name=image_tag,json=imageTag,proto3" json:"image_tag,omitempty"`
// The process tags hash is used as a key for agent stats agregation.
ProcessTagsHash uint64 `protobuf:"varint,15,opt,name=process_tags_hash,json=processTagsHash,proto3" json:"process_tags_hash,omitempty"`
// The process tags contains a list of tags that are specific to the process.
ProcessTags string `protobuf:"bytes,16,opt,name=process_tags,json=processTags,proto3" json:"process_tags,omitempty"`
// contains filtered or unexported fields
}
ClientStatsPayload is the first layer of span stats aggregation. It is also the payload sent by tracers to the agent when stats in tracer are enabled.
func (*ClientStatsPayload) DecodeMsg ¶
func (z *ClientStatsPayload) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*ClientStatsPayload) Descriptor
deprecated
func (*ClientStatsPayload) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatsPayload.ProtoReflect.Descriptor instead.
func (*ClientStatsPayload) EncodeMsg ¶
func (z *ClientStatsPayload) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*ClientStatsPayload) GetAgentAggregation ¶
func (x *ClientStatsPayload) GetAgentAggregation() string
func (*ClientStatsPayload) GetContainerID ¶
func (x *ClientStatsPayload) GetContainerID() string
func (*ClientStatsPayload) GetEnv ¶
func (x *ClientStatsPayload) GetEnv() string
func (*ClientStatsPayload) GetGitCommitSha ¶ added in v0.52.0
func (x *ClientStatsPayload) GetGitCommitSha() string
func (*ClientStatsPayload) GetHostname ¶
func (x *ClientStatsPayload) GetHostname() string
func (*ClientStatsPayload) GetImageTag ¶ added in v0.52.0
func (x *ClientStatsPayload) GetImageTag() string
func (*ClientStatsPayload) GetLang ¶
func (x *ClientStatsPayload) GetLang() string
func (*ClientStatsPayload) GetProcessTags ¶ added in v0.66.0
func (x *ClientStatsPayload) GetProcessTags() string
func (*ClientStatsPayload) GetProcessTagsHash ¶ added in v0.66.0
func (x *ClientStatsPayload) GetProcessTagsHash() uint64
func (*ClientStatsPayload) GetRuntimeID ¶
func (x *ClientStatsPayload) GetRuntimeID() string
func (*ClientStatsPayload) GetSequence ¶
func (x *ClientStatsPayload) GetSequence() uint64
func (*ClientStatsPayload) GetService ¶
func (x *ClientStatsPayload) GetService() string
func (*ClientStatsPayload) GetStats ¶
func (x *ClientStatsPayload) GetStats() []*ClientStatsBucket
func (*ClientStatsPayload) GetTags ¶
func (x *ClientStatsPayload) GetTags() []string
func (*ClientStatsPayload) GetTracerVersion ¶
func (x *ClientStatsPayload) GetTracerVersion() string
func (*ClientStatsPayload) GetVersion ¶
func (x *ClientStatsPayload) GetVersion() string
func (*ClientStatsPayload) MarshalMsg ¶
func (z *ClientStatsPayload) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ClientStatsPayload) MarshalToSizedBufferVT ¶
func (m *ClientStatsPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ClientStatsPayload) MarshalToVT ¶
func (m *ClientStatsPayload) MarshalToVT(dAtA []byte) (int, error)
func (*ClientStatsPayload) MarshalVT ¶
func (m *ClientStatsPayload) MarshalVT() (dAtA []byte, err error)
func (*ClientStatsPayload) Msgsize ¶
func (z *ClientStatsPayload) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ClientStatsPayload) ProtoMessage ¶
func (*ClientStatsPayload) ProtoMessage()
func (*ClientStatsPayload) ProtoReflect ¶
func (x *ClientStatsPayload) ProtoReflect() protoreflect.Message
func (*ClientStatsPayload) Reset ¶
func (x *ClientStatsPayload) Reset()
func (*ClientStatsPayload) SizeVT ¶
func (m *ClientStatsPayload) SizeVT() (n int)
func (*ClientStatsPayload) String ¶
func (x *ClientStatsPayload) String() string
func (*ClientStatsPayload) UnmarshalMsg ¶
func (z *ClientStatsPayload) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*ClientStatsPayload) UnmarshalVT ¶
func (m *ClientStatsPayload) UnmarshalVT(dAtA []byte) error
type Span ¶
type Span struct {
// service is the name of the service with which this span is associated.
// @gotags: json:"service" msg:"service"
Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service" msg:"service"`
// name is the operation name of this span.
// @gotags: json:"name" msg:"name"
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" msg:"name"`
// resource is the resource name of this span, also sometimes called the endpoint (for web spans).
// @gotags: json:"resource" msg:"resource"
Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource" msg:"resource"`
// traceID is the ID of the trace to which this span belongs.
// @gotags: json:"trace_id" msg:"trace_id"
TraceID uint64 `protobuf:"varint,4,opt,name=traceID,proto3" json:"trace_id" msg:"trace_id"`
// spanID is the ID of this span.
// @gotags: json:"span_id" msg:"span_id"
SpanID uint64 `protobuf:"varint,5,opt,name=spanID,proto3" json:"span_id" msg:"span_id"`
// parentID is the ID of this span's parent, or zero if this span has no parent.
// @gotags: json:"parent_id" msg:"parent_id"
ParentID uint64 `protobuf:"varint,6,opt,name=parentID,proto3" json:"parent_id" msg:"parent_id"`
// start is the number of nanoseconds between the Unix epoch and the beginning of this span.
// @gotags: json:"start" msg:"start"
Start int64 `protobuf:"varint,7,opt,name=start,proto3" json:"start" msg:"start"`
// duration is the time length of this span in nanoseconds.
// @gotags: json:"duration" msg:"duration"
Duration int64 `protobuf:"varint,8,opt,name=duration,proto3" json:"duration" msg:"duration"`
// error is 1 if there is an error associated with this span, or 0 if there is not.
// @gotags: json:"error" msg:"error"
Error int32 `protobuf:"varint,9,opt,name=error,proto3" json:"error" msg:"error"`
// meta is a mapping from tag name to tag value for string-valued tags.
// @gotags: json:"meta,omitempty" msg:"meta,omitempty"
Meta map[string]string `` /* 157-byte string literal not displayed */
// metrics is a mapping from tag name to tag value for numeric-valued tags.
// @gotags: json:"metrics,omitempty" msg:"metrics,omitempty"
Metrics map[string]float64 `` /* 168-byte string literal not displayed */
// type is the type of the service with which this span is associated. Example values: web, db, lambda.
// @gotags: json:"type" msg:"type"
Type string `protobuf:"bytes,12,opt,name=type,proto3" json:"type" msg:"type"`
// meta_struct is a registry of structured "other" data used by, e.g., AppSec.
// @gotags: json:"meta_struct,omitempty" msg:"meta_struct,omitempty"
MetaStruct map[string][]byte `` /* 194-byte string literal not displayed */
// span_links represents a collection of links, where each link defines a causal relationship between two spans.
// @gotags: json:"span_links,omitempty" msg:"span_links,omitempty"
SpanLinks []*SpanLink `protobuf:"bytes,14,rep,name=spanLinks,proto3" json:"span_links,omitempty" msg:"span_links,omitempty"`
// spanEvents represent an event at an instant in time related to this span, but not necessarily during the span.
// @gotags: json:"span_events,omitempty" msg:"span_events,omitempty"
SpanEvents []*SpanEvent `protobuf:"bytes,15,rep,name=spanEvents,proto3" json:"span_events,omitempty" msg:"span_events,omitempty"`
// contains filtered or unexported fields
}
func (*Span) Descriptor
deprecated
func (*Span) Get128BitTraceID ¶ added in v0.73.0
Get128BitTraceID returns the 128-bit trace ID for the span.
func (*Span) GetDuration ¶
func (*Span) GetMetaStruct ¶
func (*Span) GetMetrics ¶
func (*Span) GetParentID ¶
func (*Span) GetResource ¶
func (*Span) GetService ¶
func (*Span) GetSpanEvents ¶ added in v0.63.0
func (*Span) GetSpanLinks ¶ added in v0.52.0
func (*Span) GetTraceID ¶
func (*Span) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
func (*Span) MarshalToSizedBufferVT ¶
func (*Span) Msgsize ¶
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*Span) ProtoMessage ¶
func (*Span) ProtoMessage()
func (*Span) ProtoReflect ¶
func (x *Span) ProtoReflect() protoreflect.Message
func (*Span) ShallowCopy ¶
ShallowCopy returns a shallow copy of the copy-able portion of a Span. These are the public fields which will have a Get* method for them. The completeness of this method is enforced by the init function above. Instead of using pkg/proto/utils.ProtoCopier, which incurs heavy reflection cost for every copy at runtime, we use reflection once at startup to ensure our method is complete.
func (*Span) UnmarshalMsg ¶
UnmarshalMsg implements msgp.Unmarshaler
func (*Span) UnmarshalMsgDictionary ¶
UnmarshalMsgDictionary decodes a span from the given decoder dc, looking up strings in the given dictionary dict. For details, see the documentation for endpoint v0.5 in pkg/trace/api/version.go
func (*Span) UnmarshalVT ¶
type SpanEvent ¶ added in v0.63.0
type SpanEvent struct {
// @gotags: json:"time_unix_nano" msg:"time_unix_nano"
TimeUnixNano uint64 `protobuf:"fixed64,1,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano" msg:"time_unix_nano"` // time is the number of nanoseconds between the Unix epoch and this event.
// @gotags: json:"name" msg:"name"
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" msg:"name"` // name is this event's name.
// attributes is a mapping from attribute key string to any value.
// The order of attributes should be preserved in the key/value map.
// The supported values match the OpenTelemetry attributes specification:
// https://github.com/open-telemetry/opentelemetry-proto/blob/a8f08fc49d60538f97ffabcc7feac92f832976dd/opentelemetry/proto/common/v1/common.proto
// @gotags: json:"attributes" msg:"attributes"
Attributes map[string]*AttributeAnyValue `` /* 154-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*SpanEvent) Descriptor
deprecated
added in
v0.63.0
func (*SpanEvent) GetAttributes ¶ added in v0.63.0
func (x *SpanEvent) GetAttributes() map[string]*AttributeAnyValue
func (*SpanEvent) GetTimeUnixNano ¶ added in v0.63.0
func (*SpanEvent) MarshalMsg ¶ added in v0.63.0
MarshalMsg implements msgp.Marshaler
func (*SpanEvent) MarshalToSizedBufferVT ¶ added in v0.63.0
func (*SpanEvent) MarshalToVT ¶ added in v0.63.0
func (*SpanEvent) Msgsize ¶ added in v0.63.0
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*SpanEvent) ProtoMessage ¶ added in v0.63.0
func (*SpanEvent) ProtoMessage()
func (*SpanEvent) ProtoReflect ¶ added in v0.63.0
func (x *SpanEvent) ProtoReflect() protoreflect.Message
func (*SpanEvent) UnmarshalMsg ¶ added in v0.63.0
UnmarshalMsg implements msgp.Unmarshaler
func (*SpanEvent) UnmarshalVT ¶ added in v0.63.0
type SpanLink ¶ added in v0.52.0
type SpanLink struct {
// @gotags: json:"trace_id" msg:"trace_id"
TraceID uint64 `protobuf:"varint,1,opt,name=traceID,proto3" json:"trace_id" msg:"trace_id"` // Required.
// @gotags: json:"trace_id_high" msg:"trace_id_high,omitempty"
TraceIDHigh uint64 `protobuf:"varint,2,opt,name=traceID_high,json=traceIDHigh,proto3" json:"trace_id_high" msg:"trace_id_high,omitempty"` // Optional. The high 64 bits of a referenced trace id.
// @gotags: json:"span_id" msg:"span_id"
SpanID uint64 `protobuf:"varint,3,opt,name=spanID,proto3" json:"span_id" msg:"span_id"` // Required.
// @gotags: msg:"attributes,omitempty"
Attributes map[string]string `` // Optional. Simple mapping of keys to string values.
/* 174-byte string literal not displayed */
// @gotags: msg:"tracestate,omitempty"
Tracestate string `protobuf:"bytes,5,opt,name=tracestate,proto3" json:"tracestate,omitempty" msg:"tracestate,omitempty"` // Optional. W3C tracestate.
// @gotags: msg:"flags,omitempty"
Flags uint32 `protobuf:"varint,6,opt,name=flags,proto3" json:"flags,omitempty" msg:"flags,omitempty"` // Optional. W3C trace flags. If set, the high bit (bit 31) must be set.
// contains filtered or unexported fields
}
func (*SpanLink) Descriptor
deprecated
added in
v0.52.0
func (*SpanLink) GetAttributes ¶ added in v0.52.0
func (*SpanLink) GetTraceID ¶ added in v0.52.0
func (*SpanLink) GetTraceIDHigh ¶ added in v0.52.0
func (*SpanLink) GetTracestate ¶ added in v0.52.0
func (*SpanLink) MarshalMsg ¶ added in v0.52.0
MarshalMsg implements msgp.Marshaler
func (*SpanLink) MarshalToSizedBufferVT ¶ added in v0.52.0
func (*SpanLink) MarshalToVT ¶ added in v0.52.0
func (*SpanLink) Msgsize ¶ added in v0.52.0
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*SpanLink) ProtoMessage ¶ added in v0.52.0
func (*SpanLink) ProtoMessage()
func (*SpanLink) ProtoReflect ¶ added in v0.52.0
func (x *SpanLink) ProtoReflect() protoreflect.Message
func (*SpanLink) UnmarshalMsg ¶ added in v0.52.0
UnmarshalMsg implements msgp.Unmarshaler
func (*SpanLink) UnmarshalVT ¶ added in v0.52.0
type StatsPayload ¶
type StatsPayload struct {
AgentHostname string `protobuf:"bytes,1,opt,name=agentHostname,proto3" json:"agentHostname,omitempty"`
AgentEnv string `protobuf:"bytes,2,opt,name=agentEnv,proto3" json:"agentEnv,omitempty"`
// @gotags: json:"stats,omitempty" msg:"Stats,omitempty"
Stats []*ClientStatsPayload `protobuf:"bytes,3,rep,name=stats,proto3" json:"stats,omitempty" msg:"Stats,omitempty"`
AgentVersion string `protobuf:"bytes,4,opt,name=agentVersion,proto3" json:"agentVersion,omitempty"`
ClientComputed bool `protobuf:"varint,5,opt,name=clientComputed,proto3" json:"clientComputed,omitempty"`
// splitPayload indicates if the payload is actually one of several payloads split out from a larger payload.
// This field can be used in the backend to signal if re-aggregation is necessary.
SplitPayload bool `protobuf:"varint,6,opt,name=splitPayload,proto3" json:"splitPayload,omitempty"`
// contains filtered or unexported fields
}
StatsPayload is the payload used to send stats from the agent to the backend.
func (*StatsPayload) DecodeMsg ¶
func (z *StatsPayload) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*StatsPayload) Descriptor
deprecated
func (*StatsPayload) Descriptor() ([]byte, []int)
Deprecated: Use StatsPayload.ProtoReflect.Descriptor instead.
func (*StatsPayload) EncodeMsg ¶
func (z *StatsPayload) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*StatsPayload) GetAgentEnv ¶
func (x *StatsPayload) GetAgentEnv() string
func (*StatsPayload) GetAgentHostname ¶
func (x *StatsPayload) GetAgentHostname() string
func (*StatsPayload) GetAgentVersion ¶
func (x *StatsPayload) GetAgentVersion() string
func (*StatsPayload) GetClientComputed ¶
func (x *StatsPayload) GetClientComputed() bool
func (*StatsPayload) GetSplitPayload ¶ added in v0.50.0
func (x *StatsPayload) GetSplitPayload() bool
func (*StatsPayload) GetStats ¶
func (x *StatsPayload) GetStats() []*ClientStatsPayload
func (*StatsPayload) MarshalMsg ¶
func (z *StatsPayload) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*StatsPayload) MarshalToSizedBufferVT ¶
func (m *StatsPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StatsPayload) MarshalToVT ¶
func (m *StatsPayload) MarshalToVT(dAtA []byte) (int, error)
func (*StatsPayload) MarshalVT ¶
func (m *StatsPayload) MarshalVT() (dAtA []byte, err error)
func (*StatsPayload) Msgsize ¶
func (z *StatsPayload) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*StatsPayload) ProtoMessage ¶
func (*StatsPayload) ProtoMessage()
func (*StatsPayload) ProtoReflect ¶
func (x *StatsPayload) ProtoReflect() protoreflect.Message
func (*StatsPayload) Reset ¶
func (x *StatsPayload) Reset()
func (*StatsPayload) SizeVT ¶
func (m *StatsPayload) SizeVT() (n int)
func (*StatsPayload) String ¶
func (x *StatsPayload) String() string
func (*StatsPayload) UnmarshalMsg ¶
func (z *StatsPayload) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*StatsPayload) UnmarshalVT ¶
func (m *StatsPayload) UnmarshalVT(dAtA []byte) error
type Trace ¶
type Trace []*Span
Trace is a collection of spans with the same trace ID
func (Trace) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
type TraceChunk ¶
type TraceChunk struct {
// priority specifies sampling priority of the trace.
// @gotags: json:"priority" msg:"priority"
Priority int32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority" msg:"priority"`
// origin specifies origin product ("lambda", "rum", etc.) of the trace.
// @gotags: json:"origin" msg:"origin"
Origin string `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin" msg:"origin"`
// spans specifies list of containing spans.
// @gotags: json:"spans" msg:"spans"
Spans []*Span `protobuf:"bytes,3,rep,name=spans,proto3" json:"spans" msg:"spans"`
// tags specifies tags common in all `spans`.
// @gotags: json:"tags" msg:"tags"
Tags map[string]string `` /* 136-byte string literal not displayed */
// droppedTrace specifies whether the trace was dropped by samplers or not.
// @gotags: json:"dropped_trace" msg:"dropped_trace"
DroppedTrace bool `protobuf:"varint,5,opt,name=droppedTrace,proto3" json:"dropped_trace" msg:"dropped_trace"`
// contains filtered or unexported fields
}
TraceChunk represents a list of spans with the same trace ID. In other words, a chunk of a trace.
func (*TraceChunk) Descriptor
deprecated
func (*TraceChunk) Descriptor() ([]byte, []int)
Deprecated: Use TraceChunk.ProtoReflect.Descriptor instead.
func (*TraceChunk) GetDroppedTrace ¶
func (x *TraceChunk) GetDroppedTrace() bool
func (*TraceChunk) GetOrigin ¶
func (x *TraceChunk) GetOrigin() string
func (*TraceChunk) GetPriority ¶
func (x *TraceChunk) GetPriority() int32
func (*TraceChunk) GetSpans ¶
func (x *TraceChunk) GetSpans() []*Span
func (*TraceChunk) GetTags ¶
func (x *TraceChunk) GetTags() map[string]string
func (*TraceChunk) MarshalMsg ¶
func (z *TraceChunk) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*TraceChunk) MarshalToSizedBufferVT ¶
func (m *TraceChunk) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TraceChunk) MarshalToVT ¶
func (m *TraceChunk) MarshalToVT(dAtA []byte) (int, error)
func (*TraceChunk) MarshalVT ¶
func (m *TraceChunk) MarshalVT() (dAtA []byte, err error)
func (*TraceChunk) Msgsize ¶
func (z *TraceChunk) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*TraceChunk) ProtoMessage ¶
func (*TraceChunk) ProtoMessage()
func (*TraceChunk) ProtoReflect ¶
func (x *TraceChunk) ProtoReflect() protoreflect.Message
func (*TraceChunk) Reset ¶
func (x *TraceChunk) Reset()
func (*TraceChunk) ShallowCopy ¶
func (t *TraceChunk) ShallowCopy() *TraceChunk
ShallowCopy returns a shallow copy of the copy-able portion of a TraceChunk. These are the public fields which will have a Get* method for them. The completeness of this method is enforced by the init function above. Instead of using pkg/proto/utils.ProtoCopier, which incurs heavy reflection cost for every copy at runtime, we use reflection once at startup to ensure our method is complete.
func (*TraceChunk) SizeVT ¶
func (m *TraceChunk) SizeVT() (n int)
func (*TraceChunk) String ¶
func (x *TraceChunk) String() string
func (*TraceChunk) UnmarshalMsg ¶
func (z *TraceChunk) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*TraceChunk) UnmarshalVT ¶
func (m *TraceChunk) UnmarshalVT(dAtA []byte) error
type TraceRootFlag ¶ added in v0.53.0
type TraceRootFlag int32
const ( TraceRootFlag_DEPRECATED_NOT_SET TraceRootFlag = 0 TraceRootFlag_DEPRECATED_TRUE TraceRootFlag = 1 TraceRootFlag_DEPRECATED_FALSE TraceRootFlag = 2 )
func (*TraceRootFlag) DecodeMsg ¶ added in v0.53.0
func (z *TraceRootFlag) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (TraceRootFlag) Descriptor ¶ added in v0.53.0
func (TraceRootFlag) Descriptor() protoreflect.EnumDescriptor
func (TraceRootFlag) EncodeMsg ¶ added in v0.53.0
func (z TraceRootFlag) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (TraceRootFlag) Enum ¶ added in v0.53.0
func (x TraceRootFlag) Enum() *TraceRootFlag
func (TraceRootFlag) EnumDescriptor
deprecated
added in
v0.53.0
func (TraceRootFlag) EnumDescriptor() ([]byte, []int)
Deprecated: Use TraceRootFlag.Descriptor instead.
func (TraceRootFlag) MarshalMsg ¶ added in v0.53.0
func (z TraceRootFlag) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (TraceRootFlag) Msgsize ¶ added in v0.53.0
func (z TraceRootFlag) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (TraceRootFlag) Number ¶ added in v0.53.0
func (x TraceRootFlag) Number() protoreflect.EnumNumber
func (TraceRootFlag) String ¶ added in v0.53.0
func (x TraceRootFlag) String() string
func (TraceRootFlag) Type ¶ added in v0.53.0
func (TraceRootFlag) Type() protoreflect.EnumType
func (*TraceRootFlag) UnmarshalMsg ¶ added in v0.53.0
func (z *TraceRootFlag) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type TracerPayload ¶
type TracerPayload struct {
// containerID specifies the ID of the container where the tracer is running on.
// @gotags: json:"container_id" msg:"container_id"
ContainerID string `protobuf:"bytes,1,opt,name=containerID,proto3" json:"container_id" msg:"container_id"`
// languageName specifies language of the tracer.
// @gotags: json:"language_name" msg:"language_name"
LanguageName string `protobuf:"bytes,2,opt,name=languageName,proto3" json:"language_name" msg:"language_name"`
// languageVersion specifies language version of the tracer.
// @gotags: json:"language_version" msg:"language_version"
LanguageVersion string `protobuf:"bytes,3,opt,name=languageVersion,proto3" json:"language_version" msg:"language_version"`
// tracerVersion specifies version of the tracer.
// @gotags: json:"tracer_version" msg:"tracer_version"
TracerVersion string `protobuf:"bytes,4,opt,name=tracerVersion,proto3" json:"tracer_version" msg:"tracer_version"`
// runtimeID specifies V4 UUID representation of a tracer session.
// @gotags: json:"runtime_id" msg:"runtime_id"
RuntimeID string `protobuf:"bytes,5,opt,name=runtimeID,proto3" json:"runtime_id" msg:"runtime_id"`
// chunks specifies list of containing trace chunks.
// @gotags: json:"chunks" msg:"chunks"
Chunks []*TraceChunk `protobuf:"bytes,6,rep,name=chunks,proto3" json:"chunks" msg:"chunks"`
// tags specifies tags common in all `chunks`.
// @gotags: json:"tags" msg:"tags"
Tags map[string]string `` /* 136-byte string literal not displayed */
// env specifies `env` tag that set with the tracer.
// @gotags: json:"env" msg:"env"
Env string `protobuf:"bytes,8,opt,name=env,proto3" json:"env" msg:"env"`
// hostname specifies hostname of where the tracer is running.
// @gotags: json:"hostname" msg:"hostname"
Hostname string `protobuf:"bytes,9,opt,name=hostname,proto3" json:"hostname" msg:"hostname"`
// version specifies `version` tag that set with the tracer.
// @gotags: json:"app_version" msg:"app_version"
AppVersion string `protobuf:"bytes,10,opt,name=appVersion,proto3" json:"app_version" msg:"app_version"`
// contains filtered or unexported fields
}
TracerPayload represents a payload the trace agent receives from tracers.
func (*TracerPayload) Cut ¶
func (p *TracerPayload) Cut(i int) *TracerPayload
Cut cuts off a new tracer payload from the `p` with [0, i-1] chunks and keeps [i, n-1] chunks in the original payload `p`.
func (*TracerPayload) Descriptor
deprecated
func (*TracerPayload) Descriptor() ([]byte, []int)
Deprecated: Use TracerPayload.ProtoReflect.Descriptor instead.
func (*TracerPayload) GetAppVersion ¶
func (x *TracerPayload) GetAppVersion() string
func (*TracerPayload) GetChunks ¶
func (x *TracerPayload) GetChunks() []*TraceChunk
func (*TracerPayload) GetContainerID ¶
func (x *TracerPayload) GetContainerID() string
func (*TracerPayload) GetEnv ¶
func (x *TracerPayload) GetEnv() string
func (*TracerPayload) GetHostname ¶
func (x *TracerPayload) GetHostname() string
func (*TracerPayload) GetLanguageName ¶
func (x *TracerPayload) GetLanguageName() string
func (*TracerPayload) GetLanguageVersion ¶
func (x *TracerPayload) GetLanguageVersion() string
func (*TracerPayload) GetRuntimeID ¶
func (x *TracerPayload) GetRuntimeID() string
func (*TracerPayload) GetTags ¶
func (x *TracerPayload) GetTags() map[string]string
func (*TracerPayload) GetTracerVersion ¶
func (x *TracerPayload) GetTracerVersion() string
func (*TracerPayload) MarshalMsg ¶
func (z *TracerPayload) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*TracerPayload) MarshalToSizedBufferVT ¶
func (m *TracerPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TracerPayload) MarshalToVT ¶
func (m *TracerPayload) MarshalToVT(dAtA []byte) (int, error)
func (*TracerPayload) MarshalVT ¶
func (m *TracerPayload) MarshalVT() (dAtA []byte, err error)
func (*TracerPayload) Msgsize ¶
func (z *TracerPayload) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*TracerPayload) ProtoMessage ¶
func (*TracerPayload) ProtoMessage()
func (*TracerPayload) ProtoReflect ¶
func (x *TracerPayload) ProtoReflect() protoreflect.Message
func (*TracerPayload) RemoveChunk ¶
func (p *TracerPayload) RemoveChunk(i int)
RemoveChunk removes a chunk by its index.
func (*TracerPayload) Reset ¶
func (x *TracerPayload) Reset()
func (*TracerPayload) SizeVT ¶
func (m *TracerPayload) SizeVT() (n int)
func (*TracerPayload) String ¶
func (x *TracerPayload) String() string
func (*TracerPayload) UnmarshalMsg ¶
func (z *TracerPayload) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
func (*TracerPayload) UnmarshalVT ¶
func (m *TracerPayload) UnmarshalVT(dAtA []byte) error
type Traces ¶
type Traces []Trace
Traces is a list of traces. This model matters as this is what we unpack from msgp.
func (Traces) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
func (Traces) Msgsize ¶
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*Traces) UnmarshalMsg ¶
UnmarshalMsg implements msgp.Unmarshaler
func (*Traces) UnmarshalMsgDictionary ¶
UnmarshalMsgDictionary decodes a trace using the specification from the v0.5 endpoint. For details, see the documentation for endpoint v0.5 in pkg/trace/api/version.go
type Trilean ¶ added in v0.55.0
type Trilean int32
Trilean is an expanded boolean type that is meant to differentiate between being unset and false.
func (Trilean) Descriptor ¶ added in v0.55.0
func (Trilean) Descriptor() protoreflect.EnumDescriptor
func (Trilean) EnumDescriptor
deprecated
added in
v0.55.0
func (Trilean) MarshalMsg ¶ added in v0.55.0
MarshalMsg implements msgp.Marshaler
func (Trilean) Msgsize ¶ added in v0.55.0
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (Trilean) Number ¶ added in v0.55.0
func (x Trilean) Number() protoreflect.EnumNumber
func (Trilean) Type ¶ added in v0.55.0
func (Trilean) Type() protoreflect.EnumType
Source Files
¶
- agent_payload.pb.go
- agent_payload_gen.go
- agent_payload_vtproto.pb.go
- decoder_bytes.go
- decoder_v05.go
- span.pb.go
- span_gen.go
- span_utils.go
- span_vtproto.pb.go
- stats.pb.go
- stats_gen.go
- stats_vtproto.pb.go
- trace.go
- trace_gen.go
- tracer_payload.pb.go
- tracer_payload_gen.go
- tracer_payload_utils.go
- tracer_payload_vtproto.pb.go