datadog

Documentation

Index

• Constants
• func InitializeMetricClient(mp metric.MeterProvider, source string) statsd.ClientInterface
• type Ingester
• type TraceAgent
  • func NewAgent(ctx context.Context, out chan *pb.StatsPayload, ...) *TraceAgent
  • func NewAgentWithConfig(ctx context.Context, cfg *traceconfig.AgentConfig, out chan *pb.StatsPayload, ...) *TraceAgent
  • func (p *TraceAgent) Ingest(ctx context.Context, traces ptrace.Traces)
  • func (p *TraceAgent) Start()
  • func (p *TraceAgent) Stop()

Constants

const (
	ExporterSourceTag  = "datadogexporter"
	ConnectorSourceTag = "datadogconnector"
)

Functions

func InitializeMetricClient

func InitializeMetricClient(mp metric.MeterProvider, source string) statsd.ClientInterface

InitializeMetricClient using a meter provider.

Types

type Ingester

type Ingester interface {
	// Start starts the ingester.
	Start()

	// Ingest ingests the set of traces.
	Ingest(ctx context.Context, traces ptrace.Traces)

	// Stop stops the ingester.
	Stop()
}

An Ingester is able to ingest traces. Implemented by traceagent.

type TraceAgent

type TraceAgent struct {
	*agent.Agent
	// contains filtered or unexported fields
}

TraceAgent specifies a minimal trace agent instance that is able to process traces and output stats.

func NewAgent

func NewAgent(ctx context.Context, out chan *pb.StatsPayload, metricsClient statsd.ClientInterface, timingReporter timing.Reporter) *TraceAgent

newAgent creates a new unstarted traceagent using the given context. Call Start to start the traceagent. The out channel will receive outoing stats payloads resulting from spans ingested using the Ingest method.

func NewAgentWithConfig

func NewAgentWithConfig(ctx context.Context, cfg *traceconfig.AgentConfig, out chan *pb.StatsPayload, metricsClient statsd.ClientInterface, timingReporter timing.Reporter) *TraceAgent

newAgentWithConfig creates a new traceagent with the given config cfg. Used in tests; use newAgent instead.

func (*TraceAgent) Ingest

func (p *TraceAgent) Ingest(ctx context.Context, traces ptrace.Traces)

Ingest processes the given spans within the traceagent and outputs stats through the output channel provided to newAgent. Do not call Ingest on an unstarted or stopped traceagent.

func (*TraceAgent) Start

func (p *TraceAgent) Start()

Start starts the traceagent, making it ready to ingest spans.

func (*TraceAgent) Stop

func (p *TraceAgent) Stop()

Stop stops the traceagent, making it unable to ingest spans. Do not call Ingest after Stop.