datadog

Documentation

Index

• Constants
• type DDMetric
• type DatadogMetricSink
  • func NewDatadogMetricSink(interval float64, flushMaxPerBody int, hostname string, tags []string, ...) (*DatadogMetricSink, error)
  • func (dd *DatadogMetricSink) Flush(ctx context.Context, interMetrics []samplers.InterMetric) error
  • func (dd *DatadogMetricSink) FlushEventsChecks(ctx context.Context, events []samplers.UDPEvent, ...)
  • func (dd *DatadogMetricSink) Name() string
  • func (dd *DatadogMetricSink) Start(cl *trace.Client) error
• type DatadogSpanSink
  • func NewDatadogSpanSink(address string, bufferSize int, stats *statsd.Client, httpClient *http.Client, ...) (*DatadogSpanSink, error)
  • func (dd *DatadogSpanSink) Flush()
  • func (dd *DatadogSpanSink) Ingest(span *ssf.SSFSpan) error
  • func (dd *DatadogSpanSink) Name() string
  • func (dd *DatadogSpanSink) Start(cl *trace.Client) error
• type DatadogTraceSpan

Constants

const DatadogResourceKey = "resource"

Types

type DDMetric

type DDMetric struct {
	Name       string        `json:"metric"`
	Value      [1][2]float64 `json:"points"`
	Tags       []string      `json:"tags,omitempty"`
	MetricType string        `json:"type"`
	Hostname   string        `json:"host,omitempty"`
	DeviceName string        `json:"device_name,omitempty"`
	Interval   int32         `json:"interval,omitempty"`
}

DDMetric is a data structure that represents the JSON that Datadog wants when posting to the API

type DatadogMetricSink

type DatadogMetricSink struct {
	HTTPClient *http.Client
	APIKey     string
	DDHostname string
	// contains filtered or unexported fields
}

func NewDatadogMetricSink

func NewDatadogMetricSink(interval float64, flushMaxPerBody int, hostname string, tags []string, ddHostname string, apiKey string, httpClient *http.Client, stats *statsd.Client, log *logrus.Logger) (*DatadogMetricSink, error)

NewDatadogMetricSink creates a new Datadog sink for trace spans.

func (*DatadogMetricSink) Flush

func (dd *DatadogMetricSink) Flush(ctx context.Context, interMetrics []samplers.InterMetric) error

func (*DatadogMetricSink) FlushEventsChecks

func (dd *DatadogMetricSink) FlushEventsChecks(ctx context.Context, events []samplers.UDPEvent, checks []samplers.UDPServiceCheck)

func (*DatadogMetricSink) Name

func (dd *DatadogMetricSink) Name() string

Name returns the name of this sink.

func (*DatadogMetricSink) Start

func (dd *DatadogMetricSink) Start(cl *trace.Client) error

Start sets the sink up.

type DatadogSpanSink

type DatadogSpanSink struct {
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

DatadogSpanSink is a sink for sending spans to a Datadog trace agent.

func NewDatadogSpanSink

func NewDatadogSpanSink(address string, bufferSize int, stats *statsd.Client, httpClient *http.Client, commonTags map[string]string, log *logrus.Logger) (*DatadogSpanSink, error)

NewDatadogSpanSink creates a new Datadog sink for trace spans.

func (*DatadogSpanSink) Flush

func (dd *DatadogSpanSink) Flush()

Flush signals the sink to send it's spans to their destination. For this sync it means we'll be making an HTTP request to send them along. We assume it's beneficial to performance to defer these until the normal 10s flush.

func (*DatadogSpanSink) Ingest

func (dd *DatadogSpanSink) Ingest(span *ssf.SSFSpan) error

Ingest takes the span and adds it to the ringbuffer.

func (*DatadogSpanSink) Name

func (dd *DatadogSpanSink) Name() string

Name returns the name of this sink.

func (*DatadogSpanSink) Start

func (dd *DatadogSpanSink) Start(cl *trace.Client) error

Start performs final adjustments on the sink.

type DatadogTraceSpan

type DatadogTraceSpan struct {
	Duration int64              `json:"duration"`
	Error    int64              `json:"error"`
	Meta     map[string]string  `json:"meta"`
	Metrics  map[string]float64 `json:"metrics"`
	Name     string             `json:"name"`
	ParentID int64              `json:"parent_id,omitempty"`
	Resource string             `json:"resource,omitempty"`
	Service  string             `json:"service"`
	SpanID   int64              `json:"span_id"`
	Start    int64              `json:"start"`
	TraceID  int64              `json:"trace_id"`
	Type     string             `json:"type"`
}

DatadogTraceSpan represents a trace span as JSON for the Datadog tracing API.