utils

Documentation

Index

• Variables
• func CreateClient(apiKey string, endpoint string) *datadog.Client
• func NewHTTPClient(settings exporterhelper.TimeoutSettings, insecureSkipVerify bool) *http.Client
• func SetDDHeaders(reqHeader http.Header, buildInfo component.BuildInfo, apiKey string)
• func SetExtraHeaders(h http.Header, extras map[string]string)
• func UserAgent(buildInfo component.BuildInfo) string
• func ValidateAPIKey(logger *zap.Logger, client *datadog.Client) error
• type Retrier
  • func NewRetrier(logger *zap.Logger, settings exporterhelper.RetrySettings, ...) *Retrier
  • func (r *Retrier) DoWithRetries(ctx context.Context, fn func(context.Context) error) error

Variables

var (
	// JSONHeaders headers for JSON requests.
	JSONHeaders = map[string]string{
		"Content-Type":     "application/json",
		"Content-Encoding": "gzip",
	}
	// ProtobufHeaders headers for protobuf requests.
	ProtobufHeaders = map[string]string{
		"Content-Type":     "application/x-protobuf",
		"Content-Encoding": "identity",
	}
)

var ErrInvalidAPI = errors.New("API Key validation failed")

Functions

func CreateClient

func CreateClient(apiKey string, endpoint string) *datadog.Client

CreateClient creates a new Datadog client

func NewHTTPClient

func NewHTTPClient(settings exporterhelper.TimeoutSettings, insecureSkipVerify bool) *http.Client

NewHTTPClient returns a http.Client configured with the Agent options.

func SetDDHeaders

func SetDDHeaders(reqHeader http.Header, buildInfo component.BuildInfo, apiKey string)

SetDDHeaders sets the Datadog-specific headers

func SetExtraHeaders

func SetExtraHeaders(h http.Header, extras map[string]string)

SetExtraHeaders appends a header map to HTTP headers.

func UserAgent

func UserAgent(buildInfo component.BuildInfo) string

func ValidateAPIKey

func ValidateAPIKey(logger *zap.Logger, client *datadog.Client) error

ValidateAPIKey checks that the provided client was given a correct API key.

Types

type Retrier

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

func NewRetrier

func NewRetrier(logger *zap.Logger, settings exporterhelper.RetrySettings, scrubber scrub.Scrubber) *Retrier

func (*Retrier) DoWithRetries

func (r *Retrier) DoWithRetries(ctx context.Context, fn func(context.Context) error) error

DoWithRetries does a function with retries. This is a condensed version of the code on the exporterhelper, which we reuse here since we want custom retry logic.