Versions in this module Expand all Collapse all v4 v4.0.1 Aug 25, 2024 v4.0.0 Apr 20, 2024 Changes in this version + func BuildBatchRequestEntry(messages ...BatchMessage) ([]types.SendMessageBatchRequestEntry, map[string]int) + func GetQueueURL(ctx context.Context, s sqsiface.SQSAPI, name string) (*string, error) + func NewBatchError(id2index map[string]int, errors []types.BatchResultErrorEntry) error + type BatchChangeMessageVisibility struct + ReceiptHandle *string + VisibilityTimeout int32 + type BatchError struct + Code string + Index int + Message string + SenderFault bool + func IsBatchError(err error) (errors []*BatchError, ok bool) + func (e *BatchError) Error() string + type BatchMessage struct + Body string + Options []option.SendMessageInput + type Queue struct + SQS sqsiface.SQSAPI + URL *string + func MustNew(ctx context.Context, s sqsiface.SQSAPI, name string) *Queue + func New(ctx context.Context, s sqsiface.SQSAPI, name string) (*Queue, error) + func (q *Queue) ChangeMessageVisibility(ctx context.Context, receiptHandle *string, visibilityTimeout int32) error + func (q *Queue) ChangeMessageVisibilityBatch(ctx context.Context, opts ...BatchChangeMessageVisibility) error + func (q *Queue) DeleteMessage(ctx context.Context, receiptHandle *string) error + func (q *Queue) DeleteMessageBatch(ctx context.Context, receiptHandles ...*string) error + func (q *Queue) DeleteQueue(ctx context.Context) error + func (q *Queue) PurgeQueue(ctx context.Context) error + func (q *Queue) ReceiveMessage(ctx context.Context, opts ...option.ReceiveMessageInput) ([]types.Message, error) + func (q *Queue) SendMessage(ctx context.Context, body string, opts ...option.SendMessageInput) (*sqs.SendMessageOutput, error) + func (q *Queue) SendMessageBatch(ctx context.Context, messages ...BatchMessage) error Other modules containing this package github.com/nabeken/aws-go-sqs/v3
Go to main page