Versions in this module Expand all Collapse all v0 v0.2.1 Feb 22, 2026 v0.2.0 Feb 19, 2026 Changes in this version + type Client struct + func New(awsCfg *aws.Config, queueName string, logger types.Logger, opts ...Option) *Client + func (c *Client) Init(ctx context.Context) (*Client, error) + func (c *Client) Name() string + func (c *Client) Receive(ctx context.Context, sinkCh chan<- *types.FifoQueueItem) error + func (c *Client) Send(ctx context.Context, groupID, dedupID, body string) error + type Option func(*Options) + func WithMaxMessageExtension(d time.Duration) Option + func WithMaxOutstandingBytes(n int) Option + func WithMaxOutstandingMessages(n int) Option + func WithSQSClient(client sqsClient) Option + func WithSqsAPIMaxRetryAttempts(n int) Option + func WithSqsAPIMaxRetryBackoffDelay(d time.Duration) Option + func WithSqsReceiveMaxNumberOfMessages(n int32) Option + func WithSqsReceiveWaitTimeSeconds(seconds int32) Option + func WithSqsVisibilityTimeout(seconds int32) Option + type Options struct + type WebhookHandler struct + func NewWebhookHandler(awsCfg *aws.Config) *WebhookHandler + func (c *WebhookHandler) HandleWebhook(ctx context.Context, queueURL string, data *types.WebhookCallback, ...) error + func (c *WebhookHandler) Init(_ context.Context) (*WebhookHandler, error) + func (c *WebhookHandler) ShouldHandleWebhook(_ context.Context, target string) bool
Go to main page