Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

sqs

package

Go to main page

Versions in this module

v1

v1.0.3

Jan 18, 2024

v1.0.2

Jan 18, 2024

v1.0.1

Jan 4, 2024

Changes in this version

+ var ErrMessageBodyEmpty = errors.New("sqs: no message body passed")

+ var ErrParseBody = errors.New("sqs: message parse body failed")

+ func CancelMessageMoveTask(ctx context.Context, taskHandle string, opts ...option.Default) (*sqs.CancelMessageMoveTaskOutput, error)

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

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

+ func CreateQueue(ctx context.Context, queueName string, opts ...option.CreateQueue) (*sqs.CreateQueueOutput, error)

+ func DeleteMessage(ctx context.Context, queueUrl, receiptHandle string, opts ...option.Default) (*sqs.DeleteMessageOutput, error)

+ func DeleteMessageBatch(ctx context.Context, input DeleteMessageBatchInput, opts ...option.Default) (*sqs.DeleteMessageBatchOutput, error)

+ func DeleteQueue(ctx context.Context, queueUrl string, opts ...option.Default) (*sqs.DeleteQueueOutput, error)

+ func GetQueueAttributes(ctx context.Context, input GetQueueAttributesInput, opts ...option.Default) (*sqs.GetQueueAttributesOutput, error)

+ func GetQueueUrl(ctx context.Context, input GetQueueUrlInput, opts ...option.Default) (*sqs.GetQueueUrlOutput, error)

+ func ListDeadLetterSourceQueues(ctx context.Context, queueUrl string, ...) (*sqs.ListDeadLetterSourceQueuesOutput, error)

+ func ListMessageMoveTasks(ctx context.Context, sourceArn string, opts ...option.ListMessageMoveTasks) (*sqs.ListMessageMoveTasksOutput, error)

+ func ListQueueTags(ctx context.Context, queueUrl string, opts ...option.Default) (*sqs.ListQueueTagsOutput, error)

+ func ListQueues(ctx context.Context, opts ...option.ListQueues) (*sqs.ListQueuesOutput, error)

+ func PurgeQueue(ctx context.Context, queueUrl string, opts ...option.Default) (*sqs.PurgeQueueOutput, error)

+ func ReceiveMessageAsync[Body, MessageAttributes any](queueUrl string, handler HandlerConsumerFunc[Body, MessageAttributes], ...)

+ func ReceiveMessage[Body, MessageAttributes any](queueUrl string, handler HandlerConsumerFunc[Body, MessageAttributes], ...)

+ func SendMessage(ctx context.Context, queueUrl string, body any, opts ...option.Producer) (*sqs.SendMessageOutput, error)

+ func SendMessageAsync(ctx context.Context, queueUrl string, body any, opts ...option.Producer)

+ func SetQueueAttributes(ctx context.Context, input SetQueueAttributesInput, opts ...option.Default) (*sqs.SetQueueAttributesOutput, error)

+ func SimpleReceiveMessageAsync[Body any](queueUrl string, simpleHandle HandlerSimpleConsumerFunc[Body], ...)

+ func SimpleReceiveMessage[Body any](queueUrl string, simpleHandle HandlerSimpleConsumerFunc[Body], ...)

+ func StartMessageMoveTask(ctx context.Context, input StartMessageMoveTaskInput, opts ...option.Default) (*sqs.StartMessageMoveTaskOutput, error)

+ func TagQueue(ctx context.Context, input TagQueueInput, opts ...option.Default) (*sqs.TagQueueOutput, error)

+ func UntagQueue(ctx context.Context, input UntagQueueInput, opts ...option.Default) (*sqs.UntagQueueOutput, error)

+ type Attributes struct

+ ApproximateFirstReceiveTimestamp time.Time

+ ApproximateReceiveCount int

+ MessageDeduplicationId string

+ MessageGroupId string

+ SenderId string

+ SentTimestamp time.Time

+ SequenceNumber int

+ type ChangeMessageVisibilityBatchInput struct

+ Entries []ChangeMessageVisibilityBatchRequestEntry

+ QueueUrl string

+ type ChangeMessageVisibilityBatchRequestEntry struct

+ Id string

+ ReceiptHandle string

+ VisibilityTimeout int32

+ type ChangeMessageVisibilityInput struct

+ QueueUrl string

+ ReceiptHandle string

+ VisibilityTimeout time.Duration

+ type Context struct

+ Message MessageReceived[Body, MessageAttributes]

+ QueueUrl string

+ type DeleteMessageBatchInput struct

+ Entries []DeleteMessageBatchRequestEntry

+ QueueUrl string

+ type DeleteMessageBatchRequestEntry struct

+ Id string

+ ReceiptHandle string

+ type GetQueueAttributesInput struct

+ AttributeNames []types.QueueAttributeName

+ QueueUrl string

+ type GetQueueUrlInput struct

+ QueueName string

+ QueueOwnerAWSAccountId *string

+ type HandlerConsumerFunc func(ctx *Context[Body, MessageAttributes]) error

+ type HandlerSimpleConsumerFunc func(ctx *SimpleContext[Body]) error

+ type MessageReceived struct

+ Attributes Attributes

+ Body Body

+ Id string

+ MD5OfBody string

+ MD5OfMessageAttributes *string

+ MessageAttributes MessageAttributes

+ ReceiptHandle string

+ type SetQueueAttributesInput struct

+ Attributes map[string]string

+ QueueUrl string

+ type SimpleContext Context[Body, map[string]types.MessageAttributeValue]

+ type StartMessageMoveTaskInput struct

+ DestinationArn *string

+ MaxNumberOfMessagesPerSecond *int32

+ SourceArn string

+ type TagQueueInput struct

+ QueueUrl string

+ Tags map[string]string

+ type UntagQueueInput struct

+ QueueUrl string

+ TagKeys []string