datadog

Documentation

Index

• Constants
• Variables
• func New(lgr log.Logger, registry metrics.Registry, cp coordinator.Coordinator, ...) providers.Provider
• func NewSink(cfg *DatadogDestination, logger log.Logger, registry metrics.Registry) (abstract.Sinker, error)
• type DatadogDestination
  • func (d *DatadogDestination) CleanupMode() model.CleanupType
  • func (d *DatadogDestination) Compatible(src model.Source, transferType abstract.TransferType) error
  • func (d *DatadogDestination) GetProviderType() abstract.ProviderType
  • func (d *DatadogDestination) IsDestination()
  • func (d *DatadogDestination) Validate() error
  • func (d *DatadogDestination) WithDefaults()
• type Provider
  • func (p Provider) Sink(config middlewares.Config) (abstract.Sinker, error)
  • func (p Provider) Type() abstract.ProviderType
• type Sink
  • func (s *Sink) Close() error
  • func (s *Sink) Push(items []abstract.ChangeItem) error

Constants

const ProviderType = abstract.ProviderType("datadog")

Variables

var (
	FatalErrors = set.New("403 Forbidden")
)

Functions

func New

func New(lgr log.Logger, registry metrics.Registry, cp coordinator.Coordinator, transfer *model.Transfer) providers.Provider

func NewSink

func NewSink(cfg *DatadogDestination, logger log.Logger, registry metrics.Registry) (abstract.Sinker, error)

Types

type DatadogDestination

type DatadogDestination struct {
	ClientAPIKey model.SecretString
	DatadogHost  string

	// mapping to columns
	SourceColumn    string
	TagColumns      []string
	HostColumn      string
	ServiceColumn   string
	MessageTemplate string
	ChunkSize       int
}

func (*DatadogDestination) CleanupMode

func (d *DatadogDestination) CleanupMode() model.CleanupType

func (*DatadogDestination) Compatible

func (d *DatadogDestination) Compatible(src model.Source, transferType abstract.TransferType) error

func (*DatadogDestination) GetProviderType

func (d *DatadogDestination) GetProviderType() abstract.ProviderType

func (*DatadogDestination) IsDestination

func (d *DatadogDestination) IsDestination()

func (*DatadogDestination) Validate

func (d *DatadogDestination) Validate() error

func (*DatadogDestination) WithDefaults

func (d *DatadogDestination) WithDefaults()

type Provider

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

func (Provider) Sink

func (p Provider) Sink(config middlewares.Config) (abstract.Sinker, error)

func (Provider) Type

func (p Provider) Type() abstract.ProviderType

type Sink

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

func (*Sink) Close

func (s *Sink) Close() error

func (*Sink) Push

func (s *Sink) Push(items []abstract.ChangeItem) error