api

Documentation

Index

• func AttachEndpoint(e Endpoint)
• func NewMeasuredListener(ln net.Listener, name string) net.Listener
• type Cache
  • func NewCache(gcInterval time.Duration) *Cache
  • func (c *Cache) Get(currentTime time.Time, key string, cacheValidity time.Duration) (interface{}, bool, error)
  • func (c *Cache) Store(currentTime time.Time, key string, value interface{}, err error)
• type Endpoint
• type HTTPReceiver
  • func NewHTTPReceiver(conf *config.AgentConfig, dynConf *sampler.DynamicConfig, out chan *Payload, ...) *HTTPReceiver
  • func (r *HTTPReceiver) Languages() string
  • func (r *HTTPReceiver) Start()
  • func (r *HTTPReceiver) Stop() error
  • func (r *HTTPReceiver) TagStats(v Version, header http.Header) *info.TagStats
• type IDProvider
  • func NewIDProvider(procRoot string) IDProvider
• type OTLPReceiver
  • func NewOTLPReceiver(out chan<- *Payload, cfg *config.AgentConfig) *OTLPReceiver
  • func (o *OTLPReceiver) Export(ctx context.Context, in ptraceotlp.Request) (ptraceotlp.Response, error)
  • func (o *OTLPReceiver) ReceiveResourceSpans(ctx context.Context, rspans ptrace.ResourceSpans, header http.Header, ...) source.Source
  • func (o *OTLPReceiver) ServeHTTP(w http.ResponseWriter, req *http.Request)
  • func (o *OTLPReceiver) Start()
  • func (o *OTLPReceiver) Stop()
• type Payload
  • func (p *Payload) Chunk(i int) *pb.TraceChunk
  • func (p *Payload) Chunks() []*pb.TraceChunk
  • func (p *Payload) RemoveChunk(i int)
  • func (p *Payload) ReplaceChunk(i int, chunk *pb.TraceChunk)
• type StatsProcessor
• type Version

Functions

func AttachEndpoint

func AttachEndpoint(e Endpoint)

AttachEndpoint attaches an additional endpoint to the trace-agent. It is not thread-safe and should be called before (pkg/trace.*Agent).Run or (*HTTPReceiver).Start. In other words, endpoint setup must be final before the agent or HTTP receiver starts.

func NewMeasuredListener

func NewMeasuredListener(ln net.Listener, name string) net.Listener

NewMeasuredListener wraps ln and emits metrics every 10 seconds. The metric name is datadog.trace_agent.receiver.<name>. Additionally, a "status" tag will be added with potential values "accepted", "timedout" or "errored".

Types

type Cache

type Cache struct {
	// contains filtered or unexported fields
}

Cache provides a caching mechanism based on staleness toleration provided by requestor

func NewCache

func NewCache(gcInterval time.Duration) *Cache

NewCache returns a new cache dedicated to a collector

func (*Cache) Get

func (c *Cache) Get(currentTime time.Time, key string, cacheValidity time.Duration) (interface{}, bool, error)

Get retrieves data from cache, returns not found if cacheValidity == 0

func (*Cache) Store

func (c *Cache) Store(currentTime time.Time, key string, value interface{}, err error)

Store sets data in the cache, it also clears the cache if the gcInterval has passed

type Endpoint

type Endpoint struct {
	// Pattern specifies the API pattern, as registered by the HTTP handler.
	Pattern string

	// Handler specifies the http.Handler for this endpoint.
	Handler func(*HTTPReceiver) http.Handler

	// Hidden reports whether this endpoint should be hidden in the /info
	// discovery endpoint.
	Hidden bool

	// IsEnabled specifies a function which reports whether this endpoint should be enabled
	// based on the given config conf.
	IsEnabled func(conf *config.AgentConfig) bool
}

Endpoint specifies an API endpoint definition.

type HTTPReceiver

type HTTPReceiver struct {
	Stats       *info.ReceiverStats
	RateLimiter *rateLimiter
	// contains filtered or unexported fields
}

HTTPReceiver is a collector that uses HTTP protocol and just holds a chan where the spans received are sent one by one

func NewHTTPReceiver

func NewHTTPReceiver(conf *config.AgentConfig, dynConf *sampler.DynamicConfig, out chan *Payload, statsProcessor StatsProcessor) *HTTPReceiver

NewHTTPReceiver returns a pointer to a new HTTPReceiver

func (*HTTPReceiver) Languages

func (r *HTTPReceiver) Languages() string

Languages returns the list of the languages used in the traces the agent receives.

func (*HTTPReceiver) Start

func (r *HTTPReceiver) Start()

Start starts doing the HTTP server and is ready to receive traces

func (*HTTPReceiver) Stop

func (r *HTTPReceiver) Stop() error

Stop stops the receiver and shuts down the HTTP server.

func (*HTTPReceiver) TagStats

func (r *HTTPReceiver) TagStats(v Version, header http.Header) *info.TagStats

TagStats returns the stats and tags coinciding with the information found in header. For more information, check the "Datadog-Meta-*" HTTP headers defined in this file.

type IDProvider

type IDProvider interface {
	GetContainerID(context.Context, http.Header) string
}

IDProvider implementations are able to look up a container ID given a ctx and http header.

func NewIDProvider

func NewIDProvider(procRoot string) IDProvider

NewIDProvider initializes an IDProvider instance using the provided procRoot to perform cgroups lookups in linux environments.

type OTLPReceiver

type OTLPReceiver struct {
	// contains filtered or unexported fields
}

OTLPReceiver implements an OpenTelemetry Collector receiver which accepts incoming data on two ports for both plain HTTP and gRPC.

func NewOTLPReceiver

func NewOTLPReceiver(out chan<- *Payload, cfg *config.AgentConfig) *OTLPReceiver

NewOTLPReceiver returns a new OTLPReceiver which sends any incoming traces down the out channel.

func (*OTLPReceiver) Export

func (o *OTLPReceiver) Export(ctx context.Context, in ptraceotlp.Request) (ptraceotlp.Response, error)

Export implements ptraceotlp.Server

func (*OTLPReceiver) ReceiveResourceSpans

func (o *OTLPReceiver) ReceiveResourceSpans(ctx context.Context, rspans ptrace.ResourceSpans, header http.Header, protocol string) source.Source

ReceiveResourceSpans processes the given rspans and returns the source that it identified from processing them.

func (*OTLPReceiver) ServeHTTP

func (o *OTLPReceiver) ServeHTTP(w http.ResponseWriter, req *http.Request)

ServeHTTP implements http.Handler

func (*OTLPReceiver) Start

func (o *OTLPReceiver) Start()

Start starts the OTLPReceiver, if any of the servers were configured as active.

func (*OTLPReceiver) Stop

func (o *OTLPReceiver) Stop()

Stop stops any running server.

type Payload

type Payload struct {
	// Source specifies information about the source of these traces, such as:
	// language, interpreter, tracer version, etc.
	Source *info.TagStats

	// TracerPayload holds the incoming payload from the tracer.
	TracerPayload *pb.TracerPayload

	// ClientComputedTopLevel specifies that the client has already marked top-level
	// spans.
	ClientComputedTopLevel bool

	// ClientComputedStats reports whether the client has computed and sent over stats
	// so that the agent doesn't have to.
	ClientComputedStats bool

	// ClientDroppedP0s specifies the number of P0 traces chunks dropped by the client.
	ClientDroppedP0s int64
}

Payload specifies information about a set of traces received by the API.

func (*Payload) Chunk

func (p *Payload) Chunk(i int) *pb.TraceChunk

Chunk returns a chunk in TracerPayload by its index

func (*Payload) Chunks

func (p *Payload) Chunks() []*pb.TraceChunk

Chunks returns chunks in TracerPayload

func (*Payload) RemoveChunk

func (p *Payload) RemoveChunk(i int)

RemoveChunk removes a chunk in TracerPayload by its index

func (*Payload) ReplaceChunk

func (p *Payload) ReplaceChunk(i int, chunk *pb.TraceChunk)

ReplaceChunk replaces a chunk in TracerPayload at a given index

type StatsProcessor

type StatsProcessor interface {
	// ProcessStats takes a stats payload and consumes it. It is considered to be originating
	// from the given lang.
	ProcessStats(p pb.ClientStatsPayload, lang, tracerVersion string)
}

StatsProcessor implementations are able to process incoming client stats.

type Version

type Version string

Version is a dumb way to version our collector handlers

const (

	// V07 API
	//
	// Content-Type: application/msgpack
	// Payload: TracerPayload (pkg/trace/pb/tracer_payload.proto)
	// Response: Service sampling rates.
	//
	V07 Version = "v0.7"
)