sqs

package

Go to main page

Versions in this module

v0

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)

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