sqs

package

Go to main page

Versions in this module

v0

v0.24.0

Jul 22, 2020

Changes in this version

type ListDeadLetterSourceQueuesInput

+ MaxResults *int64

+ NextToken *string

type ListDeadLetterSourceQueuesOutput

+ NextToken *string

+ type ListDeadLetterSourceQueuesPaginator struct

+ func NewListDeadLetterSourceQueuesPaginator(req ListDeadLetterSourceQueuesRequest) ListDeadLetterSourceQueuesPaginator

+ func (p *ListDeadLetterSourceQueuesPaginator) CurrentPage() *ListDeadLetterSourceQueuesOutput

type ListQueuesInput

+ MaxResults *int64

+ NextToken *string

type ListQueuesOutput

+ NextToken *string

+ type ListQueuesPaginator struct

+ func NewListQueuesPaginator(req ListQueuesRequest) ListQueuesPaginator

+ func (p *ListQueuesPaginator) CurrentPage() *ListQueuesOutput

v0.23.0

May 28, 2020

v0.22.0

Apr 27, 2020

v0.21.0

Apr 22, 2020

v0.20.0

Mar 17, 2020

Changes in this version

+ type InvalidChecksumError struct

+ Err error

+ Reason string

+ func (e *InvalidChecksumError) Error() string

+ func (e *InvalidChecksumError) RetryableError() bool

+ func (e *InvalidChecksumError) Unwrap() error

v0.19.0

Jan 30, 2020

v0.18.0

Dec 12, 2019

v0.17.0

Nov 21, 2019

v0.16.0

Nov 13, 2019

v0.15.0

Oct 18, 2019

v0.14.0

Oct 8, 2019

v0.13.0

Oct 2, 2019

v0.12.0

Sep 17, 2019

Changes in this version

type MessageSystemAttributeName

+ const MessageSystemAttributeNameAwstraceHeader

+ type MessageSystemAttributeNameForSends string

+ const MessageSystemAttributeNameForSendsAwstraceHeader

+ func (enum MessageSystemAttributeNameForSends) MarshalValue() (string, error)

+ func (enum MessageSystemAttributeNameForSends) MarshalValueBuf(b []byte) ([]byte, error)

+ type MessageSystemAttributeValue struct

+ BinaryListValues [][]byte

+ BinaryValue []byte

+ DataType *string

+ StringListValues []string

+ StringValue *string

+ func (s *MessageSystemAttributeValue) Validate() error

+ func (s MessageSystemAttributeValue) String() string

type SendMessageBatchRequestEntry

+ MessageSystemAttributes map[string]MessageSystemAttributeValue

type SendMessageBatchResultEntry

+ MD5OfMessageSystemAttributes *string

type SendMessageInput

+ MessageSystemAttributes map[string]MessageSystemAttributeValue

type SendMessageOutput

+ MD5OfMessageSystemAttributes *string

v0.11.0

Aug 23, 2019

Changes in this version

type CreateQueueInput

+ Tags map[string]string

v0.10.0

Jul 25, 2019

v0.9.0

May 28, 2019

Changes in this version

+ const ServiceID

+ type AddPermissionResponse struct

+ func (r *AddPermissionResponse) SDKResponseMetdata() *aws.Response

+ type ChangeMessageVisibilityBatchResponse struct

+ func (r *ChangeMessageVisibilityBatchResponse) SDKResponseMetdata() *aws.Response

+ type ChangeMessageVisibilityResponse struct

+ func (r *ChangeMessageVisibilityResponse) SDKResponseMetdata() *aws.Response

+ type Client struct

+ DisableComputeChecksums bool

+ func (c *Client) AddPermissionRequest(input *AddPermissionInput) AddPermissionRequest

+ func (c *Client) ChangeMessageVisibilityBatchRequest(input *ChangeMessageVisibilityBatchInput) ChangeMessageVisibilityBatchRequest

+ func (c *Client) ChangeMessageVisibilityRequest(input *ChangeMessageVisibilityInput) ChangeMessageVisibilityRequest

+ func (c *Client) CreateQueueRequest(input *CreateQueueInput) CreateQueueRequest

+ func (c *Client) DeleteMessageBatchRequest(input *DeleteMessageBatchInput) DeleteMessageBatchRequest

+ func (c *Client) DeleteMessageRequest(input *DeleteMessageInput) DeleteMessageRequest

+ func (c *Client) DeleteQueueRequest(input *DeleteQueueInput) DeleteQueueRequest

+ func (c *Client) GetQueueAttributesRequest(input *GetQueueAttributesInput) GetQueueAttributesRequest

+ func (c *Client) GetQueueUrlRequest(input *GetQueueUrlInput) GetQueueUrlRequest

+ func (c *Client) ListDeadLetterSourceQueuesRequest(input *ListDeadLetterSourceQueuesInput) ListDeadLetterSourceQueuesRequest

+ func (c *Client) ListQueueTagsRequest(input *ListQueueTagsInput) ListQueueTagsRequest

+ func (c *Client) ListQueuesRequest(input *ListQueuesInput) ListQueuesRequest

+ func (c *Client) PurgeQueueRequest(input *PurgeQueueInput) PurgeQueueRequest

+ func (c *Client) ReceiveMessageRequest(input *ReceiveMessageInput) ReceiveMessageRequest

+ func (c *Client) RemovePermissionRequest(input *RemovePermissionInput) RemovePermissionRequest

+ func (c *Client) SendMessageBatchRequest(input *SendMessageBatchInput) SendMessageBatchRequest

+ func (c *Client) SendMessageRequest(input *SendMessageInput) SendMessageRequest

+ func (c *Client) SetQueueAttributesRequest(input *SetQueueAttributesInput) SetQueueAttributesRequest

+ func (c *Client) TagQueueRequest(input *TagQueueInput) TagQueueRequest

+ func (c *Client) UntagQueueRequest(input *UntagQueueInput) UntagQueueRequest

+ type CreateQueueResponse struct

+ func (r *CreateQueueResponse) SDKResponseMetdata() *aws.Response

+ type DeleteMessageBatchResponse struct

+ func (r *DeleteMessageBatchResponse) SDKResponseMetdata() *aws.Response

+ type DeleteMessageResponse struct

+ func (r *DeleteMessageResponse) SDKResponseMetdata() *aws.Response

+ type DeleteQueueResponse struct

+ func (r *DeleteQueueResponse) SDKResponseMetdata() *aws.Response

+ type GetQueueAttributesResponse struct

+ func (r *GetQueueAttributesResponse) SDKResponseMetdata() *aws.Response

+ type GetQueueUrlResponse struct

+ func (r *GetQueueUrlResponse) SDKResponseMetdata() *aws.Response

+ type ListDeadLetterSourceQueuesResponse struct

+ func (r *ListDeadLetterSourceQueuesResponse) SDKResponseMetdata() *aws.Response

+ type ListQueueTagsResponse struct

+ func (r *ListQueueTagsResponse) SDKResponseMetdata() *aws.Response

+ type ListQueuesResponse struct

+ func (r *ListQueuesResponse) SDKResponseMetdata() *aws.Response

+ type PurgeQueueResponse struct

+ func (r *PurgeQueueResponse) SDKResponseMetdata() *aws.Response

+ type ReceiveMessageResponse struct

+ func (r *ReceiveMessageResponse) SDKResponseMetdata() *aws.Response

+ type RemovePermissionResponse struct

+ func (r *RemovePermissionResponse) SDKResponseMetdata() *aws.Response

+ type SendMessageBatchResponse struct

+ func (r *SendMessageBatchResponse) SDKResponseMetdata() *aws.Response

+ type SendMessageResponse struct

+ func (r *SendMessageResponse) SDKResponseMetdata() *aws.Response

+ type SetQueueAttributesResponse struct

+ func (r *SetQueueAttributesResponse) SDKResponseMetdata() *aws.Response

+ type TagQueueResponse struct

+ func (r *TagQueueResponse) SDKResponseMetdata() *aws.Response

+ type UntagQueueResponse struct

+ func (r *UntagQueueResponse) SDKResponseMetdata() *aws.Response

v0.8.0

Apr 25, 2019

v0.7.0

Jan 3, 2019

v0.6.0

Dec 3, 2018

v0.5.0

Sep 27, 2018

v0.4.0

May 26, 2018

v0.3.0

Mar 8, 2018

Changes in this version

type AddPermissionRequest

+ Copy func(*AddPermissionInput) AddPermissionRequest

type ChangeMessageVisibilityBatchRequest

+ Copy func(*ChangeMessageVisibilityBatchInput) ChangeMessageVisibilityBatchRequest

type ChangeMessageVisibilityRequest

+ Copy func(*ChangeMessageVisibilityInput) ChangeMessageVisibilityRequest

type CreateQueueRequest

+ Copy func(*CreateQueueInput) CreateQueueRequest

type DeleteMessageBatchRequest

+ Copy func(*DeleteMessageBatchInput) DeleteMessageBatchRequest

type DeleteMessageRequest

+ Copy func(*DeleteMessageInput) DeleteMessageRequest

type DeleteQueueRequest

+ Copy func(*DeleteQueueInput) DeleteQueueRequest

type GetQueueAttributesRequest

+ Copy func(*GetQueueAttributesInput) GetQueueAttributesRequest

type GetQueueUrlRequest

+ Copy func(*GetQueueUrlInput) GetQueueUrlRequest

type ListDeadLetterSourceQueuesRequest

+ Copy func(*ListDeadLetterSourceQueuesInput) ListDeadLetterSourceQueuesRequest

type ListQueueTagsRequest

+ Copy func(*ListQueueTagsInput) ListQueueTagsRequest

type ListQueuesRequest

+ Copy func(*ListQueuesInput) ListQueuesRequest

type MessageSystemAttributeName

+ func (enum MessageSystemAttributeName) MarshalValue() (string, error)

+ func (enum MessageSystemAttributeName) MarshalValueBuf(b []byte) ([]byte, error)

type PurgeQueueRequest

+ Copy func(*PurgeQueueInput) PurgeQueueRequest

type QueueAttributeName

+ func (enum QueueAttributeName) MarshalValue() (string, error)

+ func (enum QueueAttributeName) MarshalValueBuf(b []byte) ([]byte, error)

type ReceiveMessageRequest

+ Copy func(*ReceiveMessageInput) ReceiveMessageRequest

type RemovePermissionRequest

+ Copy func(*RemovePermissionInput) RemovePermissionRequest

type SendMessageBatchRequest

+ Copy func(*SendMessageBatchInput) SendMessageBatchRequest

type SendMessageRequest

+ Copy func(*SendMessageInput) SendMessageRequest

type SetQueueAttributesRequest

+ Copy func(*SetQueueAttributesInput) SetQueueAttributesRequest

type TagQueueRequest

+ Copy func(*TagQueueInput) TagQueueRequest

type UntagQueueRequest

+ Copy func(*UntagQueueInput) UntagQueueRequest

v0.2.0

Jan 15, 2018

Changes in this version

+ type ListQueueTagsInput struct

+ QueueUrl *string

+ func (s *ListQueueTagsInput) SetQueueUrl(v string) *ListQueueTagsInput

+ func (s *ListQueueTagsInput) Validate() error

+ func (s ListQueueTagsInput) GoString() string

+ func (s ListQueueTagsInput) String() string

+ type ListQueueTagsOutput struct

+ Tags map[string]string

+ func (s *ListQueueTagsOutput) SetTags(v map[string]string) *ListQueueTagsOutput

+ func (s ListQueueTagsOutput) GoString() string

+ func (s ListQueueTagsOutput) SDKResponseMetadata() aws.Response

+ func (s ListQueueTagsOutput) String() string

+ type ListQueueTagsRequest struct

+ Input *ListQueueTagsInput

+ func (r ListQueueTagsRequest) Send() (*ListQueueTagsOutput, error)

type SQS

+ func (c *SQS) ListQueueTagsRequest(input *ListQueueTagsInput) ListQueueTagsRequest

+ func (c *SQS) TagQueueRequest(input *TagQueueInput) TagQueueRequest

+ func (c *SQS) UntagQueueRequest(input *UntagQueueInput) UntagQueueRequest

+ type TagQueueInput struct

+ QueueUrl *string

+ Tags map[string]string

+ func (s *TagQueueInput) SetQueueUrl(v string) *TagQueueInput

+ func (s *TagQueueInput) SetTags(v map[string]string) *TagQueueInput

+ func (s *TagQueueInput) Validate() error

+ func (s TagQueueInput) GoString() string

+ func (s TagQueueInput) String() string

+ type TagQueueOutput struct

+ func (s TagQueueOutput) GoString() string

+ func (s TagQueueOutput) SDKResponseMetadata() aws.Response

+ func (s TagQueueOutput) String() string

+ type TagQueueRequest struct

+ Input *TagQueueInput

+ func (r TagQueueRequest) Send() (*TagQueueOutput, error)

+ type UntagQueueInput struct

+ QueueUrl *string

+ TagKeys []string

+ func (s *UntagQueueInput) SetQueueUrl(v string) *UntagQueueInput

+ func (s *UntagQueueInput) SetTagKeys(v []string) *UntagQueueInput

+ func (s *UntagQueueInput) Validate() error

+ func (s UntagQueueInput) GoString() string

+ func (s UntagQueueInput) String() string

+ type UntagQueueOutput struct

+ func (s UntagQueueOutput) GoString() string

+ func (s UntagQueueOutput) SDKResponseMetadata() aws.Response

+ func (s UntagQueueOutput) String() string

+ type UntagQueueRequest struct

+ Input *UntagQueueInput

+ func (r UntagQueueRequest) Send() (*UntagQueueOutput, error)

v0.1.0

Dec 21, 2017

Changes in this version

+ const EndpointsID

+ const ErrCodeBatchEntryIdsNotDistinct

+ const ErrCodeBatchRequestTooLong

+ const ErrCodeEmptyBatchRequest

+ const ErrCodeInvalidAttributeName

+ const ErrCodeInvalidBatchEntryId

+ const ErrCodeInvalidIdFormat

+ const ErrCodeInvalidMessageContents

+ const ErrCodeMessageNotInflight

+ const ErrCodeOverLimit

+ const ErrCodePurgeQueueInProgress

+ const ErrCodeQueueDeletedRecently

+ const ErrCodeQueueDoesNotExist

+ const ErrCodeQueueNameExists

+ const ErrCodeReceiptHandleIsInvalid

+ const ErrCodeTooManyEntriesInBatchRequest

+ const ErrCodeUnsupportedOperation

+ const ServiceName

+ type AddPermissionInput struct

+ AWSAccountIds []string

+ Actions []string

+ Label *string

+ QueueUrl *string

+ func (s *AddPermissionInput) SetAWSAccountIds(v []string) *AddPermissionInput

+ func (s *AddPermissionInput) SetActions(v []string) *AddPermissionInput

+ func (s *AddPermissionInput) SetLabel(v string) *AddPermissionInput

+ func (s *AddPermissionInput) SetQueueUrl(v string) *AddPermissionInput

+ func (s *AddPermissionInput) Validate() error

+ func (s AddPermissionInput) GoString() string

+ func (s AddPermissionInput) String() string

+ type AddPermissionOutput struct

+ func (s AddPermissionOutput) GoString() string

+ func (s AddPermissionOutput) SDKResponseMetadata() aws.Response

+ func (s AddPermissionOutput) String() string

+ type AddPermissionRequest struct

+ Input *AddPermissionInput

+ func (r AddPermissionRequest) Send() (*AddPermissionOutput, error)

+ type BatchResultErrorEntry struct

+ Code *string

+ Id *string

+ Message *string

+ SenderFault *bool

+ func (s *BatchResultErrorEntry) SetCode(v string) *BatchResultErrorEntry

+ func (s *BatchResultErrorEntry) SetId(v string) *BatchResultErrorEntry

+ func (s *BatchResultErrorEntry) SetMessage(v string) *BatchResultErrorEntry

+ func (s *BatchResultErrorEntry) SetSenderFault(v bool) *BatchResultErrorEntry

+ func (s BatchResultErrorEntry) GoString() string

+ func (s BatchResultErrorEntry) String() string

+ type ChangeMessageVisibilityBatchInput struct

+ Entries []ChangeMessageVisibilityBatchRequestEntry

+ QueueUrl *string

+ func (s *ChangeMessageVisibilityBatchInput) SetEntries(v []ChangeMessageVisibilityBatchRequestEntry) *ChangeMessageVisibilityBatchInput

+ func (s *ChangeMessageVisibilityBatchInput) SetQueueUrl(v string) *ChangeMessageVisibilityBatchInput

+ func (s *ChangeMessageVisibilityBatchInput) Validate() error

+ func (s ChangeMessageVisibilityBatchInput) GoString() string

+ func (s ChangeMessageVisibilityBatchInput) String() string

+ type ChangeMessageVisibilityBatchOutput struct

+ Failed []BatchResultErrorEntry

+ Successful []ChangeMessageVisibilityBatchResultEntry

+ func (s *ChangeMessageVisibilityBatchOutput) SetFailed(v []BatchResultErrorEntry) *ChangeMessageVisibilityBatchOutput

+ func (s *ChangeMessageVisibilityBatchOutput) SetSuccessful(v []ChangeMessageVisibilityBatchResultEntry) *ChangeMessageVisibilityBatchOutput

+ func (s ChangeMessageVisibilityBatchOutput) GoString() string

+ func (s ChangeMessageVisibilityBatchOutput) SDKResponseMetadata() aws.Response

+ func (s ChangeMessageVisibilityBatchOutput) String() string

+ type ChangeMessageVisibilityBatchRequest struct

+ Input *ChangeMessageVisibilityBatchInput

+ func (r ChangeMessageVisibilityBatchRequest) Send() (*ChangeMessageVisibilityBatchOutput, error)

+ type ChangeMessageVisibilityBatchRequestEntry struct

+ Id *string

+ ReceiptHandle *string

+ VisibilityTimeout *int64

+ func (s *ChangeMessageVisibilityBatchRequestEntry) SetId(v string) *ChangeMessageVisibilityBatchRequestEntry

+ func (s *ChangeMessageVisibilityBatchRequestEntry) SetReceiptHandle(v string) *ChangeMessageVisibilityBatchRequestEntry

+ func (s *ChangeMessageVisibilityBatchRequestEntry) SetVisibilityTimeout(v int64) *ChangeMessageVisibilityBatchRequestEntry

+ func (s *ChangeMessageVisibilityBatchRequestEntry) Validate() error

+ func (s ChangeMessageVisibilityBatchRequestEntry) GoString() string

+ func (s ChangeMessageVisibilityBatchRequestEntry) String() string

+ type ChangeMessageVisibilityBatchResultEntry struct

+ Id *string

+ func (s *ChangeMessageVisibilityBatchResultEntry) SetId(v string) *ChangeMessageVisibilityBatchResultEntry

+ func (s ChangeMessageVisibilityBatchResultEntry) GoString() string

+ func (s ChangeMessageVisibilityBatchResultEntry) String() string

+ type ChangeMessageVisibilityInput struct

+ QueueUrl *string

+ ReceiptHandle *string

+ VisibilityTimeout *int64

+ func (s *ChangeMessageVisibilityInput) SetQueueUrl(v string) *ChangeMessageVisibilityInput

+ func (s *ChangeMessageVisibilityInput) SetReceiptHandle(v string) *ChangeMessageVisibilityInput

+ func (s *ChangeMessageVisibilityInput) SetVisibilityTimeout(v int64) *ChangeMessageVisibilityInput

+ func (s *ChangeMessageVisibilityInput) Validate() error

+ func (s ChangeMessageVisibilityInput) GoString() string

+ func (s ChangeMessageVisibilityInput) String() string

+ type ChangeMessageVisibilityOutput struct

+ func (s ChangeMessageVisibilityOutput) GoString() string

+ func (s ChangeMessageVisibilityOutput) SDKResponseMetadata() aws.Response

+ func (s ChangeMessageVisibilityOutput) String() string

+ type ChangeMessageVisibilityRequest struct

+ Input *ChangeMessageVisibilityInput

+ func (r ChangeMessageVisibilityRequest) Send() (*ChangeMessageVisibilityOutput, error)

+ type CreateQueueInput struct

+ Attributes map[string]string

+ QueueName *string

+ func (s *CreateQueueInput) SetAttributes(v map[string]string) *CreateQueueInput

+ func (s *CreateQueueInput) SetQueueName(v string) *CreateQueueInput

+ func (s *CreateQueueInput) Validate() error

+ func (s CreateQueueInput) GoString() string

+ func (s CreateQueueInput) String() string

+ type CreateQueueOutput struct

+ QueueUrl *string

+ func (s *CreateQueueOutput) SetQueueUrl(v string) *CreateQueueOutput

+ func (s CreateQueueOutput) GoString() string

+ func (s CreateQueueOutput) SDKResponseMetadata() aws.Response

+ func (s CreateQueueOutput) String() string

+ type CreateQueueRequest struct

+ Input *CreateQueueInput

+ func (r CreateQueueRequest) Send() (*CreateQueueOutput, error)

+ type DeleteMessageBatchInput struct

+ Entries []DeleteMessageBatchRequestEntry

+ QueueUrl *string

+ func (s *DeleteMessageBatchInput) SetEntries(v []DeleteMessageBatchRequestEntry) *DeleteMessageBatchInput

+ func (s *DeleteMessageBatchInput) SetQueueUrl(v string) *DeleteMessageBatchInput

+ func (s *DeleteMessageBatchInput) Validate() error

+ func (s DeleteMessageBatchInput) GoString() string

+ func (s DeleteMessageBatchInput) String() string

+ type DeleteMessageBatchOutput struct

+ Failed []BatchResultErrorEntry

+ Successful []DeleteMessageBatchResultEntry

+ func (s *DeleteMessageBatchOutput) SetFailed(v []BatchResultErrorEntry) *DeleteMessageBatchOutput

+ func (s *DeleteMessageBatchOutput) SetSuccessful(v []DeleteMessageBatchResultEntry) *DeleteMessageBatchOutput

+ func (s DeleteMessageBatchOutput) GoString() string

+ func (s DeleteMessageBatchOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteMessageBatchOutput) String() string

+ type DeleteMessageBatchRequest struct

+ Input *DeleteMessageBatchInput

+ func (r DeleteMessageBatchRequest) Send() (*DeleteMessageBatchOutput, error)

+ type DeleteMessageBatchRequestEntry struct

+ Id *string

+ ReceiptHandle *string

+ func (s *DeleteMessageBatchRequestEntry) SetId(v string) *DeleteMessageBatchRequestEntry

+ func (s *DeleteMessageBatchRequestEntry) SetReceiptHandle(v string) *DeleteMessageBatchRequestEntry

+ func (s *DeleteMessageBatchRequestEntry) Validate() error

+ func (s DeleteMessageBatchRequestEntry) GoString() string

+ func (s DeleteMessageBatchRequestEntry) String() string

+ type DeleteMessageBatchResultEntry struct

+ Id *string

+ func (s *DeleteMessageBatchResultEntry) SetId(v string) *DeleteMessageBatchResultEntry

+ func (s DeleteMessageBatchResultEntry) GoString() string

+ func (s DeleteMessageBatchResultEntry) String() string

+ type DeleteMessageInput struct

+ QueueUrl *string

+ ReceiptHandle *string

+ func (s *DeleteMessageInput) SetQueueUrl(v string) *DeleteMessageInput

+ func (s *DeleteMessageInput) SetReceiptHandle(v string) *DeleteMessageInput

+ func (s *DeleteMessageInput) Validate() error

+ func (s DeleteMessageInput) GoString() string

+ func (s DeleteMessageInput) String() string

+ type DeleteMessageOutput struct

+ func (s DeleteMessageOutput) GoString() string

+ func (s DeleteMessageOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteMessageOutput) String() string

+ type DeleteMessageRequest struct

+ Input *DeleteMessageInput

+ func (r DeleteMessageRequest) Send() (*DeleteMessageOutput, error)

+ type DeleteQueueInput struct

+ QueueUrl *string

+ func (s *DeleteQueueInput) SetQueueUrl(v string) *DeleteQueueInput

+ func (s *DeleteQueueInput) Validate() error

+ func (s DeleteQueueInput) GoString() string

+ func (s DeleteQueueInput) String() string

+ type DeleteQueueOutput struct

+ func (s DeleteQueueOutput) GoString() string

+ func (s DeleteQueueOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteQueueOutput) String() string

+ type DeleteQueueRequest struct

+ Input *DeleteQueueInput

+ func (r DeleteQueueRequest) Send() (*DeleteQueueOutput, error)

+ type GetQueueAttributesInput struct

+ AttributeNames []QueueAttributeName

+ QueueUrl *string

+ func (s *GetQueueAttributesInput) SetAttributeNames(v []QueueAttributeName) *GetQueueAttributesInput

+ func (s *GetQueueAttributesInput) SetQueueUrl(v string) *GetQueueAttributesInput

+ func (s *GetQueueAttributesInput) Validate() error

+ func (s GetQueueAttributesInput) GoString() string

+ func (s GetQueueAttributesInput) String() string

+ type GetQueueAttributesOutput struct

+ Attributes map[string]string

+ func (s *GetQueueAttributesOutput) SetAttributes(v map[string]string) *GetQueueAttributesOutput

+ func (s GetQueueAttributesOutput) GoString() string

+ func (s GetQueueAttributesOutput) SDKResponseMetadata() aws.Response

+ func (s GetQueueAttributesOutput) String() string

+ type GetQueueAttributesRequest struct

+ Input *GetQueueAttributesInput

+ func (r GetQueueAttributesRequest) Send() (*GetQueueAttributesOutput, error)

+ type GetQueueUrlInput struct

+ QueueName *string

+ QueueOwnerAWSAccountId *string

+ func (s *GetQueueUrlInput) SetQueueName(v string) *GetQueueUrlInput

+ func (s *GetQueueUrlInput) SetQueueOwnerAWSAccountId(v string) *GetQueueUrlInput

+ func (s *GetQueueUrlInput) Validate() error

+ func (s GetQueueUrlInput) GoString() string

+ func (s GetQueueUrlInput) String() string

+ type GetQueueUrlOutput struct

+ QueueUrl *string

+ func (s *GetQueueUrlOutput) SetQueueUrl(v string) *GetQueueUrlOutput

+ func (s GetQueueUrlOutput) GoString() string

+ func (s GetQueueUrlOutput) SDKResponseMetadata() aws.Response

+ func (s GetQueueUrlOutput) String() string

+ type GetQueueUrlRequest struct

+ Input *GetQueueUrlInput

+ func (r GetQueueUrlRequest) Send() (*GetQueueUrlOutput, error)

+ type ListDeadLetterSourceQueuesInput struct

+ QueueUrl *string

+ func (s *ListDeadLetterSourceQueuesInput) SetQueueUrl(v string) *ListDeadLetterSourceQueuesInput

+ func (s *ListDeadLetterSourceQueuesInput) Validate() error

+ func (s ListDeadLetterSourceQueuesInput) GoString() string

+ func (s ListDeadLetterSourceQueuesInput) String() string

+ type ListDeadLetterSourceQueuesOutput struct

+ QueueUrls []string

+ func (s *ListDeadLetterSourceQueuesOutput) SetQueueUrls(v []string) *ListDeadLetterSourceQueuesOutput

+ func (s ListDeadLetterSourceQueuesOutput) GoString() string

+ func (s ListDeadLetterSourceQueuesOutput) SDKResponseMetadata() aws.Response

+ func (s ListDeadLetterSourceQueuesOutput) String() string

+ type ListDeadLetterSourceQueuesRequest struct

+ Input *ListDeadLetterSourceQueuesInput

+ func (r ListDeadLetterSourceQueuesRequest) Send() (*ListDeadLetterSourceQueuesOutput, error)

+ type ListQueuesInput struct

+ QueueNamePrefix *string

+ func (s *ListQueuesInput) SetQueueNamePrefix(v string) *ListQueuesInput

+ func (s ListQueuesInput) GoString() string

+ func (s ListQueuesInput) String() string

+ type ListQueuesOutput struct

+ QueueUrls []string

+ func (s *ListQueuesOutput) SetQueueUrls(v []string) *ListQueuesOutput

+ func (s ListQueuesOutput) GoString() string

+ func (s ListQueuesOutput) SDKResponseMetadata() aws.Response

+ func (s ListQueuesOutput) String() string

+ type ListQueuesRequest struct

+ Input *ListQueuesInput

+ func (r ListQueuesRequest) Send() (*ListQueuesOutput, error)

+ type Message struct

+ Attributes map[string]string

+ Body *string

+ MD5OfBody *string

+ MD5OfMessageAttributes *string

+ MessageAttributes map[string]MessageAttributeValue

+ MessageId *string

+ ReceiptHandle *string

+ func (s *Message) SetAttributes(v map[string]string) *Message

+ func (s *Message) SetBody(v string) *Message

+ func (s *Message) SetMD5OfBody(v string) *Message

+ func (s *Message) SetMD5OfMessageAttributes(v string) *Message

+ func (s *Message) SetMessageAttributes(v map[string]MessageAttributeValue) *Message

+ func (s *Message) SetMessageId(v string) *Message

+ func (s *Message) SetReceiptHandle(v string) *Message

+ func (s Message) GoString() string

+ func (s Message) String() string

+ type MessageAttributeValue struct

+ BinaryListValues [][]byte

+ BinaryValue []byte

+ DataType *string

+ StringListValues []string

+ StringValue *string

+ func (s *MessageAttributeValue) SetBinaryListValues(v [][]byte) *MessageAttributeValue

+ func (s *MessageAttributeValue) SetBinaryValue(v []byte) *MessageAttributeValue

+ func (s *MessageAttributeValue) SetDataType(v string) *MessageAttributeValue

+ func (s *MessageAttributeValue) SetStringListValues(v []string) *MessageAttributeValue

+ func (s *MessageAttributeValue) SetStringValue(v string) *MessageAttributeValue

+ func (s *MessageAttributeValue) Validate() error

+ func (s MessageAttributeValue) GoString() string

+ func (s MessageAttributeValue) String() string

+ type MessageSystemAttributeName string

+ const MessageSystemAttributeNameApproximateFirstReceiveTimestamp

+ const MessageSystemAttributeNameApproximateReceiveCount

+ const MessageSystemAttributeNameMessageDeduplicationId

+ const MessageSystemAttributeNameMessageGroupId

+ const MessageSystemAttributeNameSenderId

+ const MessageSystemAttributeNameSentTimestamp

+ const MessageSystemAttributeNameSequenceNumber

+ type PurgeQueueInput struct

+ QueueUrl *string

+ func (s *PurgeQueueInput) SetQueueUrl(v string) *PurgeQueueInput

+ func (s *PurgeQueueInput) Validate() error

+ func (s PurgeQueueInput) GoString() string

+ func (s PurgeQueueInput) String() string

+ type PurgeQueueOutput struct

+ func (s PurgeQueueOutput) GoString() string

+ func (s PurgeQueueOutput) SDKResponseMetadata() aws.Response

+ func (s PurgeQueueOutput) String() string

+ type PurgeQueueRequest struct

+ Input *PurgeQueueInput

+ func (r PurgeQueueRequest) Send() (*PurgeQueueOutput, error)

+ 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 ReceiveMessageInput struct

+ AttributeNames []QueueAttributeName

+ MaxNumberOfMessages *int64

+ MessageAttributeNames []string

+ QueueUrl *string

+ ReceiveRequestAttemptId *string

+ VisibilityTimeout *int64

+ WaitTimeSeconds *int64

+ func (s *ReceiveMessageInput) SetAttributeNames(v []QueueAttributeName) *ReceiveMessageInput

+ func (s *ReceiveMessageInput) SetMaxNumberOfMessages(v int64) *ReceiveMessageInput

+ func (s *ReceiveMessageInput) SetMessageAttributeNames(v []string) *ReceiveMessageInput

+ func (s *ReceiveMessageInput) SetQueueUrl(v string) *ReceiveMessageInput

+ func (s *ReceiveMessageInput) SetReceiveRequestAttemptId(v string) *ReceiveMessageInput

+ func (s *ReceiveMessageInput) SetVisibilityTimeout(v int64) *ReceiveMessageInput

+ func (s *ReceiveMessageInput) SetWaitTimeSeconds(v int64) *ReceiveMessageInput

+ func (s *ReceiveMessageInput) Validate() error

+ func (s ReceiveMessageInput) GoString() string

+ func (s ReceiveMessageInput) String() string

+ type ReceiveMessageOutput struct

+ Messages []Message

+ func (s *ReceiveMessageOutput) SetMessages(v []Message) *ReceiveMessageOutput

+ func (s ReceiveMessageOutput) GoString() string

+ func (s ReceiveMessageOutput) SDKResponseMetadata() aws.Response

+ func (s ReceiveMessageOutput) String() string

+ type ReceiveMessageRequest struct

+ Input *ReceiveMessageInput

+ func (r ReceiveMessageRequest) Send() (*ReceiveMessageOutput, error)

+ type RemovePermissionInput struct

+ Label *string

+ QueueUrl *string

+ func (s *RemovePermissionInput) SetLabel(v string) *RemovePermissionInput

+ func (s *RemovePermissionInput) SetQueueUrl(v string) *RemovePermissionInput

+ func (s *RemovePermissionInput) Validate() error

+ func (s RemovePermissionInput) GoString() string

+ func (s RemovePermissionInput) String() string

+ type RemovePermissionOutput struct

+ func (s RemovePermissionOutput) GoString() string

+ func (s RemovePermissionOutput) SDKResponseMetadata() aws.Response

+ func (s RemovePermissionOutput) String() string

+ type RemovePermissionRequest struct

+ Input *RemovePermissionInput

+ func (r RemovePermissionRequest) Send() (*RemovePermissionOutput, error)

+ type SQS struct

+ DisableComputeChecksums bool

+ func New(config aws.Config) *SQS

+ func (c *SQS) AddPermissionRequest(input *AddPermissionInput) AddPermissionRequest

+ func (c *SQS) ChangeMessageVisibilityBatchRequest(input *ChangeMessageVisibilityBatchInput) ChangeMessageVisibilityBatchRequest

+ func (c *SQS) ChangeMessageVisibilityRequest(input *ChangeMessageVisibilityInput) ChangeMessageVisibilityRequest

+ func (c *SQS) CreateQueueRequest(input *CreateQueueInput) CreateQueueRequest

+ func (c *SQS) DeleteMessageBatchRequest(input *DeleteMessageBatchInput) DeleteMessageBatchRequest

+ func (c *SQS) DeleteMessageRequest(input *DeleteMessageInput) DeleteMessageRequest

+ func (c *SQS) DeleteQueueRequest(input *DeleteQueueInput) DeleteQueueRequest

+ func (c *SQS) GetQueueAttributesRequest(input *GetQueueAttributesInput) GetQueueAttributesRequest

+ func (c *SQS) GetQueueUrlRequest(input *GetQueueUrlInput) GetQueueUrlRequest

+ func (c *SQS) ListDeadLetterSourceQueuesRequest(input *ListDeadLetterSourceQueuesInput) ListDeadLetterSourceQueuesRequest

+ func (c *SQS) ListQueuesRequest(input *ListQueuesInput) ListQueuesRequest

+ func (c *SQS) PurgeQueueRequest(input *PurgeQueueInput) PurgeQueueRequest

+ func (c *SQS) ReceiveMessageRequest(input *ReceiveMessageInput) ReceiveMessageRequest

+ func (c *SQS) RemovePermissionRequest(input *RemovePermissionInput) RemovePermissionRequest

+ func (c *SQS) SendMessageBatchRequest(input *SendMessageBatchInput) SendMessageBatchRequest

+ func (c *SQS) SendMessageRequest(input *SendMessageInput) SendMessageRequest

+ func (c *SQS) SetQueueAttributesRequest(input *SetQueueAttributesInput) SetQueueAttributesRequest

+ type SendMessageBatchInput struct

+ Entries []SendMessageBatchRequestEntry

+ QueueUrl *string

+ func (s *SendMessageBatchInput) SetEntries(v []SendMessageBatchRequestEntry) *SendMessageBatchInput

+ func (s *SendMessageBatchInput) SetQueueUrl(v string) *SendMessageBatchInput

+ func (s *SendMessageBatchInput) Validate() error

+ func (s SendMessageBatchInput) GoString() string

+ func (s SendMessageBatchInput) String() string

+ type SendMessageBatchOutput struct

+ Failed []BatchResultErrorEntry

+ Successful []SendMessageBatchResultEntry

+ func (s *SendMessageBatchOutput) SetFailed(v []BatchResultErrorEntry) *SendMessageBatchOutput

+ func (s *SendMessageBatchOutput) SetSuccessful(v []SendMessageBatchResultEntry) *SendMessageBatchOutput

+ func (s SendMessageBatchOutput) GoString() string

+ func (s SendMessageBatchOutput) SDKResponseMetadata() aws.Response

+ func (s SendMessageBatchOutput) String() string

+ type SendMessageBatchRequest struct

+ Input *SendMessageBatchInput

+ func (r SendMessageBatchRequest) Send() (*SendMessageBatchOutput, error)

+ type SendMessageBatchRequestEntry struct

+ DelaySeconds *int64

+ Id *string

+ MessageAttributes map[string]MessageAttributeValue

+ MessageBody *string

+ MessageDeduplicationId *string

+ MessageGroupId *string

+ func (s *SendMessageBatchRequestEntry) SetDelaySeconds(v int64) *SendMessageBatchRequestEntry

+ func (s *SendMessageBatchRequestEntry) SetId(v string) *SendMessageBatchRequestEntry

+ func (s *SendMessageBatchRequestEntry) SetMessageAttributes(v map[string]MessageAttributeValue) *SendMessageBatchRequestEntry

+ func (s *SendMessageBatchRequestEntry) SetMessageBody(v string) *SendMessageBatchRequestEntry

+ func (s *SendMessageBatchRequestEntry) SetMessageDeduplicationId(v string) *SendMessageBatchRequestEntry

+ func (s *SendMessageBatchRequestEntry) SetMessageGroupId(v string) *SendMessageBatchRequestEntry

+ func (s *SendMessageBatchRequestEntry) Validate() error

+ func (s SendMessageBatchRequestEntry) GoString() string

+ func (s SendMessageBatchRequestEntry) String() string

+ type SendMessageBatchResultEntry struct

+ Id *string

+ MD5OfMessageAttributes *string

+ MD5OfMessageBody *string

+ MessageId *string

+ SequenceNumber *string

+ func (s *SendMessageBatchResultEntry) SetId(v string) *SendMessageBatchResultEntry

+ func (s *SendMessageBatchResultEntry) SetMD5OfMessageAttributes(v string) *SendMessageBatchResultEntry

+ func (s *SendMessageBatchResultEntry) SetMD5OfMessageBody(v string) *SendMessageBatchResultEntry

+ func (s *SendMessageBatchResultEntry) SetMessageId(v string) *SendMessageBatchResultEntry

+ func (s *SendMessageBatchResultEntry) SetSequenceNumber(v string) *SendMessageBatchResultEntry

+ func (s SendMessageBatchResultEntry) GoString() string

+ func (s SendMessageBatchResultEntry) String() string

+ type SendMessageInput struct

+ DelaySeconds *int64

+ MessageAttributes map[string]MessageAttributeValue

+ MessageBody *string

+ MessageDeduplicationId *string

+ MessageGroupId *string

+ QueueUrl *string

+ func (s *SendMessageInput) SetDelaySeconds(v int64) *SendMessageInput

+ func (s *SendMessageInput) SetMessageAttributes(v map[string]MessageAttributeValue) *SendMessageInput

+ func (s *SendMessageInput) SetMessageBody(v string) *SendMessageInput

+ func (s *SendMessageInput) SetMessageDeduplicationId(v string) *SendMessageInput

+ func (s *SendMessageInput) SetMessageGroupId(v string) *SendMessageInput

+ func (s *SendMessageInput) SetQueueUrl(v string) *SendMessageInput

+ func (s *SendMessageInput) Validate() error

+ func (s SendMessageInput) GoString() string

+ func (s SendMessageInput) String() string

+ type SendMessageOutput struct

+ MD5OfMessageAttributes *string

+ MD5OfMessageBody *string

+ MessageId *string

+ SequenceNumber *string

+ func (s *SendMessageOutput) SetMD5OfMessageAttributes(v string) *SendMessageOutput

+ func (s *SendMessageOutput) SetMD5OfMessageBody(v string) *SendMessageOutput

+ func (s *SendMessageOutput) SetMessageId(v string) *SendMessageOutput

+ func (s *SendMessageOutput) SetSequenceNumber(v string) *SendMessageOutput

+ func (s SendMessageOutput) GoString() string

+ func (s SendMessageOutput) SDKResponseMetadata() aws.Response

+ func (s SendMessageOutput) String() string

+ type SendMessageRequest struct

+ Input *SendMessageInput

+ func (r SendMessageRequest) Send() (*SendMessageOutput, error)

+ type SetQueueAttributesInput struct

+ Attributes map[string]string

+ QueueUrl *string

+ func (s *SetQueueAttributesInput) SetAttributes(v map[string]string) *SetQueueAttributesInput

+ func (s *SetQueueAttributesInput) SetQueueUrl(v string) *SetQueueAttributesInput

+ func (s *SetQueueAttributesInput) Validate() error

+ func (s SetQueueAttributesInput) GoString() string

+ func (s SetQueueAttributesInput) String() string

+ type SetQueueAttributesOutput struct

+ func (s SetQueueAttributesOutput) GoString() string

+ func (s SetQueueAttributesOutput) SDKResponseMetadata() aws.Response

+ func (s SetQueueAttributesOutput) String() string

+ type SetQueueAttributesRequest struct

+ Input *SetQueueAttributesInput

+ func (r SetQueueAttributesRequest) Send() (*SetQueueAttributesOutput, error)

Incompatible versions in this module

v2.0.0-preview.4+incompatible

May 26, 2018

v2.0.0-preview.3+incompatible

Mar 8, 2018

v2.0.0-preview.2+incompatible

Jan 15, 2018

v2.0.0-preview.1+incompatible

Dec 21, 2017

Other modules containing this package

github.com/aws/aws-sdk-go-v2/service/sqs

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL