pb

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2021 License: Apache-2.0 Imports: 10 Imported by: 20

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 

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

Index

Constants

This section is empty.

Variables

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 (
	ErrInvalidLengthTrace = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTrace   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTracePayload = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTracePayload   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type APITrace 

type APITrace struct {
	TraceID   uint64  `protobuf:"varint,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Spans     []*Span `protobuf:"bytes,2,rep,name=spans" json:"spans,omitempty"`
	StartTime int64   `protobuf:"varint,6,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime   int64   `protobuf:"varint,7,opt,name=endTime,proto3" json:"endTime,omitempty"`
}

func (*APITrace) Descriptor 

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

func (*APITrace) GetSpans 

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

func (*APITrace) Marshal 

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

func (*APITrace) MarshalTo 

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

func (*APITrace) ProtoMessage 

func (*APITrace) ProtoMessage()

func (*APITrace) Reset 

func (m *APITrace) Reset()

func (*APITrace) Size 

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

func (*APITrace) String 

func (m *APITrace) String() string

func (*APITrace) Unmarshal 

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

type APMSampling added in v0.9.0 

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

func (*APMSampling) DecodeMsg added in v0.9.0 

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

DecodeMsg implements msgp.Decodable

func (*APMSampling) Descriptor added in v0.9.0 

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

func (*APMSampling) EncodeMsg added in v0.9.0 

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

EncodeMsg implements msgp.Encodable

func (*APMSampling) GetTargetTps added in v0.9.0 

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

func (*APMSampling) Marshal added in v0.9.0 

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

func (*APMSampling) MarshalMsg added in v0.9.0 

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

MarshalMsg implements msgp.Marshaler

func (*APMSampling) MarshalTo added in v0.9.0 

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

func (*APMSampling) Msgsize added in v0.9.0 

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

func (*APMSampling) ProtoMessage()

func (*APMSampling) Reset added in v0.9.0 

func (m *APMSampling) Reset()

func (*APMSampling) Size added in v0.9.0 

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

func (*APMSampling) String added in v0.9.0 

func (m *APMSampling) String() string

func (*APMSampling) Unmarshal added in v0.9.0 

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

func (*APMSampling) UnmarshalMsg added in v0.9.0 

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

UnmarshalMsg implements msgp.Unmarshaler

type ClientGroupedStats added in v0.9.0 

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

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

DecodeMsg implements msgp.Decodable

func (*ClientGroupedStats) Descriptor added in v0.9.0 

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

func (*ClientGroupedStats) EncodeMsg added in v0.9.0 

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

EncodeMsg implements msgp.Encodable

func (*ClientGroupedStats) GetDBType added in v0.9.0 

func (m *ClientGroupedStats) GetDBType() string

func (*ClientGroupedStats) GetDuration added in v0.9.0 

func (m *ClientGroupedStats) GetDuration() uint64

func (*ClientGroupedStats) GetErrorSummary added in v0.9.0 

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

func (*ClientGroupedStats) GetErrors added in v0.9.0 

func (m *ClientGroupedStats) GetErrors() uint64

func (*ClientGroupedStats) GetHTTPStatusCode added in v0.9.0 

func (m *ClientGroupedStats) GetHTTPStatusCode() uint32

func (*ClientGroupedStats) GetHits added in v0.9.0 

func (m *ClientGroupedStats) GetHits() uint64

func (*ClientGroupedStats) GetName added in v0.9.0 

func (m *ClientGroupedStats) GetName() string

func (*ClientGroupedStats) GetOkSummary added in v0.9.0 

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

func (*ClientGroupedStats) GetResource added in v0.9.0 

func (m *ClientGroupedStats) GetResource() string

func (*ClientGroupedStats) GetService added in v0.9.0 

func (m *ClientGroupedStats) GetService() string

func (*ClientGroupedStats) GetSynthetics added in v0.9.0 

func (m *ClientGroupedStats) GetSynthetics() bool

func (*ClientGroupedStats) GetTopLevelHits added in v0.9.0 

func (m *ClientGroupedStats) GetTopLevelHits() uint64

func (*ClientGroupedStats) GetType added in v0.9.0 

func (m *ClientGroupedStats) GetType() string

func (*ClientGroupedStats) Marshal added in v0.9.0 

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

func (*ClientGroupedStats) MarshalMsg added in v0.9.0 

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

MarshalMsg implements msgp.Marshaler

func (*ClientGroupedStats) MarshalTo added in v0.9.0 

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

func (*ClientGroupedStats) Msgsize added in v0.9.0 

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

func (*ClientGroupedStats) ProtoMessage()

func (*ClientGroupedStats) Reset added in v0.9.0 

func (m *ClientGroupedStats) Reset()

func (*ClientGroupedStats) Size added in v0.9.0 

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

func (*ClientGroupedStats) String added in v0.9.0 

func (m *ClientGroupedStats) String() string

func (*ClientGroupedStats) Unmarshal added in v0.9.0 

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

func (*ClientGroupedStats) UnmarshalMsg added in v0.9.0 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ClientGroupedStats) XXX_DiscardUnknown added in v0.9.0 

func (m *ClientGroupedStats) XXX_DiscardUnknown()

func (*ClientGroupedStats) XXX_Marshal added in v0.9.0 

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

func (*ClientGroupedStats) XXX_Merge added in v0.9.0 

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

func (*ClientGroupedStats) XXX_Size added in v0.9.0 

func (m *ClientGroupedStats) XXX_Size() int

func (*ClientGroupedStats) XXX_Unmarshal added in v0.9.0 

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

type ClientStatsBucket added in v0.9.0 

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

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

DecodeMsg implements msgp.Decodable

func (*ClientStatsBucket) Descriptor added in v0.9.0 

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

func (*ClientStatsBucket) EncodeMsg added in v0.9.0 

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

EncodeMsg implements msgp.Encodable

func (*ClientStatsBucket) GetAgentTimeShift added in v0.9.0 

func (m *ClientStatsBucket) GetAgentTimeShift() int64

func (*ClientStatsBucket) GetDuration added in v0.9.0 

func (m *ClientStatsBucket) GetDuration() uint64

func (*ClientStatsBucket) GetStart added in v0.9.0 

func (m *ClientStatsBucket) GetStart() uint64

func (*ClientStatsBucket) GetStats added in v0.9.0 

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

func (*ClientStatsBucket) Marshal added in v0.9.0 

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

func (*ClientStatsBucket) MarshalMsg added in v0.9.0 

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

MarshalMsg implements msgp.Marshaler

func (*ClientStatsBucket) MarshalTo added in v0.9.0 

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

func (*ClientStatsBucket) Msgsize added in v0.9.0 

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

func (*ClientStatsBucket) ProtoMessage()

func (*ClientStatsBucket) Reset added in v0.9.0 

func (m *ClientStatsBucket) Reset()

func (*ClientStatsBucket) Size added in v0.9.0 

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

func (*ClientStatsBucket) String added in v0.9.0 

func (m *ClientStatsBucket) String() string

func (*ClientStatsBucket) Unmarshal added in v0.9.0 

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

func (*ClientStatsBucket) UnmarshalMsg added in v0.9.0 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ClientStatsBucket) XXX_DiscardUnknown added in v0.9.0 

func (m *ClientStatsBucket) XXX_DiscardUnknown()

func (*ClientStatsBucket) XXX_Marshal added in v0.9.0 

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

func (*ClientStatsBucket) XXX_Merge added in v0.9.0 

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

func (*ClientStatsBucket) XXX_Size added in v0.9.0 

func (m *ClientStatsBucket) XXX_Size() int

func (*ClientStatsBucket) XXX_Unmarshal added in v0.9.0 

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

type ClientStatsPayload added in v0.9.0 

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

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

DecodeMsg implements msgp.Decodable

func (*ClientStatsPayload) Descriptor added in v0.9.0 

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

func (*ClientStatsPayload) EncodeMsg added in v0.9.0 

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

EncodeMsg implements msgp.Encodable

func (*ClientStatsPayload) GetAgentAggregation added in v0.9.0 

func (m *ClientStatsPayload) GetAgentAggregation() string

func (*ClientStatsPayload) GetContainerID added in v0.9.0 

func (m *ClientStatsPayload) GetContainerID() string

func (*ClientStatsPayload) GetEnv added in v0.9.0 

func (m *ClientStatsPayload) GetEnv() string

func (*ClientStatsPayload) GetHostname added in v0.9.0 

func (m *ClientStatsPayload) GetHostname() string

func (*ClientStatsPayload) GetLang added in v0.9.0 

func (m *ClientStatsPayload) GetLang() string

func (*ClientStatsPayload) GetRuntimeID added in v0.9.0 

func (m *ClientStatsPayload) GetRuntimeID() string

func (*ClientStatsPayload) GetSequence added in v0.9.0 

func (m *ClientStatsPayload) GetSequence() uint64

func (*ClientStatsPayload) GetService added in v0.9.0 

func (m *ClientStatsPayload) GetService() string

func (*ClientStatsPayload) GetStats added in v0.9.0 

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

func (*ClientStatsPayload) GetTags added in v0.9.0 

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

func (*ClientStatsPayload) GetTracerVersion added in v0.9.0 

func (m *ClientStatsPayload) GetTracerVersion() string

func (*ClientStatsPayload) GetVersion added in v0.9.0 

func (m *ClientStatsPayload) GetVersion() string

func (*ClientStatsPayload) Marshal added in v0.9.0 

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

func (*ClientStatsPayload) MarshalMsg added in v0.9.0 

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

MarshalMsg implements msgp.Marshaler

func (*ClientStatsPayload) MarshalTo added in v0.9.0 

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

func (*ClientStatsPayload) Msgsize added in v0.9.0 

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

func (*ClientStatsPayload) ProtoMessage()

func (*ClientStatsPayload) Reset added in v0.9.0 

func (m *ClientStatsPayload) Reset()

func (*ClientStatsPayload) Size added in v0.9.0 

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

func (*ClientStatsPayload) String added in v0.9.0 

func (m *ClientStatsPayload) String() string

func (*ClientStatsPayload) Unmarshal added in v0.9.0 

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

func (*ClientStatsPayload) UnmarshalMsg added in v0.9.0 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*ClientStatsPayload) XXX_DiscardUnknown added in v0.9.0 

func (m *ClientStatsPayload) XXX_DiscardUnknown()

func (*ClientStatsPayload) XXX_Marshal added in v0.9.0 

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

func (*ClientStatsPayload) XXX_Merge added in v0.9.0 

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

func (*ClientStatsPayload) XXX_Size added in v0.9.0 

func (m *ClientStatsPayload) XXX_Size() int

func (*ClientStatsPayload) XXX_Unmarshal added in v0.9.0 

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

Span specifies the common Datadog API and trace agent span.

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

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

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

UnmarshalMsg implements msgp.Unmarshaler

func (*Span) UnmarshalMsgDictionary added in v0.9.0 

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

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

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

DecodeMsg implements msgp.Decodable

func (*StatsPayload) Descriptor added in v0.9.0 

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

func (*StatsPayload) EncodeMsg added in v0.9.0 

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

EncodeMsg implements msgp.Encodable

func (*StatsPayload) GetAgentEnv added in v0.9.0 

func (m *StatsPayload) GetAgentEnv() string

func (*StatsPayload) GetAgentHostname added in v0.9.0 

func (m *StatsPayload) GetAgentHostname() string

func (*StatsPayload) GetAgentVersion added in v0.9.0 

func (m *StatsPayload) GetAgentVersion() string

func (*StatsPayload) GetClientComputed added in v0.9.0 

func (m *StatsPayload) GetClientComputed() bool

func (*StatsPayload) GetStats added in v0.9.0 

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

func (*StatsPayload) Marshal added in v0.9.0 

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

func (*StatsPayload) MarshalMsg added in v0.9.0 

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

MarshalMsg implements msgp.Marshaler

func (*StatsPayload) MarshalTo added in v0.9.0 

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

func (*StatsPayload) Msgsize added in v0.9.0 

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

func (*StatsPayload) ProtoMessage()

func (*StatsPayload) Reset added in v0.9.0 

func (m *StatsPayload) Reset()

func (*StatsPayload) Size added in v0.9.0 

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

func (*StatsPayload) String added in v0.9.0 

func (m *StatsPayload) String() string

func (*StatsPayload) Unmarshal added in v0.9.0 

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

func (*StatsPayload) UnmarshalMsg added in v0.9.0 

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

UnmarshalMsg implements msgp.Unmarshaler

func (*StatsPayload) XXX_DiscardUnknown added in v0.9.0 

func (m *StatsPayload) XXX_DiscardUnknown()

func (*StatsPayload) XXX_Marshal added in v0.9.0 

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

func (*StatsPayload) XXX_Merge added in v0.9.0 

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

func (*StatsPayload) XXX_Size added in v0.9.0 

func (m *StatsPayload) XXX_Size() int

func (*StatsPayload) XXX_Unmarshal added in v0.9.0 

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

type TargetTPS added in v0.9.0 

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

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

DecodeMsg implements msgp.Decodable

func (*TargetTPS) Descriptor added in v0.9.0 

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

func (TargetTPS) EncodeMsg added in v0.9.0 

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

EncodeMsg implements msgp.Encodable

func (*TargetTPS) Marshal added in v0.9.0 

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

func (TargetTPS) MarshalMsg added in v0.9.0 

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

MarshalMsg implements msgp.Marshaler

func (*TargetTPS) MarshalTo added in v0.9.0 

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

func (TargetTPS) Msgsize added in v0.9.0 

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

func (*TargetTPS) ProtoMessage()

func (*TargetTPS) Reset added in v0.9.0 

func (m *TargetTPS) Reset()

func (*TargetTPS) Size added in v0.9.0 

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

func (*TargetTPS) String added in v0.9.0 

func (m *TargetTPS) String() string

func (*TargetTPS) Unmarshal added in v0.9.0 

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

func (*TargetTPS) UnmarshalMsg added in v0.9.0 

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

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

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

UnmarshalMsg implements msgp.Unmarshaler

type TracePayload 

type TracePayload struct {
	HostName     string      `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"`
	Env          string      `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
	Traces       []*APITrace `protobuf:"bytes,3,rep,name=traces" json:"traces,omitempty"`
	Transactions []*Span     `protobuf:"bytes,4,rep,name=transactions" json:"transactions,omitempty"`
}

func (*TracePayload) Descriptor 

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

func (*TracePayload) GetTraces 

func (m *TracePayload) GetTraces() []*APITrace

func (*TracePayload) GetTransactions 

func (m *TracePayload) GetTransactions() []*Span

func (*TracePayload) Marshal 

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

func (*TracePayload) MarshalTo 

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

func (*TracePayload) ProtoMessage 

func (*TracePayload) ProtoMessage()

func (*TracePayload) Reset 

func (m *TracePayload) Reset()

func (*TracePayload) Size 

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

func (*TracePayload) String 

func (m *TracePayload) String() string

func (*TracePayload) Unmarshal 

func (m *TracePayload) Unmarshal(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 added in v0.9.0 

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

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

UnmarshalMsg implements msgp.Unmarshaler

func (*Traces) UnmarshalMsgDictionary added in v0.9.0 

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