pb

package
Version: v0.0.0-...-4e92ac7 Latest Latest
Warning

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

Go to latest
Published: Sep 17, 2021 License: Apache-2.0 Imports: 10 Imported by: 3

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

Index

Constants

This section is empty.

Variables

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

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

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

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

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
t or T : Toggle theme light dark auto
y or Y : Canonical URL