sqs

Feb 14, 2023

Changes in this version

+ func WithBatchDeduplicationID(applier func(int) string) withBatchDeduplicationID

+ func WithBatchMessageAttribute(key string, applier func(int) *types.MessageAttributeValue) withBatchMessageAttribute

+ func WithBatchMessageGroupID(applier func(int) string) withBatchMessageGroupID

type SQSConnection

+ func (conn *SQSConnection) SendMessages(ctx context.Context, url string, items []any, ...) (*sqs.SendMessageBatchOutput, error)

+ type SQSOption interface

+ Apply func(*SQSConnection)

+ type SendMessageBatchOption interface

+ ApplyBatch func(int, *types.SendMessageBatchRequestEntry)

+ type WithSendMessagesBatchSize int

+ func (w WithSendMessagesBatchSize) Apply(sqs *SQSConnection)

Feb 13, 2023

Changes in this version

+ type SQSAPI interface

+ AddPermission func(ctx context.Context, params *sqs.AddPermissionInput, ...) (*sqs.AddPermissionOutput, error)

+ ChangeMessageVisibility func(ctx context.Context, params *sqs.ChangeMessageVisibilityInput, ...) (*sqs.ChangeMessageVisibilityOutput, error)

+ ChangeMessageVisibilityBatch func(ctx context.Context, params *sqs.ChangeMessageVisibilityBatchInput, ...) (*sqs.ChangeMessageVisibilityBatchOutput, error)

+ CreateQueue func(ctx context.Context, params *sqs.CreateQueueInput, ...) (*sqs.CreateQueueOutput, error)

+ DeleteMessage func(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)

+ DeleteMessageBatch func(ctx context.Context, params *sqs.DeleteMessageBatchInput, ...) (*sqs.DeleteMessageBatchOutput, error)

+ DeleteQueue func(ctx context.Context, params *sqs.DeleteQueueInput, ...) (*sqs.DeleteQueueOutput, error)

+ GetQueueAttributes func(ctx context.Context, params *sqs.GetQueueAttributesInput, ...) (*sqs.GetQueueAttributesOutput, error)

+ GetQueueUrl func(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error)

+ ListDeadLetterSourceQueues func(ctx context.Context, params *sqs.ListDeadLetterSourceQueuesInput, ...) (*sqs.ListDeadLetterSourceQueuesOutput, error)

+ ListQueueTags func(ctx context.Context, params *sqs.ListQueueTagsInput, ...) (*sqs.ListQueueTagsOutput, error)

+ ListQueues func(ctx context.Context, params *sqs.ListQueuesInput, optFns ...func(*sqs.Options)) (*sqs.ListQueuesOutput, error)

+ PurgeQueue func(ctx context.Context, params *sqs.PurgeQueueInput, optFns ...func(*sqs.Options)) (*sqs.PurgeQueueOutput, error)

+ ReceiveMessage func(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error)

+ RemovePermission func(ctx context.Context, params *sqs.RemovePermissionInput, ...) (*sqs.RemovePermissionOutput, error)

+ SendMessage func(ctx context.Context, params *sqs.SendMessageInput, ...) (*sqs.SendMessageOutput, error)

+ SendMessageBatch func(ctx context.Context, params *sqs.SendMessageBatchInput, ...) (*sqs.SendMessageBatchOutput, error)

+ SetQueueAttributes func(ctx context.Context, params *sqs.SetQueueAttributesInput, ...) (*sqs.SetQueueAttributesOutput, error)

+ TagQueue func(ctx context.Context, params *sqs.TagQueueInput, optFns ...func(*sqs.Options)) (*sqs.TagQueueOutput, error)

+ UntagQueue func(ctx context.Context, params *sqs.UntagQueueInput, optFns ...func(*sqs.Options)) (*sqs.UntagQueueOutput, error)

Feb 13, 2023

Changes in this version

+ func WithMessageAttribute(key string, attr *types.MessageAttributeValue) withMessageAttribute

+ type GetQueueUrlOption interface

+ Apply func(*sqs.GetQueueUrlInput)

+ type SQSConnection struct

+ func FromClient(inner *sqs.Client, logger *utils.Logger) *SQSConnection

+ func NewSQSConnection(cfg aws.Config, logger *utils.Logger) *SQSConnection

+ func (conn *SQSConnection) GetURL(ctx context.Context, queueName string, options ...GetQueueUrlOption) (string, error)

+ func (conn *SQSConnection) SendMessage(ctx context.Context, url string, item any, options ...SendMessageOption) (*sqs.SendMessageOutput, error)

+ type SendMessageOption interface

+ Apply func(*sqs.SendMessageInput)

+ type WithAWSAccountID string

+ func (w WithAWSAccountID) Apply(input *sqs.GetQueueUrlInput)

+ type WithDeduplicationID string

+ func (w WithDeduplicationID) Apply(input *sqs.SendMessageInput)

+ type WithMessageGroupID string

+ func (w WithMessageGroupID) Apply(input *sqs.SendMessageInput)