trace

package
v0.76.2 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2026 License: Apache-2.0 Imports: 21 Imported by: 36

Documentation

Overview

Package trace defines the types and functions to encode/decode traces.

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var File_datadog_trace_agent_payload_proto protoreflect.FileDescriptor
View Source 
var File_datadog_trace_span_proto protoreflect.FileDescriptor
View Source 
var File_datadog_trace_stats_proto protoreflect.FileDescriptor
View Source 
var File_datadog_trace_tracer_payload_proto protoreflect.FileDescriptor

Functions

func AppendAgentPayload added in v0.76.0 

func AppendAgentPayload(buf []byte, ap *AgentPayload) ([]byte, error)

AppendAgentPayload appends the serialized AgentPayload to the given buffer.

func MarshalAgentPayload added in v0.76.0 

func MarshalAgentPayload(ap *AgentPayload) ([]byte, error)

MarshalAgentPayload serializes an AgentPayload to protobuf binary format. This is a custom serializer that ignores the TracerPayloads field and only serializes the IdxTracerPayloads field along with the other fields. String compaction is performed during serialization without modifying the input payload.

func MarshalAgentPayloadPrepared added in v0.76.0 

func MarshalAgentPayloadPrepared(ap *AgentPayload, prepared []*PreparedTracerPayload) ([]byte, error)

MarshalAgentPayloadPrepared serializes an AgentPayload using pre-computed PreparedTracerPayloads. This is more efficient when the compaction has already been computed for size calculations, as it avoids recomputing the string mapping. Note: The ap.IdxTracerPayloads field is ignored; only the prepared payloads are serialized.

func SizeAgentPayload added in v0.76.0 

func SizeAgentPayload(ap *AgentPayload) int

SizeAgentPayload calculates the size of the serialized AgentPayload. Note: This returns an estimate as exact size depends on string compaction which happens during serialization.

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) Enum added in v0.63.0 

func (x AttributeAnyValue_AttributeAnyValueType) Enum() *AttributeAnyValue_AttributeAnyValueType

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) Enum added in v0.63.0 

func (x AttributeArrayValue_AttributeArrayValueType) Enum() *AttributeArrayValue_AttributeArrayValueType

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 PreparedTracerPayload added in v0.76.0 

type PreparedTracerPayload struct {
	Size int // compacted serialized size
	// contains filtered or unexported fields
}

PreparedTracerPayload holds a TracerPayload along with its pre-computed string compactor and size. This allows accurate size calculations for buffer management and avoids recomputing the compaction during serialization.

func PrepareTracerPayload added in v0.76.0 

func PrepareTracerPayload(tp *idx.TracerPayload) *PreparedTracerPayload

PrepareTracerPayload creates a PreparedTracerPayload by computing the string compaction and size upfront. The compactor is reused during serialization.

func PrepareTracerPayloadWithChunks added in v0.76.0 

func PrepareTracerPayloadWithChunks(source *idx.TracerPayload, chunks []*idx.TraceChunk) *PreparedTracerPayload

PrepareTracerPayloadWithChunks creates a PreparedTracerPayload using only a subset of chunks from the source payload. This is useful for splitting large payloads while reusing the string table. PreparedTracerPayloads must not be modified to avoid race conditions.

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) Descriptor() ([]byte, []int)

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) Get128BitTraceID added in v0.73.0 

func (s *Span) Get128BitTraceID() ([]byte, error)

Get128BitTraceID returns the 128-bit trace ID for the span.

func (*Span) GetDuration 

func (x *Span) GetDuration() int64

func (*Span) GetError 

func (x *Span) GetError() int32

func (*Span) GetMeta 

func (x *Span) GetMeta() map[string]string

func (*Span) GetMetaStruct 

func (x *Span) GetMetaStruct() map[string][]byte

func (*Span) GetMetrics 

func (x *Span) GetMetrics() map[string]float64

func (*Span) GetName 

func (x *Span) GetName() string

func (*Span) GetParentID 

func (x *Span) GetParentID() uint64

func (*Span) GetResource 

func (x *Span) GetResource() string

func (*Span) GetService 

func (x *Span) GetService() string

func (*Span) GetSpanEvents added in v0.63.0 

func (x *Span) GetSpanEvents() []*SpanEvent

func (*Span) GetSpanID 

func (x *Span) GetSpanID() uint64
func (x *Span) GetSpanLinks() []*SpanLink

func (*Span) GetStart 

func (x *Span) GetStart() int64

func (*Span) GetTraceID 

func (x *Span) GetTraceID() uint64

func (*Span) GetType 

func (x *Span) GetType() string

func (*Span) MarshalMsg 

func (z *Span) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Span) MarshalToSizedBufferVT 

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

func (*Span) MarshalToVT 

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

func (*Span) MarshalVT 

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

func (*Span) Msgsize 

func (z *Span) Msgsize() (s int)

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) Reset 

func (x *Span) Reset()

func (*Span) ShallowCopy 

func (s *Span) ShallowCopy() *Span

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) SizeVT 

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

func (*Span) String 

func (x *Span) String() string

func (*Span) UnmarshalMsg 

func (z *Span) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*Span) UnmarshalMsgDictionary 

func (z *Span) UnmarshalMsgDictionary(bts []byte, dict []string) ([]byte, error)

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 

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

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) Descriptor() ([]byte, []int)

Deprecated: Use SpanEvent.ProtoReflect.Descriptor instead.

func (*SpanEvent) GetAttributes added in v0.63.0 

func (x *SpanEvent) GetAttributes() map[string]*AttributeAnyValue

func (*SpanEvent) GetName added in v0.63.0 

func (x *SpanEvent) GetName() string

func (*SpanEvent) GetTimeUnixNano added in v0.63.0 

func (x *SpanEvent) GetTimeUnixNano() uint64

func (*SpanEvent) MarshalMsg added in v0.63.0 

func (z *SpanEvent) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*SpanEvent) MarshalToSizedBufferVT added in v0.63.0 

func (m *SpanEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanEvent) MarshalToVT added in v0.63.0 

func (m *SpanEvent) MarshalToVT(dAtA []byte) (int, error)

func (*SpanEvent) MarshalVT added in v0.63.0 

func (m *SpanEvent) MarshalVT() (dAtA []byte, err error)

func (*SpanEvent) Msgsize added in v0.63.0 

func (z *SpanEvent) Msgsize() (s int)

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) Reset added in v0.63.0 

func (x *SpanEvent) Reset()

func (*SpanEvent) SizeVT added in v0.63.0 

func (m *SpanEvent) SizeVT() (n int)

func (*SpanEvent) String added in v0.63.0 

func (x *SpanEvent) String() string

func (*SpanEvent) UnmarshalMsg added in v0.63.0 

func (z *SpanEvent) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*SpanEvent) UnmarshalVT added in v0.63.0 

func (m *SpanEvent) UnmarshalVT(dAtA []byte) error
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) Descriptor() ([]byte, []int)

Deprecated: Use SpanLink.ProtoReflect.Descriptor instead.

func (*SpanLink) GetAttributes added in v0.52.0 

func (x *SpanLink) GetAttributes() map[string]string

func (*SpanLink) GetFlags added in v0.52.0 

func (x *SpanLink) GetFlags() uint32

func (*SpanLink) GetSpanID added in v0.52.0 

func (x *SpanLink) GetSpanID() uint64

func (*SpanLink) GetTraceID added in v0.52.0 

func (x *SpanLink) GetTraceID() uint64

func (*SpanLink) GetTraceIDHigh added in v0.52.0 

func (x *SpanLink) GetTraceIDHigh() uint64

func (*SpanLink) GetTracestate added in v0.52.0 

func (x *SpanLink) GetTracestate() string

func (*SpanLink) MarshalMsg added in v0.52.0 

func (z *SpanLink) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*SpanLink) MarshalToSizedBufferVT added in v0.52.0 

func (m *SpanLink) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SpanLink) MarshalToVT added in v0.52.0 

func (m *SpanLink) MarshalToVT(dAtA []byte) (int, error)

func (*SpanLink) MarshalVT added in v0.52.0 

func (m *SpanLink) MarshalVT() (dAtA []byte, err error)

func (*SpanLink) Msgsize added in v0.52.0 

func (z *SpanLink) Msgsize() (s int)

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) Reset added in v0.52.0 

func (x *SpanLink) Reset()

func (*SpanLink) SizeVT added in v0.52.0 

func (m *SpanLink) SizeVT() (n int)

func (*SpanLink) String added in v0.52.0 

func (x *SpanLink) String() string

func (*SpanLink) UnmarshalMsg added in v0.52.0 

func (z *SpanLink) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*SpanLink) UnmarshalVT added in v0.52.0 

func (m *SpanLink) UnmarshalVT(dAtA []byte) error

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 

func (z Trace) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (Trace) Msgsize 

func (z Trace) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Trace) UnmarshalMsg 

func (z *Trace) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

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 

func (z Traces) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (Traces) Msgsize 

func (z Traces) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Traces) UnmarshalMsg 

func (z *Traces) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*Traces) UnmarshalMsgDictionary 

func (t *Traces) UnmarshalMsgDictionary(bts []byte) error

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. 

const (
	Trilean_NOT_SET Trilean = 0
	Trilean_TRUE    Trilean = 1
	Trilean_FALSE   Trilean = 2
)

func (*Trilean) DecodeMsg added in v0.55.0 

func (z *Trilean) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (Trilean) Descriptor added in v0.55.0 

func (Trilean) Descriptor() protoreflect.EnumDescriptor

func (Trilean) EncodeMsg added in v0.55.0 

func (z Trilean) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (Trilean) Enum added in v0.55.0 

func (x Trilean) Enum() *Trilean

func (Trilean) EnumDescriptor deprecated added in v0.55.0 

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

Deprecated: Use Trilean.Descriptor instead.

func (Trilean) MarshalMsg added in v0.55.0 

func (z Trilean) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (Trilean) Msgsize added in v0.55.0 

func (z Trilean) Msgsize() (s int)

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) String added in v0.55.0 

func (x Trilean) String() string

func (Trilean) Type added in v0.55.0 

func (Trilean) Type() protoreflect.EnumType

func (*Trilean) UnmarshalMsg added in v0.55.0 

func (z *Trilean) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

Source Files

View all Source files

Directories

Path Synopsis
Package idx is used to unmarshal v1.0 Trace payloads
 Package idx is used to unmarshal v1.0 Trace payloads

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.