pb

package

v0.0.0-...-e57142c Latest Latest Go to latest Published: Jan 14, 2019 License: BSD-3-Clause Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

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 model is a generated protocol buffer package.

It is generated from these files:
	span.proto
	trace.proto
	trace_payload.proto

It has these top-level messages:
	Span
	APITrace
	TracePayload

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 (
	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 ServicesMetadata ¶

type ServicesMetadata map[string]map[string]string

ServicesMetadata is a standard key/val meta map attached to each named service

func (*ServicesMetadata) DecodeMsg ¶

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

DecodeMsg implements msgp.Decodable

func (ServicesMetadata) EncodeMsg ¶

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

EncodeMsg implements msgp.Encodable

func (ServicesMetadata) Msgsize ¶

func (z ServicesMetadata) Msgsize() (s int)

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

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) DecodeMsg ¶

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

DecodeMsg implements msgp.Decodable

func (*Span) Descriptor ¶

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

func (*Span) EncodeMsg ¶

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

EncodeMsg implements msgp.Encodable

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

type Trace ¶

type Trace []*Span

Trace is a collection of spans with the same trace ID

func (*Trace) DecodeMsg ¶

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

DecodeMsg implements msgp.Decodable

func (Trace) EncodeMsg ¶

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

EncodeMsg implements msgp.Encodable

func (Trace) Msgsize ¶

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

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) DecodeMsg ¶

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

DecodeMsg implements msgp.Decodable

func (Traces) EncodeMsg ¶

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

EncodeMsg implements msgp.Encodable

func (Traces) Msgsize ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL