Documentation
¶
Overview ¶
Package sqs is a thin wrapper over the AWS SQS SDK for the consumers that poll a queue (currently the inbound-email bridge). It exposes long-poll receive + delete and nothing else.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client wraps the AWS SQS SDK client bound to a single queue URL.
func NewClient ¶
NewClient creates an SQS client for the given region, bound to queueURL.
IMDS is disabled for the same reason as the S3 client: pods get credentials via IRSA (or static keys in dev), never the node instance role, and leaving IMDS in the chain blocks credential resolution for the full deadline on every call.
type Message ¶
Message is a received SQS message: its body plus the receipt handle needed to delete it.
type Queue ¶
type Queue interface {
Receive(ctx context.Context, maxMessages, waitSeconds int32) ([]Message, *apierror.APIError)
Delete(ctx context.Context, receiptHandle string) *apierror.APIError
}
Queue defines the SQS operations the consumers need. An interface so consumers can be unit-tested against a fake.
Source Files