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

v0

v0.3.8

Sep 1, 2021

v0.3.7

Aug 26, 2021

v0.3.6

Jun 18, 2021

v0.3.5

May 18, 2021

Changes in this version

+ type BatchResultErrorEntry struct

+ Code string

+ ID string

+ Message string

+ SenderFault bool

+ type ChangeMessageVisibilityBatchRequest struct

+ Entries []ChangeMessageVisibilityBatchRequestEntry

+ QueueURL string

+ func (r ChangeMessageVisibilityBatchRequest) ToInput() *SDK.ChangeMessageVisibilityBatchInput

+ type ChangeMessageVisibilityBatchRequestEntry struct

+ ID string

+ ReceiptHandle string

+ VisibilityTimeout int64

+ func (r ChangeMessageVisibilityBatchRequestEntry) ToSDK() SDK.ChangeMessageVisibilityBatchRequestEntry

+ type ChangeMessageVisibilityBatchResult struct

+ Failed []BatchResultErrorEntry

+ Successful []ChangeMessageVisibilityBatchResultEntry

+ func NewChangeMessageVisibilityBatchResult(o *SDK.ChangeMessageVisibilityBatchResponse) *ChangeMessageVisibilityBatchResult

+ type ChangeMessageVisibilityBatchResultEntry struct

+ ID string

+ type ChangeMessageVisibilityRequest struct

+ QueueURL string

+ ReceiptHandle string

+ VisibilityTimeout int64

+ func (r ChangeMessageVisibilityRequest) ToInput() *SDK.ChangeMessageVisibilityInput

+ type ChangeMessageVisibilityResult struct

+ func NewChangeMessageVisibilityResult(o *SDK.ChangeMessageVisibilityResponse) *ChangeMessageVisibilityResult

+ type CreateQueueRequest struct

+ Attributes map[string]string

+ QueueName string

+ Tags map[string]string

+ func (r CreateQueueRequest) ToInput() *SDK.CreateQueueInput

+ type CreateQueueResult struct

+ QueueURL string

+ func NewCreateQueueResult(o *SDK.CreateQueueResponse) *CreateQueueResult

+ type DeleteMessageBatchRequest struct

+ Entries []DeleteMessageBatchRequestEntry

+ QueueURL string

+ func (r DeleteMessageBatchRequest) ToInput() *SDK.DeleteMessageBatchInput

+ type DeleteMessageBatchRequestEntry struct

+ ID string

+ ReceiptHandle string

+ func (r DeleteMessageBatchRequestEntry) ToSDK() SDK.DeleteMessageBatchRequestEntry

+ type DeleteMessageBatchResult struct

+ Failed []BatchResultErrorEntry

+ Successful []DeleteMessageBatchResultEntry

+ func NewDeleteMessageBatchResult(o *SDK.DeleteMessageBatchResponse) *DeleteMessageBatchResult

+ type DeleteMessageBatchResultEntry struct

+ ID string

+ type DeleteMessageRequest struct

+ QueueURL string

+ ReceiptHandle string

+ func (r DeleteMessageRequest) ToInput() *SDK.DeleteMessageInput

+ type DeleteMessageResult struct

+ func NewDeleteMessageResult(o *SDK.DeleteMessageResponse) *DeleteMessageResult

+ type DeleteQueueRequest struct

+ QueueURL string

+ func (r DeleteQueueRequest) ToInput() *SDK.DeleteQueueInput

+ type DeleteQueueResult struct

+ func NewDeleteQueueResult(o *SDK.DeleteQueueResponse) *DeleteQueueResult

+ type GetQueueAttributesRequest struct

+ AttributeNames []QueueAttributeName

+ QueueURL string

+ func (r GetQueueAttributesRequest) ToInput() *SDK.GetQueueAttributesInput

+ type GetQueueAttributesResult struct

+ Attributes map[string]string

+ func NewGetQueueAttributesResult(o *SDK.GetQueueAttributesResponse) *GetQueueAttributesResult

+ type GetQueueURLRequest struct

+ QueueName string

+ QueueOwnerAWSAccountID string

+ func (r GetQueueURLRequest) ToInput() *SDK.GetQueueUrlInput

+ type GetQueueURLResult struct

+ QueueURL string

+ func NewGetQueueURLResult(o *SDK.GetQueueUrlResponse) *GetQueueURLResult

+ type ListDeadLetterSourceQueuesRequest struct

+ MaxResults int64

+ NextToken string

+ QueueURL string

+ func (r ListDeadLetterSourceQueuesRequest) ToInput() *SDK.ListDeadLetterSourceQueuesInput

+ type ListDeadLetterSourceQueuesResult struct

+ NextToken string

+ QueueURLs []string

+ func NewListDeadLetterSourceQueuesResult(o *SDK.ListDeadLetterSourceQueuesResponse) *ListDeadLetterSourceQueuesResult

+ type ListQueueTagsRequest struct

+ QueueURL string

+ func (r ListQueueTagsRequest) ToInput() *SDK.ListQueueTagsInput

+ type ListQueueTagsResult struct

+ Tags map[string]string

+ func NewListQueueTagsResult(o *SDK.ListQueueTagsResponse) *ListQueueTagsResult

+ type ListQueuesRequest struct

+ MaxResults int64

+ NextToken string

+ QueueNamePrefix string

+ func (r ListQueuesRequest) ToInput() *SDK.ListQueuesInput

+ type ListQueuesResult struct

+ NextToken string

+ QueueURLs []string

+ func NewListQueuesResult(o *SDK.ListQueuesResponse) *ListQueuesResult

+ type Message struct

+ Attributes map[string]string

+ Body string

+ MD5OfBody string

+ MD5OfMessageAttributes string

+ MessageAttributes map[string]MessageAttributeValue

+ MessageID string

+ ReceiptHandle string

+ type MessageAttributeValue struct

+ BinaryListValues [][]byte

+ BinaryValue []byte

+ DataType string

+ StringListValues []string

+ StringValue string

+ func (r MessageAttributeValue) ToSDK() SDK.MessageAttributeValue

+ type MessageSystemAttributeValue struct

+ BinaryListValues [][]byte

+ BinaryValue []byte

+ DataType string

+ StringListValues []string

+ StringValue string

+ func (r MessageSystemAttributeValue) ToSDK() SDK.MessageSystemAttributeValue

+ type PurgeQueueRequest struct

+ QueueURL string

+ func (r PurgeQueueRequest) ToInput() *SDK.PurgeQueueInput

+ type PurgeQueueResult struct

+ func NewPurgeQueueResult(o *SDK.PurgeQueueResponse) *PurgeQueueResult

+ type QueueAttributeName string

+ const QueueAttributeNameAll

+ const QueueAttributeNameApproximateNumberOfMessages

+ const QueueAttributeNameApproximateNumberOfMessagesDelayed

+ const QueueAttributeNameApproximateNumberOfMessagesNotVisible

+ const QueueAttributeNameContentBasedDeduplication

+ const QueueAttributeNameCreatedTimestamp

+ const QueueAttributeNameDelaySeconds

+ const QueueAttributeNameFifoQueue

+ const QueueAttributeNameKmsDataKeyReusePeriodSeconds

+ const QueueAttributeNameKmsMasterKeyID

+ const QueueAttributeNameLastModifiedTimestamp

+ const QueueAttributeNameMaximumMessageSize

+ const QueueAttributeNameMessageRetentionPeriod

+ const QueueAttributeNamePolicy

+ const QueueAttributeNameQueueArn

+ const QueueAttributeNameReceiveMessageWaitTimeSeconds

+ const QueueAttributeNameRedrivePolicy

+ const QueueAttributeNameVisibilityTimeout

+ type ReceiveMessageRequest struct

+ AttributeNames []QueueAttributeName

+ MaxNumberOfMessages int64

+ MessageAttributeNames []string

+ QueueURL string

+ ReceiveRequestAttemptID string

+ UseShortPolling bool

+ VisibilityTimeout int64

+ WaitTimeSeconds int64

+ func (r ReceiveMessageRequest) ToInput() *SDK.ReceiveMessageInput

+ type ReceiveMessageResult struct

+ Messages []Message

+ func NewReceiveMessageResult(o *SDK.ReceiveMessageResponse) *ReceiveMessageResult

+ type SQS struct

+ func New(conf config.Config) (*SQS, error)

+ func (svc *SQS) ChangeMessageVisibility(ctx context.Context, r ChangeMessageVisibilityRequest) (*ChangeMessageVisibilityResult, error)

+ func (svc *SQS) ChangeMessageVisibilityBatch(ctx context.Context, r ChangeMessageVisibilityBatchRequest) (*ChangeMessageVisibilityBatchResult, error)

+ func (svc *SQS) CreateQueue(ctx context.Context, r CreateQueueRequest) (*CreateQueueResult, error)

+ func (svc *SQS) DeleteMessage(ctx context.Context, r DeleteMessageRequest) (*DeleteMessageResult, error)

+ func (svc *SQS) DeleteMessageBatch(ctx context.Context, r DeleteMessageBatchRequest) (*DeleteMessageBatchResult, error)

+ func (svc *SQS) DeleteQueue(ctx context.Context, r DeleteQueueRequest) (*DeleteQueueResult, error)

+ func (svc *SQS) Errorf(format string, v ...interface{})

+ func (svc *SQS) GetClient() *SDK.Client

+ func (svc *SQS) GetQueueAttributes(ctx context.Context, r GetQueueAttributesRequest) (*GetQueueAttributesResult, error)

+ func (svc *SQS) GetQueueURL(ctx context.Context, r GetQueueURLRequest) (*GetQueueURLResult, error)

+ func (svc *SQS) Infof(format string, v ...interface{})

+ func (svc *SQS) ListDeadLetterSourceQueues(ctx context.Context, r ListDeadLetterSourceQueuesRequest) (*ListDeadLetterSourceQueuesResult, error)

+ func (svc *SQS) ListQueueTags(ctx context.Context, r ListQueueTagsRequest) (*ListQueueTagsResult, error)

+ func (svc *SQS) ListQueues(ctx context.Context, r ListQueuesRequest) (*ListQueuesResult, error)

+ func (svc *SQS) PurgeQueue(ctx context.Context, r PurgeQueueRequest) (*PurgeQueueResult, error)

+ func (svc *SQS) RawAddPermission(ctx context.Context, in *SDK.AddPermissionInput) (*SDK.AddPermissionResponse, error)

+ func (svc *SQS) RawChangeMessageVisibility(ctx context.Context, in *SDK.ChangeMessageVisibilityInput) (*SDK.ChangeMessageVisibilityResponse, error)

+ func (svc *SQS) RawChangeMessageVisibilityBatch(ctx context.Context, in *SDK.ChangeMessageVisibilityBatchInput) (*SDK.ChangeMessageVisibilityBatchResponse, error)

+ func (svc *SQS) RawCreateQueue(ctx context.Context, in *SDK.CreateQueueInput) (*SDK.CreateQueueResponse, error)

+ func (svc *SQS) RawDeleteMessage(ctx context.Context, in *SDK.DeleteMessageInput) (*SDK.DeleteMessageResponse, error)

+ func (svc *SQS) RawDeleteMessageBatch(ctx context.Context, in *SDK.DeleteMessageBatchInput) (*SDK.DeleteMessageBatchResponse, error)

+ func (svc *SQS) RawDeleteQueue(ctx context.Context, in *SDK.DeleteQueueInput) (*SDK.DeleteQueueResponse, error)

+ func (svc *SQS) RawGetQueueAttributes(ctx context.Context, in *SDK.GetQueueAttributesInput) (*SDK.GetQueueAttributesResponse, error)

+ func (svc *SQS) RawGetQueueUrl(ctx context.Context, in *SDK.GetQueueUrlInput) (*SDK.GetQueueUrlResponse, error)

+ func (svc *SQS) RawListDeadLetterSourceQueues(ctx context.Context, in *SDK.ListDeadLetterSourceQueuesInput) (*SDK.ListDeadLetterSourceQueuesResponse, error)

+ func (svc *SQS) RawListQueueTags(ctx context.Context, in *SDK.ListQueueTagsInput) (*SDK.ListQueueTagsResponse, error)

+ func (svc *SQS) RawListQueues(ctx context.Context, in *SDK.ListQueuesInput) (*SDK.ListQueuesResponse, error)

+ func (svc *SQS) RawPurgeQueue(ctx context.Context, in *SDK.PurgeQueueInput) (*SDK.PurgeQueueResponse, error)

+ func (svc *SQS) RawReceiveMessage(ctx context.Context, in *SDK.ReceiveMessageInput) (*SDK.ReceiveMessageResponse, error)

+ func (svc *SQS) RawRemovePermission(ctx context.Context, in *SDK.RemovePermissionInput) (*SDK.RemovePermissionResponse, error)

+ func (svc *SQS) RawSendMessage(ctx context.Context, in *SDK.SendMessageInput) (*SDK.SendMessageResponse, error)

+ func (svc *SQS) RawSendMessageBatch(ctx context.Context, in *SDK.SendMessageBatchInput) (*SDK.SendMessageBatchResponse, error)

+ func (svc *SQS) RawSetQueueAttributes(ctx context.Context, in *SDK.SetQueueAttributesInput) (*SDK.SetQueueAttributesResponse, error)

+ func (svc *SQS) RawTagQueue(ctx context.Context, in *SDK.TagQueueInput) (*SDK.TagQueueResponse, error)

+ func (svc *SQS) RawUntagQueue(ctx context.Context, in *SDK.UntagQueueInput) (*SDK.UntagQueueResponse, error)

+ func (svc *SQS) ReceiveMessage(ctx context.Context, r ReceiveMessageRequest) (*ReceiveMessageResult, error)

+ func (svc *SQS) SendMessage(ctx context.Context, r SendMessageRequest) (*SendMessageResult, error)

+ func (svc *SQS) SendMessageBatch(ctx context.Context, r SendMessageBatchRequest) (*SendMessageBatchResult, error)

+ func (svc *SQS) SetLogger(logger log.Logger)

+ func (svc *SQS) SetQueueAttributes(ctx context.Context, r SetQueueAttributesRequest) (*SetQueueAttributesResult, error)

+ func (svc *SQS) XCreateQueue(ctx context.Context, queueName string) (queueURL string, err error)

+ func (svc *SQS) XDeleteMessage(ctx context.Context, queueURL, receiptHandle string) error

+ func (svc *SQS) XDeleteQueue(ctx context.Context, queueURL string) error

+ func (svc *SQS) XDeleteQueueByName(ctx context.Context, queueName string) error

+ func (svc *SQS) XExistsQueue(ctx context.Context, queueName string) (bool, error)

+ func (svc *SQS) XGetQueueURL(ctx context.Context, queueName string) (queueURL string, err error)

+ func (svc *SQS) XIsEmptyQueue(ctx context.Context, queueURL string) (bool, error)

+ func (svc *SQS) XListAllQueueURLs(ctx context.Context, queuePrefix string) (queueURLs []string, err error)

+ func (svc *SQS) XPurgeQueue(ctx context.Context, queueURL string) error

+ func (svc *SQS) XPurgeQueueByName(ctx context.Context, queueName string) error

+ func (svc *SQS) XReceiveMessage(ctx context.Context, queueURL string) ([]Message, error)

+ func (svc *SQS) XReceiveMessageLongPolling(ctx context.Context, queueURL string, waitSec int64) ([]Message, error)

+ func (svc *SQS) XSendMessage(ctx context.Context, queueURL, message string) error

+ func (svc *SQS) XSendMessageBatch(ctx context.Context, queueURL string, messages []string) (XSendMessageBatchResult, error)

+ type SendMessageBatchRequest struct

+ Entries []SendMessageBatchRequestEntry

+ QueueURL string

+ func (r SendMessageBatchRequest) ToInput() *SDK.SendMessageBatchInput

+ type SendMessageBatchRequestEntry struct

+ DelaySeconds int64

+ ID string

+ MessageAttributes map[string]MessageAttributeValue

+ MessageBody string

+ MessageDeduplicationID string

+ MessageGroupID string

+ MessageSystemAttributes map[string]MessageSystemAttributeValue

+ func (r SendMessageBatchRequestEntry) ToSDK() SDK.SendMessageBatchRequestEntry

+ type SendMessageBatchResult struct

+ Failed []BatchResultErrorEntry

+ Successful []SendMessageBatchResultEntry

+ func NewSendMessageBatchResult(o *SDK.SendMessageBatchResponse) *SendMessageBatchResult

+ type SendMessageBatchResultEntry struct

+ ID string

+ MD5OfMessageAttributes string

+ MD5OfMessageBody string

+ MD5OfMessageSystemAttributes string

+ MessageID string

+ SequenceNumber string

+ type SendMessageRequest struct

+ DelaySeconds int64

+ MessageAttributes map[string]MessageAttributeValue

+ MessageBody string

+ MessageDeduplicationID string

+ MessageGroupID string

+ MessageSystemAttributes map[string]MessageSystemAttributeValue

+ QueueURL string

+ func (r SendMessageRequest) ToInput() *SDK.SendMessageInput

+ type SendMessageResult struct

+ MD5OfMessageAttributes string

+ MD5OfMessageBody string

+ MD5OfMessageSystemAttributes string

+ MessageID string

+ SequenceNumber string

+ func NewSendMessageResult(o *SDK.SendMessageResponse) *SendMessageResult

+ type SetQueueAttributesRequest struct

+ Attributes map[string]string

+ QueueURL string

+ func (r SetQueueAttributesRequest) ToInput() *SDK.SetQueueAttributesInput

+ type SetQueueAttributesResult struct

+ func NewSetQueueAttributesResult(o *SDK.SetQueueAttributesResponse) *SetQueueAttributesResult

+ type XSendMessageBatchResult struct

+ FailEntries []BatchResultErrorEntry

+ Failed []int

+ Success []int