datadogreceiver

README

chqdatadog receiver

This is a fork of the standard datadog receiver to make it easier to use in a multi-pod environment as well as ensure that the incoming telemtry is converted to semantic OTEL attributes.

This may eventually be submitted as a change request. Documentation on this component is limited as its primary use case is intended to be in the Cardinal collector ecosystem.

Documentation

Index

• Constants
• func NewFactory() receiver.Factory
• type Config
  • func (cfg *Config) Validate() error
• type DDError
• type DDErrorWrapper
• type DDLog
• type Message
• type MetricsPayloadV1
• type SeriesV1

Constants

const (
	GoFatalError    = "fatal error:"
	GoPanic         = "panic:"
	PythonTraceBack = "Traceback "
)

Functions

func NewFactory

func NewFactory() receiver.Factory

NewFactory creates a factory for DataDog receiver.

Types

type Config

type Config struct {
	confighttp.ServerConfig `mapstructure:",squash"`
	// ReadTimeout of the http server
	ReadTimeout       time.Duration `mapstructure:"read_timeout"`
	TagcacheExtension *component.ID `mapstructure:"tagcache_extension"`
}

func (*Config) Validate

func (cfg *Config) Validate() error

Validate checks the receiver configuration is valid

type DDError

type DDError struct {
	Detail string `json:"detail"`
	Status string `json:"status"`
	Title  string `json:"title"`
}

type DDErrorWrapper

type DDErrorWrapper struct {
	Errors []DDError `json:"errors"`
}

type DDLog

type DDLog struct {
	DDSource string `json:"ddsource,omitempty"`
	DDTags   string `json:"ddtags,omitempty"`
	Message  string `json:"message,omitempty"`
	Hostname string `json:"hostname,omitempty"`
	Service  string `json:"service,omitempty"`
}

type Message

type Message struct {
	Timestamp pcommon.Timestamp
	Body      string
}

type MetricsPayloadV1

type MetricsPayloadV1 struct {
	Series []SeriesV1 `json:"series"`
}

MetricsPayloadV1 is for the /api/v1/series endpoint.

type SeriesV1

type SeriesV1 struct {
	Host     *string                    `json:"host,omitempty"`
	Interval *int64                     `json:"interval,omitempty"`
	Metric   string                     `json:"metric"`
	Points   []tuple.T2[int64, float64] `json:"points"`
	Tags     []string                   `json:"tags,omitempty"`
	Type     *string                    `json:"type,omitempty"`
}

SeriesV1 is for the /api/v1/series endpoint.