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 DestAWSKinesisConfig ¶
type DestAWSKinesisConfig struct {
MetadataInPayload bool
}
type DestWebhookConfig ¶
type DestWebhookConfig struct {
Mode string
ProxyURL string
HeaderPrefix string
EventIDHeader WebhookHeaderConfig
SignatureHeader WebhookHeaderConfig
TimestampHeader WebhookHeaderConfig
TopicHeader WebhookHeaderConfig
SignatureContentTemplate string
SignatureHeaderTemplate string
SignatureEncoding string
SignatureAlgorithm string
SigningSecretTemplate string
MaxResponseBodyBytes int
}
type RegisterDefaultDestinationOptions ¶
type RegisterDefaultDestinationOptions struct {
UserAgent string
IncludeMillisecondTimestamp bool
Webhook *DestWebhookConfig
AWSKinesis *DestAWSKinesisConfig
// 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
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".
Click to show internal directories.
Click to hide internal directories.