datadog

Documentation

Index

• func GetProxyTransportFunc(proxy *Proxy, logger *gosteno.Logger) func(*http.Request) (*url.URL, error)
• type Client
  • func New(apiURL string, logIntakeURL string, apiKey string, prefix string, ...) *Client
  • func NewClients(config *config.Config, log *gosteno.Logger) ([]*Client, error)
  • func (c *Client) MakeInternalMetric(name, _type string, value uint64, timestamp int64) (metric.MetricKey, metric.MetricValue)
  • func (c *Client) PostLogs(logs []logs.LogMessage) uint64
  • func (c *Client) PostMetrics(metrics metric.MetricsMap) uint64
• type FormatData
• type Formatter
  • func (f Formatter) FormatLogs(maxPostBytes uint32, data []logs.LogMessage) []FormatData
  • func (f Formatter) FormatMetrics(prefix string, maxPostBytes uint32, ...) []FormatData
• type Payload
• type Proxy

Functions

func GetProxyTransportFunc

func GetProxyTransportFunc(proxy *Proxy, logger *gosteno.Logger) func(*http.Request) (*url.URL, error)

GetProxyTransportFunc manages the proxy configuration

Types

type Client

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

func New

func New(
	apiURL string,
	logIntakeURL string,
	apiKey string,
	prefix string,
	deployment string,
	ip string,
	writeTimeout time.Duration,
	flushDuration time.Duration,
	maxPostBytes uint32,
	logger *gosteno.Logger,
	customTags []string,
	proxy *Proxy,
) *Client

func NewClients

func NewClients(config *config.Config, log *gosteno.Logger) ([]*Client, error)

func (*Client) MakeInternalMetric

func (c *Client) MakeInternalMetric(name, _type string, value uint64, timestamp int64) (metric.MetricKey, metric.MetricValue)

MakeInternalMetric creates a metric with the provided name, value and timestamp

func (*Client) PostLogs

func (c *Client) PostLogs(logs []logs.LogMessage) uint64

PostLogs forwards the logs to datadog

func (*Client) PostMetrics

func (c *Client) PostMetrics(metrics metric.MetricsMap) uint64

PostMetrics forwards the metrics to datadog

type FormatData

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

type Formatter

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

func (Formatter) FormatLogs

func (f Formatter) FormatLogs(maxPostBytes uint32, data []logs.LogMessage) []FormatData

func (Formatter) FormatMetrics

func (f Formatter) FormatMetrics(prefix string, maxPostBytes uint32, data map[metric.MetricKey]metric.MetricValue) []FormatData

type Payload

type Payload struct {
	Series []metric.Series `json:"series"`
}

type Proxy

type Proxy struct {
	HTTP    string
	HTTPS   string
	NoProxy []string
}