pb

package
v0.0.0-...-7983b3b Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package pb contains the data structures used by the trace agent to communicate with tracers and the Datadog API. Note that the "//go:generate" directives from this package were removed because the generated files were manually edited to create adaptions (see decoder.go).

TODO: eventually move this to https://github.com/DataDog/agent-payload/v5 

Package pb is a generated protocol buffer package.

It is generated from these files:
	remote_rates.proto

It has these top-level messages:
	TargetTPS
	APMSampling

Package pb is a generated protocol buffer package.

It is generated from these files:
	span.proto
	tracer_payload.proto
	agent_payload.proto

It has these top-level messages:
	Span
	TraceChunk
	TracerPayload
	AgentPayload

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAgentPayload = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAgentPayload   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRemoteRates = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRemoteRates   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSpan = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSpan   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStats   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTracerPayload = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTracerPayload   = fmt.Errorf("proto: integer overflow")
)

Functions

func MetaHook 

func MetaHook() (hook func(k, v string) string, ok bool)

MetaHook returns the active meta hook. A MetaHook is a function which is ran for each span.Meta[k] = v value and has the opportunity to alter the final v.

func SetMetaHook 

func SetMetaHook(hook func(k, v string) string)

SetMetaHook registers a callback which will run upon decoding each map entry in the span's Meta field. The hook has the opportunity to alter the value that is assigned to span.Meta[k] at decode time. By default, if no hook is defined, the behaviour is span.Meta[k] = v.

Types

type APMSampling 

type APMSampling struct {
	TargetTps []TargetTPS `protobuf:"bytes,1,rep,name=target_tps,json=targetTps" json:"target_tps"`
}

func (*APMSampling) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*APMSampling) Descriptor 

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

func (*APMSampling) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*APMSampling) GetTargetTps 

func (m *APMSampling) GetTargetTps() []TargetTPS

func (*APMSampling) Marshal 

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

func (*APMSampling) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*APMSampling) MarshalTo 

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

func (*APMSampling) Msgsize 

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

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

func (*APMSampling) ProtoMessage 

func (*APMSampling) ProtoMessage()

func (*APMSampling) Reset 

func (m *APMSampling) Reset()

func (*APMSampling) Size 

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

func (*APMSampling) String 

func (m *APMSampling) String() string

func (*APMSampling) Unmarshal 

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

func (*APMSampling) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

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" json:"tracerPayloads,omitempty"`
	// tags specifies tags common in all `tracerPayloads`.
	Tags map[string]string `` /* 142-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"`
}

AgentPayload represents payload the agent sends to the intake.

func (*AgentPayload) Descriptor 

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

func (*AgentPayload) GetTags 

func (m *AgentPayload) GetTags() map[string]string

func (*AgentPayload) GetTracerPayloads 

func (m *AgentPayload) GetTracerPayloads() []*TracerPayload

func (*AgentPayload) Marshal 

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

func (*AgentPayload) MarshalTo 

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

func (*AgentPayload) ProtoMessage 

func (*AgentPayload) ProtoMessage()

func (*AgentPayload) Reset 

func (m *AgentPayload) Reset()

func (*AgentPayload) Size 

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

func (*AgentPayload) String 

func (m *AgentPayload) String() string

func (*AgentPayload) Unmarshal 

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

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"`
	Hits           uint64 `protobuf:"varint,7,opt,name=hits,proto3" json:"hits,omitempty"`
	Errors         uint64 `protobuf:"varint,8,opt,name=errors,proto3" json:"errors,omitempty"`
	Duration       uint64 `protobuf:"varint,9,opt,name=duration,proto3" json:"duration,omitempty"`
	OkSummary      []byte `protobuf:"bytes,10,opt,name=okSummary,proto3" json:"okSummary,omitempty"`
	ErrorSummary   []byte `protobuf:"bytes,11,opt,name=errorSummary,proto3" json:"errorSummary,omitempty"`
	Synthetics     bool   `protobuf:"varint,12,opt,name=synthetics,proto3" json:"synthetics,omitempty"`
	TopLevelHits   uint64 `protobuf:"varint,13,opt,name=topLevelHits,proto3" json:"topLevelHits,omitempty"`
}

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 

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

func (*ClientGroupedStats) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*ClientGroupedStats) GetDBType 

func (m *ClientGroupedStats) GetDBType() string

func (*ClientGroupedStats) GetDuration 

func (m *ClientGroupedStats) GetDuration() uint64

func (*ClientGroupedStats) GetErrorSummary 

func (m *ClientGroupedStats) GetErrorSummary() []byte

func (*ClientGroupedStats) GetErrors 

func (m *ClientGroupedStats) GetErrors() uint64

func (*ClientGroupedStats) GetHTTPStatusCode 

func (m *ClientGroupedStats) GetHTTPStatusCode() uint32

func (*ClientGroupedStats) GetHits 

func (m *ClientGroupedStats) GetHits() uint64

func (*ClientGroupedStats) GetName 

func (m *ClientGroupedStats) GetName() string

func (*ClientGroupedStats) GetOkSummary 

func (m *ClientGroupedStats) GetOkSummary() []byte

func (*ClientGroupedStats) GetResource 

func (m *ClientGroupedStats) GetResource() string

func (*ClientGroupedStats) GetService 

func (m *ClientGroupedStats) GetService() string

func (*ClientGroupedStats) GetSynthetics 

func (m *ClientGroupedStats) GetSynthetics() bool

func (*ClientGroupedStats) GetTopLevelHits 

func (m *ClientGroupedStats) GetTopLevelHits() uint64

func (*ClientGroupedStats) GetType 

func (m *ClientGroupedStats) GetType() string

func (*ClientGroupedStats) Marshal 

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

func (*ClientGroupedStats) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*ClientGroupedStats) MarshalTo 

func (m *ClientGroupedStats) MarshalTo(dAtA []byte) (int, 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) Reset 

func (m *ClientGroupedStats) Reset()

func (*ClientGroupedStats) Size 

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

func (*ClientGroupedStats) String 

func (m *ClientGroupedStats) String() string

func (*ClientGroupedStats) Unmarshal 

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

func (*ClientGroupedStats) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ClientGroupedStats) XXX_DiscardUnknown 

func (m *ClientGroupedStats) XXX_DiscardUnknown()

func (*ClientGroupedStats) XXX_Marshal 

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

func (*ClientGroupedStats) XXX_Merge 

func (dst *ClientGroupedStats) XXX_Merge(src proto.Message)

func (*ClientGroupedStats) XXX_Size 

func (m *ClientGroupedStats) XXX_Size() int

func (*ClientGroupedStats) XXX_Unmarshal 

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

type ClientStatsBucket 

type ClientStatsBucket struct {
	Start    uint64               `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	Duration uint64               `protobuf:"varint,2,opt,name=duration,proto3" json:"duration,omitempty"`
	Stats    []ClientGroupedStats `protobuf:"bytes,3,rep,name=stats" json:"stats"`
	// 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"`
}

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 

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

func (*ClientStatsBucket) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*ClientStatsBucket) GetAgentTimeShift 

func (m *ClientStatsBucket) GetAgentTimeShift() int64

func (*ClientStatsBucket) GetDuration 

func (m *ClientStatsBucket) GetDuration() uint64

func (*ClientStatsBucket) GetStart 

func (m *ClientStatsBucket) GetStart() uint64

func (*ClientStatsBucket) GetStats 

func (m *ClientStatsBucket) GetStats() []ClientGroupedStats

func (*ClientStatsBucket) Marshal 

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

func (*ClientStatsBucket) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*ClientStatsBucket) MarshalTo 

func (m *ClientStatsBucket) MarshalTo(dAtA []byte) (int, 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) Reset 

func (m *ClientStatsBucket) Reset()

func (*ClientStatsBucket) Size 

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

func (*ClientStatsBucket) String 

func (m *ClientStatsBucket) String() string

func (*ClientStatsBucket) Unmarshal 

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

func (*ClientStatsBucket) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ClientStatsBucket) XXX_DiscardUnknown 

func (m *ClientStatsBucket) XXX_DiscardUnknown()

func (*ClientStatsBucket) XXX_Marshal 

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

func (*ClientStatsBucket) XXX_Merge 

func (dst *ClientStatsBucket) XXX_Merge(src proto.Message)

func (*ClientStatsBucket) XXX_Size 

func (m *ClientStatsBucket) XXX_Size() int

func (*ClientStatsBucket) XXX_Unmarshal 

func (m *ClientStatsBucket) XXX_Unmarshal(b []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"`
	Version       string              `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Stats         []ClientStatsBucket `protobuf:"bytes,4,rep,name=stats" json:"stats"`
	Lang          string              `protobuf:"bytes,5,opt,name=lang,proto3" json:"lang,omitempty"`
	TracerVersion string              `protobuf:"bytes,6,opt,name=tracerVersion,proto3" json:"tracerVersion,omitempty"`
	RuntimeID     string              `protobuf:"bytes,7,opt,name=runtimeID,proto3" json:"runtimeID,omitempty"`
	Sequence      uint64              `protobuf:"varint,8,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// 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" json:"tags,omitempty"`
}

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 

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

func (*ClientStatsPayload) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*ClientStatsPayload) GetAgentAggregation 

func (m *ClientStatsPayload) GetAgentAggregation() string

func (*ClientStatsPayload) GetContainerID 

func (m *ClientStatsPayload) GetContainerID() string

func (*ClientStatsPayload) GetEnv 

func (m *ClientStatsPayload) GetEnv() string

func (*ClientStatsPayload) GetHostname 

func (m *ClientStatsPayload) GetHostname() string

func (*ClientStatsPayload) GetLang 

func (m *ClientStatsPayload) GetLang() string

func (*ClientStatsPayload) GetRuntimeID 

func (m *ClientStatsPayload) GetRuntimeID() string

func (*ClientStatsPayload) GetSequence 

func (m *ClientStatsPayload) GetSequence() uint64

func (*ClientStatsPayload) GetService 

func (m *ClientStatsPayload) GetService() string

func (*ClientStatsPayload) GetStats 

func (m *ClientStatsPayload) GetStats() []ClientStatsBucket

func (*ClientStatsPayload) GetTags 

func (m *ClientStatsPayload) GetTags() []string

func (*ClientStatsPayload) GetTracerVersion 

func (m *ClientStatsPayload) GetTracerVersion() string

func (*ClientStatsPayload) GetVersion 

func (m *ClientStatsPayload) GetVersion() string

func (*ClientStatsPayload) Marshal 

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

func (*ClientStatsPayload) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*ClientStatsPayload) MarshalTo 

func (m *ClientStatsPayload) MarshalTo(dAtA []byte) (int, 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) Reset 

func (m *ClientStatsPayload) Reset()

func (*ClientStatsPayload) Size 

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

func (*ClientStatsPayload) String 

func (m *ClientStatsPayload) String() string

func (*ClientStatsPayload) Unmarshal 

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

func (*ClientStatsPayload) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ClientStatsPayload) XXX_DiscardUnknown 

func (m *ClientStatsPayload) XXX_DiscardUnknown()

func (*ClientStatsPayload) XXX_Marshal 

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

func (*ClientStatsPayload) XXX_Merge 

func (dst *ClientStatsPayload) XXX_Merge(src proto.Message)

func (*ClientStatsPayload) XXX_Size 

func (m *ClientStatsPayload) XXX_Size() int

func (*ClientStatsPayload) XXX_Unmarshal 

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

type Span 

type Span struct {
	Service  string             `protobuf:"bytes,1,opt,name=service,proto3" json:"service" msg:"service"`
	Name     string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name" msg:"name"`
	Resource string             `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource" msg:"resource"`
	TraceID  uint64             `protobuf:"varint,4,opt,name=traceID,proto3" json:"trace_id" msg:"trace_id"`
	SpanID   uint64             `protobuf:"varint,5,opt,name=spanID,proto3" json:"span_id" msg:"span_id"`
	ParentID uint64             `protobuf:"varint,6,opt,name=parentID,proto3" json:"parent_id" msg:"parent_id"`
	Start    int64              `protobuf:"varint,7,opt,name=start,proto3" json:"start" msg:"start"`
	Duration int64              `protobuf:"varint,8,opt,name=duration,proto3" json:"duration" msg:"duration"`
	Error    int32              `protobuf:"varint,9,opt,name=error,proto3" json:"error" msg:"error"`
	Meta     map[string]string  `` /* 144-byte string literal not displayed */
	Metrics  map[string]float64 `` /* 155-byte string literal not displayed */
	Type     string             `protobuf:"bytes,12,opt,name=type,proto3" json:"type" msg:"type"`
}

func (*Span) Descriptor 

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

func (*Span) GetMeta 

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

func (*Span) GetMetrics 

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

func (*Span) Marshal 

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

func (*Span) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*Span) MarshalTo 

func (m *Span) MarshalTo(data []byte) (int, 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) Reset 

func (m *Span) Reset()

func (*Span) Size 

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

func (*Span) String 

func (m *Span) String() string

func (*Span) Unmarshal 

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

func (*Span) 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

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"`
	Stats          []ClientStatsPayload `protobuf:"bytes,3,rep,name=stats" json:"stats"`
	AgentVersion   string               `protobuf:"bytes,4,opt,name=agentVersion,proto3" json:"agentVersion,omitempty"`
	ClientComputed bool                 `protobuf:"varint,5,opt,name=clientComputed,proto3" json:"clientComputed,omitempty"`
}

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 

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

func (*StatsPayload) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*StatsPayload) GetAgentEnv 

func (m *StatsPayload) GetAgentEnv() string

func (*StatsPayload) GetAgentHostname 

func (m *StatsPayload) GetAgentHostname() string

func (*StatsPayload) GetAgentVersion 

func (m *StatsPayload) GetAgentVersion() string

func (*StatsPayload) GetClientComputed 

func (m *StatsPayload) GetClientComputed() bool

func (*StatsPayload) GetStats 

func (m *StatsPayload) GetStats() []ClientStatsPayload

func (*StatsPayload) Marshal 

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

func (*StatsPayload) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*StatsPayload) MarshalTo 

func (m *StatsPayload) MarshalTo(dAtA []byte) (int, 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) Reset 

func (m *StatsPayload) Reset()

func (*StatsPayload) Size 

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

func (*StatsPayload) String 

func (m *StatsPayload) String() string

func (*StatsPayload) Unmarshal 

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

func (*StatsPayload) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*StatsPayload) XXX_DiscardUnknown 

func (m *StatsPayload) XXX_DiscardUnknown()

func (*StatsPayload) XXX_Marshal 

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

func (*StatsPayload) XXX_Merge 

func (dst *StatsPayload) XXX_Merge(src proto.Message)

func (*StatsPayload) XXX_Size 

func (m *StatsPayload) XXX_Size() int

func (*StatsPayload) XXX_Unmarshal 

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

type TargetTPS 

type TargetTPS struct {
	Service string  `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Env     string  `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
	Value   float64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*TargetTPS) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*TargetTPS) Descriptor 

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

func (TargetTPS) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*TargetTPS) Marshal 

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

func (TargetTPS) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*TargetTPS) MarshalTo 

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

func (TargetTPS) Msgsize 

func (z TargetTPS) Msgsize() (s int)

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

func (*TargetTPS) ProtoMessage 

func (*TargetTPS) ProtoMessage()

func (*TargetTPS) Reset 

func (m *TargetTPS) Reset()

func (*TargetTPS) Size 

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

func (*TargetTPS) String 

func (m *TargetTPS) String() string

func (*TargetTPS) Unmarshal 

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

func (*TargetTPS) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

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.
	Priority int32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority" msg:"priority"`
	// origin specifies origin product ("lambda", "rum", etc.) of the trace.
	Origin string `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin" msg:"origin"`
	// spans specifies list of containing spans.
	Spans []*Span `protobuf:"bytes,3,rep,name=spans" json:"spans" msg:"spans"`
	// tags specifies tags common in all `spans`.
	Tags map[string]string `` /* 143-byte string literal not displayed */
	// droppedTrace specifies whether the trace was dropped by samplers or not.
	DroppedTrace bool `protobuf:"varint,5,opt,name=droppedTrace,proto3" json:"dropped_trace" msg:"dropped_trace"`
}

TraceChunk represents a list of spans with the same trace id.

func (*TraceChunk) Descriptor 

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

func (*TraceChunk) GetSpans 

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

func (*TraceChunk) GetTags 

func (m *TraceChunk) GetTags() map[string]string

func (*TraceChunk) Marshal 

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

func (*TraceChunk) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*TraceChunk) MarshalTo 

func (m *TraceChunk) MarshalTo(data []byte) (int, 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) Reset 

func (m *TraceChunk) Reset()

func (*TraceChunk) Size 

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

func (*TraceChunk) String 

func (m *TraceChunk) String() string

func (*TraceChunk) Unmarshal 

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

func (*TraceChunk) UnmarshalMsg 

func (z *TraceChunk) 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.
	ContainerID string `protobuf:"bytes,1,opt,name=containerID,proto3" json:"container_id" msg:"container_id"`
	// languageName specifies language of the tracer.
	LanguageName string `protobuf:"bytes,2,opt,name=languageName,proto3" json:"language_name" msg:"language_name"`
	// languageVersion specifies language version of the tracer.
	LanguageVersion string `protobuf:"bytes,3,opt,name=languageVersion,proto3" json:"language_version" msg:"language_version"`
	// tracerVersion specifies version of the tracer.
	TracerVersion string `protobuf:"bytes,4,opt,name=tracerVersion,proto3" json:"tracer_version" msg:"tracer_version"`
	// runtimeID specifies V4 UUID representation of a tracer session.
	RuntimeID string `protobuf:"bytes,5,opt,name=runtimeID,proto3" json:"runtime_id" msg:"runtime_id"`
	// chunks specifies list of containing trace chunks.
	Chunks []*TraceChunk `protobuf:"bytes,6,rep,name=chunks" json:"chunks" msg:"chunks"`
	// tags specifies tags common in all `chunks`.
	Tags map[string]string `` /* 143-byte string literal not displayed */
	// env specifies `env` tag that set with the tracer.
	Env string `protobuf:"bytes,8,opt,name=env,proto3" json:"env" msg:"env"`
	// hostname specifies hostname of where the tracer is running.
	Hostname string `protobuf:"bytes,9,opt,name=hostname,proto3" json:"hostname" msg:"hostname"`
	// version specifies `version` tag that set with the tracer.
	AppVersion string `protobuf:"bytes,10,opt,name=appVersion,proto3" json:"app_version" msg:"app_version"`
}

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 

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

func (*TracerPayload) GetChunks 

func (m *TracerPayload) GetChunks() []*TraceChunk

func (*TracerPayload) GetTags 

func (m *TracerPayload) GetTags() map[string]string

func (*TracerPayload) Marshal 

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

func (*TracerPayload) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*TracerPayload) MarshalTo 

func (m *TracerPayload) MarshalTo(data []byte) (int, 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) RemoveChunk 

func (p *TracerPayload) RemoveChunk(i int)

RemoveChunk removes a chunk by its index.

func (*TracerPayload) Reset 

func (m *TracerPayload) Reset()

func (*TracerPayload) Size 

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

func (*TracerPayload) String 

func (m *TracerPayload) String() string

func (*TracerPayload) Unmarshal 

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

func (*TracerPayload) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

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

Source Files

View all Source files

Directories

Path Synopsis
open-telemetry
common/v1
resource/v1
trace/collector
trace/v1
Package otlppb is a generated protocol buffer package.
 Package otlppb is a generated protocol buffer package.

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.