Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnvAccessorCtor ¶
func EnvAccessorCtor() pkgadapter.EnvConfigAccessor
EnvAccessorCtor for configuration parameters
func NewAdapter ¶
func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ceClient cloudevents.Client) pkgadapter.Adapter
NewAdapter returns adapter implementation
Types ¶
type SourceDeliveryConfig ¶
type SourceDeliveryConfig struct {
DeadLetterQManager string `envconfig:"DEAD_LETTER_QUEUE_MANAGER"`
DeadLetterQueue string `envconfig:"DEAD_LETTER_QUEUE"`
BackoffDelay int `envconfig:"BACKOFF_DELAY"`
Retry int `envconfig:"DELIVERY_RETRY"`
}
SourceDeliveryConfig holds the delivery parameters used in the source.
type SourceEnvAccessor ¶
type SourceEnvAccessor struct {
pkgadapter.EnvConfig
mq.EnvConnectionConfig
SourceDeliveryConfig
// BridgeIdentifier is the name of the bridge workflow this source is part of
BridgeIdentifier string `envconfig:"EVENTS_BRIDGE_IDENTIFIER"`
}
SourceEnvAccessor is the set of parameters parsed from the adapter's env.
func (*SourceEnvAccessor) Delivery ¶
func (e *SourceEnvAccessor) Delivery() *mq.Delivery
Delivery returns the MQ delivery parameters.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.