destregistrydefault

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 2, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDefault

func RegisterDefault(registry destregistry.Registry, opts RegisterDefaultDestinationOptions) error

RegisterDefault registers the default destination providers with the registry. NOTE: The order of registration will determine the order of the provider array returned when listing providers.

Types

type DestAWSEventBridgeConfig added in v1.6.0

type DestAWSEventBridgeConfig struct {
	Source string
}

type DestAWSKinesisConfig

type DestAWSKinesisConfig struct {
	MetadataInPayload bool
}

type DestWebhookConfig

type DestWebhookConfig struct {
	// MetadataName selects the metadata/providers entry describing the
	// provider; empty means "webhook".
	MetadataName             string
	ProxyURL                 string
	HeaderPrefix             string
	EventIDHeader            WebhookHeaderConfig
	SignatureHeader          WebhookHeaderConfig
	TimestampHeader          WebhookHeaderConfig
	TopicHeader              WebhookHeaderConfig
	TimestampFormat          string
	SignatureContentTemplate string
	SignatureHeaderTemplate  string
	SignatureEncoding        string
	SignatureAlgorithm       string
	SigningSecretTemplate    string
	MaxResponseBodyBytes     int
	SignatureSecretEncoding  string
	SignatureSecretPrefix    string
	Compat                   *destwebhook.CompatSignatureConfig
}

type RegisterDefaultDestinationOptions

type RegisterDefaultDestinationOptions struct {
	UserAgent                   string
	IncludeMillisecondTimestamp bool
	// ProxyURL is the forward proxy chain for RabbitMQ and Kafka. Webhooks
	// use Webhook.ProxyURL only; the config layer resolves its fallback to
	// this value.
	ProxyURL       string
	Webhook        *DestWebhookConfig
	AWSKinesis     *DestAWSKinesisConfig
	AWSEventBridge *DestAWSEventBridgeConfig

	// DeliveryMaxConcurrency is the delivery worker pool size. It bounds how
	// many deliveries can be in flight, and therefore how many connections a
	// single destination could need. 0 leaves Go's per-host default in place.
	DeliveryMaxConcurrency int
}

type WebhookHeaderConfig added in v1.1.0

type WebhookHeaderConfig struct {
	Name     string
	Disabled bool
}

WebhookHeaderConfig is the resolved directive for a single webhook system header. The config layer collapses the three-state name config (and the deprecated DISABLE_* flag) into this: an empty Name with Disabled false means "use the default '<prefix>' + key".

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL