Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 api.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package sqs import ( "fmt" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/awsutil" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/private/protocol" "github.com/aws/aws-sdk-go/private/protocol/jsonrpc" ) const opAddPermission = "AddPermission" // AddPermissionRequest generates a "aws/request.Request" representing the // client's request for the AddPermission operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See AddPermission for more information on using the AddPermission // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the AddPermissionRequest method. // req, resp := client.AddPermissionRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/AddPermission func (c SQS) AddPermissionRequest(input AddPermissionInput) (req request.Request, output AddPermissionOutput) { op := &request.Operation{ Name: opAddPermission, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &AddPermissionInput{} } output = &AddPermissionOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // AddPermission API operation for Amazon Simple Queue Service. // // Adds a permission to a queue for a specific principal (https://docs.aws.amazon.com/general/latest/gr/glos-chap.html#P). // This allows sharing access to the queue. // // When you create a queue, you have full control access rights for the queue. // Only you, the owner of the queue, can grant or deny permissions to the queue. // For more information about these permissions, see Allow Developers to Write // Messages to a Shared Queue (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-writing-an-sqs-policy.html#write-messages-to-shared-queue) // in the Amazon SQS Developer Guide. // // - AddPermission generates a policy for you. You can use SetQueueAttributes // to upload your policy. For more information, see Using Custom Policies // with the Amazon SQS Access Policy Language (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-creating-custom-policies.html) // in the Amazon SQS Developer Guide. // // - An Amazon SQS policy can have a maximum of seven actions per statement. // // - To remove the ability to change queue permissions, you must deny permission // to the AddPermission, RemovePermission, and SetQueueAttributes actions // in your IAM policy. // // - Amazon SQS AddPermission does not support adding a non-account principal. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation AddPermission for usage and error information. // // Returned Error Types: // // - OverLimit // The specified action violates a limit. For example, ReceiveMessage returns // this error if the maximum number of in flight messages is reached and AddPermission // returns this error if the maximum number of permissions for the queue is // reached. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/AddPermission func (c SQS) AddPermission(input AddPermissionInput) (AddPermissionOutput, error) { req, out := c.AddPermissionRequest(input) return out, req.Send() } // AddPermissionWithContext is the same as AddPermission with the addition of // the ability to pass a context and additional request options. // // See AddPermission for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) AddPermissionWithContext(ctx aws.Context, input AddPermissionInput, opts ...request.Option) (AddPermissionOutput, error) { req, out := c.AddPermissionRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opCancelMessageMoveTask = "CancelMessageMoveTask" // CancelMessageMoveTaskRequest generates a "aws/request.Request" representing the // client's request for the CancelMessageMoveTask operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See CancelMessageMoveTask for more information on using the CancelMessageMoveTask // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the CancelMessageMoveTaskRequest method. // req, resp := client.CancelMessageMoveTaskRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/CancelMessageMoveTask func (c SQS) CancelMessageMoveTaskRequest(input CancelMessageMoveTaskInput) (req request.Request, output CancelMessageMoveTaskOutput) { op := &request.Operation{ Name: opCancelMessageMoveTask, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &CancelMessageMoveTaskInput{} } output = &CancelMessageMoveTaskOutput{} req = c.newRequest(op, input, output) return } // CancelMessageMoveTask API operation for Amazon Simple Queue Service. // // Cancels a specified message movement task. A message movement can only be // cancelled when the current status is RUNNING. Cancelling a message movement // task does not revert the messages that have already been moved. It can only // stop the messages that have not been moved yet. // // - This action is currently limited to supporting message redrive from // dead-letter queues (DLQs) (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html) // only. In this context, the source queue is the dead-letter queue (DLQ), // while the destination queue can be the original source queue (from which // the messages were driven to the dead-letter-queue), or a custom destination // queue. // // - Only one active message movement task is supported per queue at any // given time. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation CancelMessageMoveTask for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // One or more specified resources don't exist. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/CancelMessageMoveTask func (c SQS) CancelMessageMoveTask(input CancelMessageMoveTaskInput) (CancelMessageMoveTaskOutput, error) { req, out := c.CancelMessageMoveTaskRequest(input) return out, req.Send() } // CancelMessageMoveTaskWithContext is the same as CancelMessageMoveTask with the addition of // the ability to pass a context and additional request options. // // See CancelMessageMoveTask for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) CancelMessageMoveTaskWithContext(ctx aws.Context, input CancelMessageMoveTaskInput, opts ...request.Option) (CancelMessageMoveTaskOutput, error) { req, out := c.CancelMessageMoveTaskRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opChangeMessageVisibility = "ChangeMessageVisibility" // ChangeMessageVisibilityRequest generates a "aws/request.Request" representing the // client's request for the ChangeMessageVisibility operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ChangeMessageVisibility for more information on using the ChangeMessageVisibility // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ChangeMessageVisibilityRequest method. // req, resp := client.ChangeMessageVisibilityRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ChangeMessageVisibility func (c SQS) ChangeMessageVisibilityRequest(input ChangeMessageVisibilityInput) (req request.Request, output ChangeMessageVisibilityOutput) { op := &request.Operation{ Name: opChangeMessageVisibility, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &ChangeMessageVisibilityInput{} } output = &ChangeMessageVisibilityOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // ChangeMessageVisibility API operation for Amazon Simple Queue Service. // // Changes the visibility timeout of a specified message in a queue to a new // value. The default visibility timeout for a message is 30 seconds. The minimum // is 0 seconds. The maximum is 12 hours. For more information, see Visibility // Timeout (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html) // in the Amazon SQS Developer Guide. // // For example, if the default timeout for a queue is 60 seconds, 15 seconds // have elapsed since you received the message, and you send a ChangeMessageVisibility // call with VisibilityTimeout set to 10 seconds, the 10 seconds begin to count // from the time that you make the ChangeMessageVisibility call. Thus, any attempt // to change the visibility timeout or to delete that message 10 seconds after // you initially change the visibility timeout (a total of 25 seconds) might // result in an error. // // An Amazon SQS message has three basic states: // // Sent to a queue by a producer. // // Received from the queue by a consumer. // // Deleted from the queue. // // A message is considered to be stored after it is sent to a queue by a producer, // but not yet received from the queue by a consumer (that is, between states // 1 and 2). There is no limit to the number of stored messages. A message is // considered to be in flight after it is received from a queue by a consumer, // but not yet deleted from the queue (that is, between states 2 and 3). There // is a limit to the number of in flight messages. // // Limits that apply to in flight messages are unrelated to the unlimited number // of stored messages. // // For most standard queues (depending on queue traffic and message backlog), // there can be a maximum of approximately 120,000 in flight messages (received // from a queue by a consumer, but not yet deleted from the queue). If you reach // this limit, Amazon SQS returns the OverLimit error message. To avoid reaching // the limit, you should delete messages from the queue after they're processed. // You can also increase the number of queues you use to process your messages. // To request a limit increase, file a support request (https://console.aws.amazon.com/support/home#/case/create?issueType=service-limit-increase&limitType=service-code-sqs). // // For FIFO queues, there can be a maximum of 20,000 in flight messages (received // from a queue by a consumer, but not yet deleted from the queue). If you reach // this limit, Amazon SQS returns no error messages. // // If you attempt to set the VisibilityTimeout to a value greater than the maximum // time left, Amazon SQS returns an error. Amazon SQS doesn't automatically // recalculate and increase the timeout to the maximum remaining time. // // Unlike with a queue, when you change the visibility timeout for a specific // message the timeout value is applied immediately but isn't saved in memory // for that message. If you don't delete a message after it is received, the // visibility timeout for the message reverts to the original timeout value // (not to the value you set using the ChangeMessageVisibility action) the next // time the message is received. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation ChangeMessageVisibility for usage and error information. // // Returned Error Types: // // - MessageNotInflight // The specified message isn't in flight. // // - ReceiptHandleIsInvalid // The specified receipt handle isn't valid. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ChangeMessageVisibility func (c SQS) ChangeMessageVisibility(input ChangeMessageVisibilityInput) (ChangeMessageVisibilityOutput, error) { req, out := c.ChangeMessageVisibilityRequest(input) return out, req.Send() } // ChangeMessageVisibilityWithContext is the same as ChangeMessageVisibility with the addition of // the ability to pass a context and additional request options. // // See ChangeMessageVisibility for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ChangeMessageVisibilityWithContext(ctx aws.Context, input ChangeMessageVisibilityInput, opts ...request.Option) (ChangeMessageVisibilityOutput, error) { req, out := c.ChangeMessageVisibilityRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opChangeMessageVisibilityBatch = "ChangeMessageVisibilityBatch" // ChangeMessageVisibilityBatchRequest generates a "aws/request.Request" representing the // client's request for the ChangeMessageVisibilityBatch operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ChangeMessageVisibilityBatch for more information on using the ChangeMessageVisibilityBatch // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ChangeMessageVisibilityBatchRequest method. // req, resp := client.ChangeMessageVisibilityBatchRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ChangeMessageVisibilityBatch func (c SQS) ChangeMessageVisibilityBatchRequest(input ChangeMessageVisibilityBatchInput) (req request.Request, output ChangeMessageVisibilityBatchOutput) { op := &request.Operation{ Name: opChangeMessageVisibilityBatch, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &ChangeMessageVisibilityBatchInput{} } output = &ChangeMessageVisibilityBatchOutput{} req = c.newRequest(op, input, output) return } // ChangeMessageVisibilityBatch API operation for Amazon Simple Queue Service. // // Changes the visibility timeout of multiple messages. This is a batch version // of ChangeMessageVisibility. The result of the action on each message is reported // individually in the response. You can send up to 10 ChangeMessageVisibility // requests with each ChangeMessageVisibilityBatch action. // // Because the batch request can result in a combination of successful and unsuccessful // actions, you should check for batch errors even when the call returns an // HTTP status code of 200. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation ChangeMessageVisibilityBatch for usage and error information. // // Returned Error Types: // // - TooManyEntriesInBatchRequest // The batch request contains more entries than permissible. // // - EmptyBatchRequest // The batch request doesn't contain any entries. // // - BatchEntryIdsNotDistinct // Two or more batch entries in the request have the same Id. // // - InvalidBatchEntryId // The Id of a batch entry in a batch request doesn't abide by the specification. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ChangeMessageVisibilityBatch func (c SQS) ChangeMessageVisibilityBatch(input ChangeMessageVisibilityBatchInput) (ChangeMessageVisibilityBatchOutput, error) { req, out := c.ChangeMessageVisibilityBatchRequest(input) return out, req.Send() } // ChangeMessageVisibilityBatchWithContext is the same as ChangeMessageVisibilityBatch with the addition of // the ability to pass a context and additional request options. // // See ChangeMessageVisibilityBatch for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ChangeMessageVisibilityBatchWithContext(ctx aws.Context, input ChangeMessageVisibilityBatchInput, opts ...request.Option) (ChangeMessageVisibilityBatchOutput, error) { req, out := c.ChangeMessageVisibilityBatchRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opCreateQueue = "CreateQueue" // CreateQueueRequest generates a "aws/request.Request" representing the // client's request for the CreateQueue operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See CreateQueue for more information on using the CreateQueue // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the CreateQueueRequest method. // req, resp := client.CreateQueueRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/CreateQueue func (c SQS) CreateQueueRequest(input CreateQueueInput) (req request.Request, output CreateQueueOutput) { op := &request.Operation{ Name: opCreateQueue, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &CreateQueueInput{} } output = &CreateQueueOutput{} req = c.newRequest(op, input, output) return } // CreateQueue API operation for Amazon Simple Queue Service. // // Creates a new standard or FIFO queue. You can pass one or more attributes // in the request. Keep the following in mind: // // - If you don't specify the FifoQueue attribute, Amazon SQS creates a standard // queue. You can't change the queue type after you create it and you can't // convert an existing standard queue into a FIFO queue. You must either // create a new FIFO queue for your application or delete your existing standard // queue and recreate it as a FIFO queue. For more information, see Moving // From a Standard Queue to a FIFO Queue (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues.html#FIFO-queues-moving) // in the Amazon SQS Developer Guide. // // - If you don't provide a value for an attribute, the queue is created // with the default value for the attribute. // // - If you delete a queue, you must wait at least 60 seconds before creating // a queue with the same name. // // To successfully create a new queue, you must provide a queue name that adheres // to the limits related to queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/limits-queues.html) // and is unique within the scope of your queues. // // After you create a queue, you must wait at least one second after the queue // is created to be able to use the queue. // // To get the queue URL, use the GetQueueUrl action. GetQueueUrl requires only // the QueueName parameter. be aware of existing queue names: // // - If you provide the name of an existing queue along with the exact names // and values of all the queue's attributes, CreateQueue returns the queue // URL for the existing queue. // // - If the queue name, attribute names, or attribute values don't match // an existing queue, CreateQueue returns an error. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation CreateQueue for usage and error information. // // Returned Error Types: // // - QueueDeletedRecently // You must wait 60 seconds after deleting a queue before you can create another // queue with the same name. // // - QueueNameExists // A queue with this name already exists. Amazon SQS returns this error only // if the request includes attributes whose values differ from those of the // existing queue. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - InvalidAddress // The accountId is invalid. // // - InvalidAttributeName // The specified attribute doesn't exist. // // - InvalidAttributeValue // A queue attribute value is invalid. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/CreateQueue func (c SQS) CreateQueue(input CreateQueueInput) (CreateQueueOutput, error) { req, out := c.CreateQueueRequest(input) return out, req.Send() } // CreateQueueWithContext is the same as CreateQueue with the addition of // the ability to pass a context and additional request options. // // See CreateQueue for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) CreateQueueWithContext(ctx aws.Context, input CreateQueueInput, opts ...request.Option) (CreateQueueOutput, error) { req, out := c.CreateQueueRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opDeleteMessage = "DeleteMessage" // DeleteMessageRequest generates a "aws/request.Request" representing the // client's request for the DeleteMessage operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See DeleteMessage for more information on using the DeleteMessage // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the DeleteMessageRequest method. // req, resp := client.DeleteMessageRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/DeleteMessage func (c SQS) DeleteMessageRequest(input DeleteMessageInput) (req request.Request, output DeleteMessageOutput) { op := &request.Operation{ Name: opDeleteMessage, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &DeleteMessageInput{} } output = &DeleteMessageOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // DeleteMessage API operation for Amazon Simple Queue Service. // // Deletes the specified message from the specified queue. To select the message // to delete, use the ReceiptHandle of the message (not the MessageId which // you receive when you send the message). Amazon SQS can delete a message from // a queue even if a visibility timeout setting causes the message to be locked // by another consumer. Amazon SQS automatically deletes messages left in a // queue longer than the retention period configured for the queue. // // The ReceiptHandle is associated with a specific instance of receiving a message. // If you receive a message more than once, the ReceiptHandle is different each // time you receive a message. When you use the DeleteMessage action, you must // provide the most recently received ReceiptHandle for the message (otherwise, // the request succeeds, but the message will not be deleted). // // For standard queues, it is possible to receive a message even after you delete // it. This might happen on rare occasions if one of the servers which stores // a copy of the message is unavailable when you send the request to delete // the message. The copy remains on the server and might be returned to you // during a subsequent receive request. You should ensure that your application // is idempotent, so that receiving a message more than once does not cause // issues. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation DeleteMessage for usage and error information. // // Returned Error Types: // // - InvalidIdFormat // The specified receipt handle isn't valid for the current version. // // - ReceiptHandleIsInvalid // The specified receipt handle isn't valid. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - InvalidAddress // The accountId is invalid. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/DeleteMessage func (c SQS) DeleteMessage(input DeleteMessageInput) (DeleteMessageOutput, error) { req, out := c.DeleteMessageRequest(input) return out, req.Send() } // DeleteMessageWithContext is the same as DeleteMessage with the addition of // the ability to pass a context and additional request options. // // See DeleteMessage for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) DeleteMessageWithContext(ctx aws.Context, input DeleteMessageInput, opts ...request.Option) (DeleteMessageOutput, error) { req, out := c.DeleteMessageRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opDeleteMessageBatch = "DeleteMessageBatch" // DeleteMessageBatchRequest generates a "aws/request.Request" representing the // client's request for the DeleteMessageBatch operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See DeleteMessageBatch for more information on using the DeleteMessageBatch // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the DeleteMessageBatchRequest method. // req, resp := client.DeleteMessageBatchRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/DeleteMessageBatch func (c SQS) DeleteMessageBatchRequest(input DeleteMessageBatchInput) (req request.Request, output DeleteMessageBatchOutput) { op := &request.Operation{ Name: opDeleteMessageBatch, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &DeleteMessageBatchInput{} } output = &DeleteMessageBatchOutput{} req = c.newRequest(op, input, output) return } // DeleteMessageBatch API operation for Amazon Simple Queue Service. // // Deletes up to ten messages from the specified queue. This is a batch version // of DeleteMessage. The result of the action on each message is reported individually // in the response. // // Because the batch request can result in a combination of successful and unsuccessful // actions, you should check for batch errors even when the call returns an // HTTP status code of 200. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation DeleteMessageBatch for usage and error information. // // Returned Error Types: // // - TooManyEntriesInBatchRequest // The batch request contains more entries than permissible. // // - EmptyBatchRequest // The batch request doesn't contain any entries. // // - BatchEntryIdsNotDistinct // Two or more batch entries in the request have the same Id. // // - InvalidBatchEntryId // The Id of a batch entry in a batch request doesn't abide by the specification. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/DeleteMessageBatch func (c SQS) DeleteMessageBatch(input DeleteMessageBatchInput) (DeleteMessageBatchOutput, error) { req, out := c.DeleteMessageBatchRequest(input) return out, req.Send() } // DeleteMessageBatchWithContext is the same as DeleteMessageBatch with the addition of // the ability to pass a context and additional request options. // // See DeleteMessageBatch for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) DeleteMessageBatchWithContext(ctx aws.Context, input DeleteMessageBatchInput, opts ...request.Option) (DeleteMessageBatchOutput, error) { req, out := c.DeleteMessageBatchRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opDeleteQueue = "DeleteQueue" // DeleteQueueRequest generates a "aws/request.Request" representing the // client's request for the DeleteQueue operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See DeleteQueue for more information on using the DeleteQueue // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the DeleteQueueRequest method. // req, resp := client.DeleteQueueRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/DeleteQueue func (c SQS) DeleteQueueRequest(input DeleteQueueInput) (req request.Request, output DeleteQueueOutput) { op := &request.Operation{ Name: opDeleteQueue, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &DeleteQueueInput{} } output = &DeleteQueueOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // DeleteQueue API operation for Amazon Simple Queue Service. // // Deletes the queue specified by the QueueUrl, regardless of the queue's contents. // // Be careful with the DeleteQueue action: When you delete a queue, any messages // in the queue are no longer available. // // When you delete a queue, the deletion process takes up to 60 seconds. Requests // you send involving that queue during the 60 seconds might succeed. For example, // a SendMessage request might succeed, but after 60 seconds the queue and the // message you sent no longer exist. // // When you delete a queue, you must wait at least 60 seconds before creating // a queue with the same name. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // The delete operation uses the HTTP GET verb. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation DeleteQueue for usage and error information. // // Returned Error Types: // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidAddress // The accountId is invalid. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/DeleteQueue func (c SQS) DeleteQueue(input DeleteQueueInput) (DeleteQueueOutput, error) { req, out := c.DeleteQueueRequest(input) return out, req.Send() } // DeleteQueueWithContext is the same as DeleteQueue with the addition of // the ability to pass a context and additional request options. // // See DeleteQueue for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) DeleteQueueWithContext(ctx aws.Context, input DeleteQueueInput, opts ...request.Option) (DeleteQueueOutput, error) { req, out := c.DeleteQueueRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetQueueAttributes = "GetQueueAttributes" // GetQueueAttributesRequest generates a "aws/request.Request" representing the // client's request for the GetQueueAttributes operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetQueueAttributes for more information on using the GetQueueAttributes // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetQueueAttributesRequest method. // req, resp := client.GetQueueAttributesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/GetQueueAttributes func (c SQS) GetQueueAttributesRequest(input GetQueueAttributesInput) (req request.Request, output GetQueueAttributesOutput) { op := &request.Operation{ Name: opGetQueueAttributes, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &GetQueueAttributesInput{} } output = &GetQueueAttributesOutput{} req = c.newRequest(op, input, output) return } // GetQueueAttributes API operation for Amazon Simple Queue Service. // // Gets attributes for the specified queue. // // To determine whether a queue is FIFO (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues.html), // you can check whether QueueName ends with the .fifo suffix. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation GetQueueAttributes for usage and error information. // // Returned Error Types: // // - InvalidAttributeName // The specified attribute doesn't exist. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - InvalidAddress // The accountId is invalid. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/GetQueueAttributes func (c SQS) GetQueueAttributes(input GetQueueAttributesInput) (GetQueueAttributesOutput, error) { req, out := c.GetQueueAttributesRequest(input) return out, req.Send() } // GetQueueAttributesWithContext is the same as GetQueueAttributes with the addition of // the ability to pass a context and additional request options. // // See GetQueueAttributes for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) GetQueueAttributesWithContext(ctx aws.Context, input GetQueueAttributesInput, opts ...request.Option) (GetQueueAttributesOutput, error) { req, out := c.GetQueueAttributesRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetQueueUrl = "GetQueueUrl" // GetQueueUrlRequest generates a "aws/request.Request" representing the // client's request for the GetQueueUrl operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetQueueUrl for more information on using the GetQueueUrl // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetQueueUrlRequest method. // req, resp := client.GetQueueUrlRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/GetQueueUrl func (c SQS) GetQueueUrlRequest(input GetQueueUrlInput) (req request.Request, output GetQueueUrlOutput) { op := &request.Operation{ Name: opGetQueueUrl, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &GetQueueUrlInput{} } output = &GetQueueUrlOutput{} req = c.newRequest(op, input, output) return } // GetQueueUrl API operation for Amazon Simple Queue Service. // // Returns the URL of an existing Amazon SQS queue. // // To access a queue that belongs to another AWS account, use the QueueOwnerAWSAccountId // parameter to specify the account ID of the queue's owner. The queue's owner // must grant you permission to access the queue. For more information about // shared queue access, see AddPermission or see Allow Developers to Write Messages // to a Shared Queue (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-writing-an-sqs-policy.html#write-messages-to-shared-queue) // in the Amazon SQS Developer Guide. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation GetQueueUrl for usage and error information. // // Returned Error Types: // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/GetQueueUrl func (c SQS) GetQueueUrl(input GetQueueUrlInput) (GetQueueUrlOutput, error) { req, out := c.GetQueueUrlRequest(input) return out, req.Send() } // GetQueueUrlWithContext is the same as GetQueueUrl with the addition of // the ability to pass a context and additional request options. // // See GetQueueUrl for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) GetQueueUrlWithContext(ctx aws.Context, input GetQueueUrlInput, opts ...request.Option) (GetQueueUrlOutput, error) { req, out := c.GetQueueUrlRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opListDeadLetterSourceQueues = "ListDeadLetterSourceQueues" // ListDeadLetterSourceQueuesRequest generates a "aws/request.Request" representing the // client's request for the ListDeadLetterSourceQueues operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListDeadLetterSourceQueues for more information on using the ListDeadLetterSourceQueues // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListDeadLetterSourceQueuesRequest method. // req, resp := client.ListDeadLetterSourceQueuesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ListDeadLetterSourceQueues func (c SQS) ListDeadLetterSourceQueuesRequest(input ListDeadLetterSourceQueuesInput) (req request.Request, output ListDeadLetterSourceQueuesOutput) { op := &request.Operation{ Name: opListDeadLetterSourceQueues, HTTPMethod: "POST", HTTPPath: "/", Paginator: &request.Paginator{ InputTokens: []string{"NextToken"}, OutputTokens: []string{"NextToken"}, LimitToken: "MaxResults", TruncationToken: "", }, } if input == nil { input = &ListDeadLetterSourceQueuesInput{} } output = &ListDeadLetterSourceQueuesOutput{} req = c.newRequest(op, input, output) return } // ListDeadLetterSourceQueues API operation for Amazon Simple Queue Service. // // Returns a list of your queues that have the RedrivePolicy queue attribute // configured with a dead-letter queue. // // The ListDeadLetterSourceQueues methods supports pagination. Set parameter // MaxResults in the request to specify the maximum number of results to be // returned in the response. If you do not set MaxResults, the response includes // a maximum of 1,000 results. If you set MaxResults and there are additional // results to display, the response includes a value for NextToken. Use NextToken // as a parameter in your next request to ListDeadLetterSourceQueues to receive // the next page of results. // // For more information about using dead-letter queues, see Using Amazon SQS // Dead-Letter Queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html) // in the Amazon SQS Developer Guide. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation ListDeadLetterSourceQueues for usage and error information. // // Returned Error Types: // // - QueueDoesNotExist // The specified queue doesn't exist. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - InvalidAddress // The accountId is invalid. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ListDeadLetterSourceQueues func (c SQS) ListDeadLetterSourceQueues(input ListDeadLetterSourceQueuesInput) (ListDeadLetterSourceQueuesOutput, error) { req, out := c.ListDeadLetterSourceQueuesRequest(input) return out, req.Send() } // ListDeadLetterSourceQueuesWithContext is the same as ListDeadLetterSourceQueues with the addition of // the ability to pass a context and additional request options. // // See ListDeadLetterSourceQueues for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ListDeadLetterSourceQueuesWithContext(ctx aws.Context, input ListDeadLetterSourceQueuesInput, opts ...request.Option) (ListDeadLetterSourceQueuesOutput, error) { req, out := c.ListDeadLetterSourceQueuesRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListDeadLetterSourceQueuesPages iterates over the pages of a ListDeadLetterSourceQueues operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListDeadLetterSourceQueues method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListDeadLetterSourceQueues operation. // pageNum := 0 // err := client.ListDeadLetterSourceQueuesPages(params, // func(page sqs.ListDeadLetterSourceQueuesOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c SQS) ListDeadLetterSourceQueuesPages(input ListDeadLetterSourceQueuesInput, fn func(ListDeadLetterSourceQueuesOutput, bool) bool) error { return c.ListDeadLetterSourceQueuesPagesWithContext(aws.BackgroundContext(), input, fn) } // ListDeadLetterSourceQueuesPagesWithContext same as ListDeadLetterSourceQueuesPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ListDeadLetterSourceQueuesPagesWithContext(ctx aws.Context, input ListDeadLetterSourceQueuesInput, fn func(ListDeadLetterSourceQueuesOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (request.Request, error) { var inCpy ListDeadLetterSourceQueuesInput if input != nil { tmp := input inCpy = &tmp } req, _ := c.ListDeadLetterSourceQueuesRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(ListDeadLetterSourceQueuesOutput), !p.HasNextPage()) { break } } return p.Err() } const opListMessageMoveTasks = "ListMessageMoveTasks" // ListMessageMoveTasksRequest generates a "aws/request.Request" representing the // client's request for the ListMessageMoveTasks operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListMessageMoveTasks for more information on using the ListMessageMoveTasks // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListMessageMoveTasksRequest method. // req, resp := client.ListMessageMoveTasksRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ListMessageMoveTasks func (c SQS) ListMessageMoveTasksRequest(input ListMessageMoveTasksInput) (req request.Request, output ListMessageMoveTasksOutput) { op := &request.Operation{ Name: opListMessageMoveTasks, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &ListMessageMoveTasksInput{} } output = &ListMessageMoveTasksOutput{} req = c.newRequest(op, input, output) return } // ListMessageMoveTasks API operation for Amazon Simple Queue Service. // // Gets the most recent message movement tasks (up to 10) under a specific source // queue. // // - This action is currently limited to supporting message redrive from // dead-letter queues (DLQs) (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html) // only. In this context, the source queue is the dead-letter queue (DLQ), // while the destination queue can be the original source queue (from which // the messages were driven to the dead-letter-queue), or a custom destination // queue. // // - Only one active message movement task is supported per queue at any // given time. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation ListMessageMoveTasks for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // One or more specified resources don't exist. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ListMessageMoveTasks func (c SQS) ListMessageMoveTasks(input ListMessageMoveTasksInput) (ListMessageMoveTasksOutput, error) { req, out := c.ListMessageMoveTasksRequest(input) return out, req.Send() } // ListMessageMoveTasksWithContext is the same as ListMessageMoveTasks with the addition of // the ability to pass a context and additional request options. // // See ListMessageMoveTasks for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ListMessageMoveTasksWithContext(ctx aws.Context, input ListMessageMoveTasksInput, opts ...request.Option) (ListMessageMoveTasksOutput, error) { req, out := c.ListMessageMoveTasksRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opListQueueTags = "ListQueueTags" // ListQueueTagsRequest generates a "aws/request.Request" representing the // client's request for the ListQueueTags operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListQueueTags for more information on using the ListQueueTags // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListQueueTagsRequest method. // req, resp := client.ListQueueTagsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ListQueueTags func (c SQS) ListQueueTagsRequest(input ListQueueTagsInput) (req request.Request, output ListQueueTagsOutput) { op := &request.Operation{ Name: opListQueueTags, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &ListQueueTagsInput{} } output = &ListQueueTagsOutput{} req = c.newRequest(op, input, output) return } // ListQueueTags API operation for Amazon Simple Queue Service. // // List all cost allocation tags added to the specified Amazon SQS queue. For // an overview, see Tagging Your Amazon SQS Queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-queue-tags.html) // in the Amazon SQS Developer Guide. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation ListQueueTags for usage and error information. // // Returned Error Types: // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ListQueueTags func (c SQS) ListQueueTags(input ListQueueTagsInput) (ListQueueTagsOutput, error) { req, out := c.ListQueueTagsRequest(input) return out, req.Send() } // ListQueueTagsWithContext is the same as ListQueueTags with the addition of // the ability to pass a context and additional request options. // // See ListQueueTags for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ListQueueTagsWithContext(ctx aws.Context, input ListQueueTagsInput, opts ...request.Option) (ListQueueTagsOutput, error) { req, out := c.ListQueueTagsRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opListQueues = "ListQueues" // ListQueuesRequest generates a "aws/request.Request" representing the // client's request for the ListQueues operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListQueues for more information on using the ListQueues // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListQueuesRequest method. // req, resp := client.ListQueuesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ListQueues func (c SQS) ListQueuesRequest(input ListQueuesInput) (req request.Request, output ListQueuesOutput) { op := &request.Operation{ Name: opListQueues, HTTPMethod: "POST", HTTPPath: "/", Paginator: &request.Paginator{ InputTokens: []string{"NextToken"}, OutputTokens: []string{"NextToken"}, LimitToken: "MaxResults", TruncationToken: "", }, } if input == nil { input = &ListQueuesInput{} } output = &ListQueuesOutput{} req = c.newRequest(op, input, output) return } // ListQueues API operation for Amazon Simple Queue Service. // // Returns a list of your queues in the current region. The response includes // a maximum of 1,000 results. If you specify a value for the optional QueueNamePrefix // parameter, only queues with a name that begins with the specified value are // returned. // // The listQueues methods supports pagination. Set parameter MaxResults in the // request to specify the maximum number of results to be returned in the response. // If you do not set MaxResults, the response includes a maximum of 1,000 results. // If you set MaxResults and there are additional results to display, the response // includes a value for NextToken. Use NextToken as a parameter in your next // request to listQueues to receive the next page of results. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation ListQueues for usage and error information. // // Returned Error Types: // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - InvalidAddress // The accountId is invalid. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ListQueues func (c SQS) ListQueues(input ListQueuesInput) (ListQueuesOutput, error) { req, out := c.ListQueuesRequest(input) return out, req.Send() } // ListQueuesWithContext is the same as ListQueues with the addition of // the ability to pass a context and additional request options. // // See ListQueues for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ListQueuesWithContext(ctx aws.Context, input ListQueuesInput, opts ...request.Option) (ListQueuesOutput, error) { req, out := c.ListQueuesRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListQueuesPages iterates over the pages of a ListQueues operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListQueues method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListQueues operation. // pageNum := 0 // err := client.ListQueuesPages(params, // func(page sqs.ListQueuesOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c SQS) ListQueuesPages(input ListQueuesInput, fn func(ListQueuesOutput, bool) bool) error { return c.ListQueuesPagesWithContext(aws.BackgroundContext(), input, fn) } // ListQueuesPagesWithContext same as ListQueuesPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ListQueuesPagesWithContext(ctx aws.Context, input ListQueuesInput, fn func(ListQueuesOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (request.Request, error) { var inCpy ListQueuesInput if input != nil { tmp := input inCpy = &tmp } req, _ := c.ListQueuesRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(ListQueuesOutput), !p.HasNextPage()) { break } } return p.Err() } const opPurgeQueue = "PurgeQueue" // PurgeQueueRequest generates a "aws/request.Request" representing the // client's request for the PurgeQueue operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See PurgeQueue for more information on using the PurgeQueue // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the PurgeQueueRequest method. // req, resp := client.PurgeQueueRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/PurgeQueue func (c SQS) PurgeQueueRequest(input PurgeQueueInput) (req request.Request, output PurgeQueueOutput) { op := &request.Operation{ Name: opPurgeQueue, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &PurgeQueueInput{} } output = &PurgeQueueOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // PurgeQueue API operation for Amazon Simple Queue Service. // // Deletes available messages in a queue (including in-flight messages) specified // by the QueueURL parameter. // // When you use the PurgeQueue action, you can't retrieve any messages deleted // from a queue. // // The message deletion process takes up to 60 seconds. We recommend waiting // for 60 seconds regardless of your queue's size. // // Messages sent to the queue before you call PurgeQueue might be received but // are deleted within the next minute. // // Messages sent to the queue after you call PurgeQueue might be deleted while // the queue is being purged. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation PurgeQueue for usage and error information. // // Returned Error Types: // // - QueueDoesNotExist // The specified queue doesn't exist. // // - PurgeQueueInProgress // Indicates that the specified queue previously received a PurgeQueue request // within the last 60 seconds (the time it can take to delete the messages in // the queue). // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/PurgeQueue func (c SQS) PurgeQueue(input PurgeQueueInput) (PurgeQueueOutput, error) { req, out := c.PurgeQueueRequest(input) return out, req.Send() } // PurgeQueueWithContext is the same as PurgeQueue with the addition of // the ability to pass a context and additional request options. // // See PurgeQueue for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) PurgeQueueWithContext(ctx aws.Context, input PurgeQueueInput, opts ...request.Option) (PurgeQueueOutput, error) { req, out := c.PurgeQueueRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opReceiveMessage = "ReceiveMessage" // ReceiveMessageRequest generates a "aws/request.Request" representing the // client's request for the ReceiveMessage operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ReceiveMessage for more information on using the ReceiveMessage // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ReceiveMessageRequest method. // req, resp := client.ReceiveMessageRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ReceiveMessage func (c SQS) ReceiveMessageRequest(input ReceiveMessageInput) (req request.Request, output ReceiveMessageOutput) { op := &request.Operation{ Name: opReceiveMessage, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &ReceiveMessageInput{} } output = &ReceiveMessageOutput{} req = c.newRequest(op, input, output) return } // ReceiveMessage API operation for Amazon Simple Queue Service. // // Retrieves one or more messages (up to 10), from the specified queue. Using // the WaitTimeSeconds parameter enables long-poll support. For more information, // see Amazon SQS Long Polling (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-long-polling.html) // in the Amazon SQS Developer Guide. // // Short poll is the default behavior where a weighted random set of machines // is sampled on a ReceiveMessage call. Thus, only the messages on the sampled // machines are returned. If the number of messages in the queue is small (fewer // than 1,000), you most likely get fewer messages than you requested per ReceiveMessage // call. If the number of messages in the queue is extremely small, you might // not receive any messages in a particular ReceiveMessage response. If this // happens, repeat the request. // // For each message returned, the response includes the following: // // - The message body. // // - An MD5 digest of the message body. For information about MD5, see RFC1321 // (https://www.ietf.org/rfc/rfc1321.txt). // // - The MessageId you received when you sent the message to the queue. // // - The receipt handle. // // - The message attributes. // // - An MD5 digest of the message attributes. // // The receipt handle is the identifier you must provide when deleting the message. // For more information, see Queue and Message Identifiers (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-queue-message-identifiers.html) // in the Amazon SQS Developer Guide. // // You can provide the VisibilityTimeout parameter in your request. The parameter // is applied to the messages that Amazon SQS returns in the response. If you // don't include the parameter, the overall visibility timeout for the queue // is used for the returned messages. For more information, see Visibility Timeout // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html) // in the Amazon SQS Developer Guide. // // A message that isn't deleted or a message whose visibility isn't extended // before the visibility timeout expires counts as a failed receive. Depending // on the configuration of the queue, the message might be sent to the dead-letter // queue. // // In the future, new attributes might be added. If you write code that calls // this action, we recommend that you structure your code so that it can handle // new attributes gracefully. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation ReceiveMessage for usage and error information. // // Returned Error Types: // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - OverLimit // The specified action violates a limit. For example, ReceiveMessage returns // this error if the maximum number of in flight messages is reached and AddPermission // returns this error if the maximum number of permissions for the queue is // reached. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - KmsDisabled // The request was denied due to request throttling. // // - KmsInvalidState // The request was rejected because the state of the specified resource is not // valid for this request. // // - KmsNotFound // The request was rejected because the specified entity or resource could not // be found. // // - KmsOptInRequired // The request was rejected because the specified key policy isn't syntactically // or semantically correct. // // - KmsThrottled // Amazon Web Services KMS throttles requests for the following conditions. // // - KmsAccessDenied // The caller doesn't have the required KMS access. // // - KmsInvalidKeyUsage // The request was rejected for one of the following reasons: // // - The KeyUsage value of the KMS key is incompatible with the API operation. // // - The encryption algorithm or signing algorithm specified for the operation // is incompatible with the type of key material in the KMS key (KeySpec). // // - InvalidAddress // The accountId is invalid. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/ReceiveMessage func (c SQS) ReceiveMessage(input ReceiveMessageInput) (ReceiveMessageOutput, error) { req, out := c.ReceiveMessageRequest(input) return out, req.Send() } // ReceiveMessageWithContext is the same as ReceiveMessage with the addition of // the ability to pass a context and additional request options. // // See ReceiveMessage for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) ReceiveMessageWithContext(ctx aws.Context, input ReceiveMessageInput, opts ...request.Option) (ReceiveMessageOutput, error) { req, out := c.ReceiveMessageRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opRemovePermission = "RemovePermission" // RemovePermissionRequest generates a "aws/request.Request" representing the // client's request for the RemovePermission operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See RemovePermission for more information on using the RemovePermission // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the RemovePermissionRequest method. // req, resp := client.RemovePermissionRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/RemovePermission func (c SQS) RemovePermissionRequest(input RemovePermissionInput) (req request.Request, output RemovePermissionOutput) { op := &request.Operation{ Name: opRemovePermission, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &RemovePermissionInput{} } output = &RemovePermissionOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // RemovePermission API operation for Amazon Simple Queue Service. // // Revokes any permissions in the queue policy that matches the specified Label // parameter. // // - Only the owner of a queue can remove permissions from it. // // - Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // - To remove the ability to change queue permissions, you must deny permission // to the AddPermission, RemovePermission, and SetQueueAttributes actions // in your IAM policy. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation RemovePermission for usage and error information. // // Returned Error Types: // // - InvalidAddress // The accountId is invalid. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/RemovePermission func (c SQS) RemovePermission(input RemovePermissionInput) (RemovePermissionOutput, error) { req, out := c.RemovePermissionRequest(input) return out, req.Send() } // RemovePermissionWithContext is the same as RemovePermission with the addition of // the ability to pass a context and additional request options. // // See RemovePermission for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) RemovePermissionWithContext(ctx aws.Context, input RemovePermissionInput, opts ...request.Option) (RemovePermissionOutput, error) { req, out := c.RemovePermissionRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opSendMessage = "SendMessage" // SendMessageRequest generates a "aws/request.Request" representing the // client's request for the SendMessage operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See SendMessage for more information on using the SendMessage // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the SendMessageRequest method. // req, resp := client.SendMessageRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/SendMessage func (c SQS) SendMessageRequest(input SendMessageInput) (req request.Request, output SendMessageOutput) { op := &request.Operation{ Name: opSendMessage, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &SendMessageInput{} } output = &SendMessageOutput{} req = c.newRequest(op, input, output) return } // SendMessage API operation for Amazon Simple Queue Service. // // Delivers a message to the specified queue. // // A message can include only XML, JSON, and unformatted text. The following // Unicode characters are allowed. For more information, see the W3C specification // for characters (http://www.w3.org/TR/REC-xml/#charsets). // // #x9 \| #xA \| #xD \| #x20 to #xD7FF \| #xE000 to #xFFFD \| #x10000 to #x10FFFF // // Amazon SQS does not throw an exception or completely reject the message if // it contains invalid characters. Instead, it replaces those invalid characters // with U+FFFD before storing the message in the queue, as long as the message // body contains at least one valid character. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation SendMessage for usage and error information. // // Returned Error Types: // // - InvalidMessageContents // The message contains characters outside the allowed set. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - KmsDisabled // The request was denied due to request throttling. // // - KmsInvalidState // The request was rejected because the state of the specified resource is not // valid for this request. // // - KmsNotFound // The request was rejected because the specified entity or resource could not // be found. // // - KmsOptInRequired // The request was rejected because the specified key policy isn't syntactically // or semantically correct. // // - KmsThrottled // Amazon Web Services KMS throttles requests for the following conditions. // // - KmsAccessDenied // The caller doesn't have the required KMS access. // // - KmsInvalidKeyUsage // The request was rejected for one of the following reasons: // // - The KeyUsage value of the KMS key is incompatible with the API operation. // // - The encryption algorithm or signing algorithm specified for the operation // is incompatible with the type of key material in the KMS key (KeySpec). // // - InvalidAddress // The accountId is invalid. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/SendMessage func (c SQS) SendMessage(input SendMessageInput) (SendMessageOutput, error) { req, out := c.SendMessageRequest(input) return out, req.Send() } // SendMessageWithContext is the same as SendMessage with the addition of // the ability to pass a context and additional request options. // // See SendMessage for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) SendMessageWithContext(ctx aws.Context, input SendMessageInput, opts ...request.Option) (SendMessageOutput, error) { req, out := c.SendMessageRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opSendMessageBatch = "SendMessageBatch" // SendMessageBatchRequest generates a "aws/request.Request" representing the // client's request for the SendMessageBatch operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See SendMessageBatch for more information on using the SendMessageBatch // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the SendMessageBatchRequest method. // req, resp := client.SendMessageBatchRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/SendMessageBatch func (c SQS) SendMessageBatchRequest(input SendMessageBatchInput) (req request.Request, output SendMessageBatchOutput) { op := &request.Operation{ Name: opSendMessageBatch, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &SendMessageBatchInput{} } output = &SendMessageBatchOutput{} req = c.newRequest(op, input, output) return } // SendMessageBatch API operation for Amazon Simple Queue Service. // // You can use SendMessageBatch to send up to 10 messages to the specified queue // by assigning either identical or different values to each message (or by // not assigning values at all). This is a batch version of SendMessage. For // a FIFO queue, multiple messages within a single batch are enqueued in the // order they are sent. // // The result of sending each message is reported individually in the response. // Because the batch request can result in a combination of successful and unsuccessful // actions, you should check for batch errors even when the call returns an // HTTP status code of 200. // // The maximum allowed individual message size and the maximum total payload // size (the sum of the individual lengths of all of the batched messages) are // both 256 KiB (262,144 bytes). // // A message can include only XML, JSON, and unformatted text. The following // Unicode characters are allowed. For more information, see the W3C specification // for characters (http://www.w3.org/TR/REC-xml/#charsets). // // #x9 \| #xA \| #xD \| #x20 to #xD7FF \| #xE000 to #xFFFD \| #x10000 to #x10FFFF // // Amazon SQS does not throw an exception or completely reject the message if // it contains invalid characters. Instead, it replaces those invalid characters // with U+FFFD before storing the message in the queue, as long as the message // body contains at least one valid character. // // If you don't specify the DelaySeconds parameter for an entry, Amazon SQS // uses the default value for the queue. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation SendMessageBatch for usage and error information. // // Returned Error Types: // // - TooManyEntriesInBatchRequest // The batch request contains more entries than permissible. // // - EmptyBatchRequest // The batch request doesn't contain any entries. // // - BatchEntryIdsNotDistinct // Two or more batch entries in the request have the same Id. // // - BatchRequestTooLong // The length of all the messages put together is more than the limit. // // - InvalidBatchEntryId // The Id of a batch entry in a batch request doesn't abide by the specification. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - KmsDisabled // The request was denied due to request throttling. // // - KmsInvalidState // The request was rejected because the state of the specified resource is not // valid for this request. // // - KmsNotFound // The request was rejected because the specified entity or resource could not // be found. // // - KmsOptInRequired // The request was rejected because the specified key policy isn't syntactically // or semantically correct. // // - KmsThrottled // Amazon Web Services KMS throttles requests for the following conditions. // // - KmsAccessDenied // The caller doesn't have the required KMS access. // // - KmsInvalidKeyUsage // The request was rejected for one of the following reasons: // // - The KeyUsage value of the KMS key is incompatible with the API operation. // // - The encryption algorithm or signing algorithm specified for the operation // is incompatible with the type of key material in the KMS key (KeySpec). // // - InvalidAddress // The accountId is invalid. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/SendMessageBatch func (c SQS) SendMessageBatch(input SendMessageBatchInput) (SendMessageBatchOutput, error) { req, out := c.SendMessageBatchRequest(input) return out, req.Send() } // SendMessageBatchWithContext is the same as SendMessageBatch with the addition of // the ability to pass a context and additional request options. // // See SendMessageBatch for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) SendMessageBatchWithContext(ctx aws.Context, input SendMessageBatchInput, opts ...request.Option) (SendMessageBatchOutput, error) { req, out := c.SendMessageBatchRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opSetQueueAttributes = "SetQueueAttributes" // SetQueueAttributesRequest generates a "aws/request.Request" representing the // client's request for the SetQueueAttributes operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See SetQueueAttributes for more information on using the SetQueueAttributes // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the SetQueueAttributesRequest method. // req, resp := client.SetQueueAttributesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/SetQueueAttributes func (c SQS) SetQueueAttributesRequest(input SetQueueAttributesInput) (req request.Request, output SetQueueAttributesOutput) { op := &request.Operation{ Name: opSetQueueAttributes, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &SetQueueAttributesInput{} } output = &SetQueueAttributesOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // SetQueueAttributes API operation for Amazon Simple Queue Service. // // Sets the value of one or more queue attributes, like a policy. When you change // a queue's attributes, the change can take up to 60 seconds for most of the // attributes to propagate throughout the Amazon SQS system. Changes made to // the MessageRetentionPeriod attribute can take up to 15 minutes and will impact // existing messages in the queue potentially causing them to be expired and // deleted if the MessageRetentionPeriod is reduced below the age of existing // messages. // // - In the future, new attributes might be added. If you write code that // calls this action, we recommend that you structure your code so that it // can handle new attributes gracefully. // // - Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // - To remove the ability to change queue permissions, you must deny permission // to the AddPermission, RemovePermission, and SetQueueAttributes actions // in your IAM policy. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation SetQueueAttributes for usage and error information. // // Returned Error Types: // // - InvalidAttributeName // The specified attribute doesn't exist. // // - InvalidAttributeValue // A queue attribute value is invalid. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // - OverLimit // The specified action violates a limit. For example, ReceiveMessage returns // this error if the maximum number of in flight messages is reached and AddPermission // returns this error if the maximum number of permissions for the queue is // reached. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/SetQueueAttributes func (c SQS) SetQueueAttributes(input SetQueueAttributesInput) (SetQueueAttributesOutput, error) { req, out := c.SetQueueAttributesRequest(input) return out, req.Send() } // SetQueueAttributesWithContext is the same as SetQueueAttributes with the addition of // the ability to pass a context and additional request options. // // See SetQueueAttributes for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) SetQueueAttributesWithContext(ctx aws.Context, input SetQueueAttributesInput, opts ...request.Option) (SetQueueAttributesOutput, error) { req, out := c.SetQueueAttributesRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opStartMessageMoveTask = "StartMessageMoveTask" // StartMessageMoveTaskRequest generates a "aws/request.Request" representing the // client's request for the StartMessageMoveTask operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See StartMessageMoveTask for more information on using the StartMessageMoveTask // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the StartMessageMoveTaskRequest method. // req, resp := client.StartMessageMoveTaskRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/StartMessageMoveTask func (c SQS) StartMessageMoveTaskRequest(input StartMessageMoveTaskInput) (req request.Request, output StartMessageMoveTaskOutput) { op := &request.Operation{ Name: opStartMessageMoveTask, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &StartMessageMoveTaskInput{} } output = &StartMessageMoveTaskOutput{} req = c.newRequest(op, input, output) return } // StartMessageMoveTask API operation for Amazon Simple Queue Service. // // Starts an asynchronous task to move messages from a specified source queue // to a specified destination queue. // // - This action is currently limited to supporting message redrive from // queues that are configured as dead-letter queues (DLQs) (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html) // of other Amazon SQS queues only. Non-SQS queue sources of dead-letter // queues, such as Lambda or Amazon SNS topics, are currently not supported. // // - In dead-letter queues redrive context, the StartMessageMoveTask the // source queue is the DLQ, while the destination queue can be the original // source queue (from which the messages were driven to the dead-letter-queue), // or a custom destination queue. // // - Only one active message movement task is supported per queue at any // given time. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation StartMessageMoveTask for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // One or more specified resources don't exist. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - InvalidAddress // The accountId is invalid. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/StartMessageMoveTask func (c SQS) StartMessageMoveTask(input StartMessageMoveTaskInput) (StartMessageMoveTaskOutput, error) { req, out := c.StartMessageMoveTaskRequest(input) return out, req.Send() } // StartMessageMoveTaskWithContext is the same as StartMessageMoveTask with the addition of // the ability to pass a context and additional request options. // // See StartMessageMoveTask for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) StartMessageMoveTaskWithContext(ctx aws.Context, input StartMessageMoveTaskInput, opts ...request.Option) (StartMessageMoveTaskOutput, error) { req, out := c.StartMessageMoveTaskRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opTagQueue = "TagQueue" // TagQueueRequest generates a "aws/request.Request" representing the // client's request for the TagQueue operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See TagQueue for more information on using the TagQueue // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the TagQueueRequest method. // req, resp := client.TagQueueRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/TagQueue func (c SQS) TagQueueRequest(input TagQueueInput) (req request.Request, output TagQueueOutput) { op := &request.Operation{ Name: opTagQueue, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &TagQueueInput{} } output = &TagQueueOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // TagQueue API operation for Amazon Simple Queue Service. // // Add cost allocation tags to the specified Amazon SQS queue. For an overview, // see Tagging Your Amazon SQS Queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-queue-tags.html) // in the Amazon SQS Developer Guide. // // When you use queue tags, keep the following guidelines in mind: // // - Adding more than 50 tags to a queue isn't recommended. // // - Tags don't have any semantic meaning. Amazon SQS interprets tags as // character strings. // // - Tags are case-sensitive. // // - A new tag with a key identical to that of an existing tag overwrites // the existing tag. // // For a full list of tag restrictions, see Quotas related to queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-limits.html#limits-queues) // in the Amazon SQS Developer Guide. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation TagQueue for usage and error information. // // Returned Error Types: // // - InvalidAddress // The accountId is invalid. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/TagQueue func (c SQS) TagQueue(input TagQueueInput) (TagQueueOutput, error) { req, out := c.TagQueueRequest(input) return out, req.Send() } // TagQueueWithContext is the same as TagQueue with the addition of // the ability to pass a context and additional request options. // // See TagQueue for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) TagQueueWithContext(ctx aws.Context, input TagQueueInput, opts ...request.Option) (TagQueueOutput, error) { req, out := c.TagQueueRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opUntagQueue = "UntagQueue" // UntagQueueRequest generates a "aws/request.Request" representing the // client's request for the UntagQueue operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See UntagQueue for more information on using the UntagQueue // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the UntagQueueRequest method. // req, resp := client.UntagQueueRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/UntagQueue func (c SQS) UntagQueueRequest(input UntagQueueInput) (req request.Request, output UntagQueueOutput) { op := &request.Operation{ Name: opUntagQueue, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &UntagQueueInput{} } output = &UntagQueueOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // UntagQueue API operation for Amazon Simple Queue Service. // // Remove cost allocation tags from the specified Amazon SQS queue. For an overview, // see Tagging Your Amazon SQS Queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-queue-tags.html) // in the Amazon SQS Developer Guide. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Simple Queue Service's // API operation UntagQueue for usage and error information. // // Returned Error Types: // // - InvalidAddress // The accountId is invalid. // // - RequestThrottled // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. // // - QueueDoesNotExist // The specified queue doesn't exist. // // - InvalidSecurity // When the request to a queue is not HTTPS and SigV4. // // - UnsupportedOperation // Error code 400. Unsupported operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05/UntagQueue func (c SQS) UntagQueue(input UntagQueueInput) (UntagQueueOutput, error) { req, out := c.UntagQueueRequest(input) return out, req.Send() } // UntagQueueWithContext is the same as UntagQueue with the addition of // the ability to pass a context and additional request options. // // See UntagQueue for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c SQS) UntagQueueWithContext(ctx aws.Context, input UntagQueueInput, opts ...request.Option) (UntagQueueOutput, error) { req, out := c.UntagQueueRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } type AddPermissionInput struct { _ struct{} `type:"structure"` // The Amazon Web Services account numbers of the principals (https://docs.aws.amazon.com/general/latest/gr/glos-chap.html#P) // who are to receive permission. For information about locating the Amazon // Web Services account identification, see Your Amazon Web Services Identifiers // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-making-api-requests.html#sqs-api-request-authentication) // in the Amazon SQS Developer Guide. // // AWSAccountIds is a required field AWSAccountIds []string `type:"list" flattened:"true" required:"true"` // The action the client wants to allow for the specified principal. Valid values: // the name of any action or . // // For more information about these actions, see Overview of Managing Access // Permissions to Your Amazon Simple Queue Service Resource (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-overview-of-managing-access.html) // in the Amazon SQS Developer Guide. // // Specifying SendMessage, DeleteMessage, or ChangeMessageVisibility for ActionName.n // also grants permissions for the corresponding batch versions of those actions: // SendMessageBatch, DeleteMessageBatch, and ChangeMessageVisibilityBatch. // // Actions is a required field Actions []string `type:"list" flattened:"true" required:"true"` // The unique identification of the permission you're setting (for example, // AliceSendMessage). Maximum 80 characters. Allowed characters include alphanumeric // characters, hyphens (-), and underscores (_). // // Label is a required field Label string `type:"string" required:"true"` // The URL of the Amazon SQS queue to which permissions are added. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AddPermissionInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AddPermissionInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s AddPermissionInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "AddPermissionInput"} if s.AWSAccountIds == nil { invalidParams.Add(request.NewErrParamRequired("AWSAccountIds")) } if s.Actions == nil { invalidParams.Add(request.NewErrParamRequired("Actions")) } if s.Label == nil { invalidParams.Add(request.NewErrParamRequired("Label")) } if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetAWSAccountIds sets the AWSAccountIds field's value. func (s AddPermissionInput) SetAWSAccountIds(v []string) AddPermissionInput { s.AWSAccountIds = v return s } // SetActions sets the Actions field's value. func (s AddPermissionInput) SetActions(v []string) AddPermissionInput { s.Actions = v return s } // SetLabel sets the Label field's value. func (s AddPermissionInput) SetLabel(v string) AddPermissionInput { s.Label = &v return s } // SetQueueUrl sets the QueueUrl field's value. func (s AddPermissionInput) SetQueueUrl(v string) AddPermissionInput { s.QueueUrl = &v return s } type AddPermissionOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AddPermissionOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AddPermissionOutput) GoString() string { return s.String() } // Two or more batch entries in the request have the same Id. type BatchEntryIdsNotDistinct struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s BatchEntryIdsNotDistinct) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s BatchEntryIdsNotDistinct) GoString() string { return s.String() } func newErrorBatchEntryIdsNotDistinct(v protocol.ResponseMetadata) error { return &BatchEntryIdsNotDistinct{ RespMetadata: v, } } func newQueryCompatibleErrorBatchEntryIdsNotDistinct(v protocol.ResponseMetadata, code string) error { return &BatchEntryIdsNotDistinct{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s BatchEntryIdsNotDistinct) Code() string { if s.Code_ != nil { return s.Code_ } return "BatchEntryIdsNotDistinct" } // Message returns the exception's message. func (s BatchEntryIdsNotDistinct) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s BatchEntryIdsNotDistinct) OrigErr() error { return nil } func (s BatchEntryIdsNotDistinct) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s BatchEntryIdsNotDistinct) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s BatchEntryIdsNotDistinct) RequestID() string { return s.RespMetadata.RequestID } // The length of all the messages put together is more than the limit. type BatchRequestTooLong struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s BatchRequestTooLong) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s BatchRequestTooLong) GoString() string { return s.String() } func newErrorBatchRequestTooLong(v protocol.ResponseMetadata) error { return &BatchRequestTooLong{ RespMetadata: v, } } func newQueryCompatibleErrorBatchRequestTooLong(v protocol.ResponseMetadata, code string) error { return &BatchRequestTooLong{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s BatchRequestTooLong) Code() string { if s.Code_ != nil { return s.Code_ } return "BatchRequestTooLong" } // Message returns the exception's message. func (s BatchRequestTooLong) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s BatchRequestTooLong) OrigErr() error { return nil } func (s BatchRequestTooLong) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s BatchRequestTooLong) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s BatchRequestTooLong) RequestID() string { return s.RespMetadata.RequestID } // Gives a detailed description of the result of an action on each entry in // the request. type BatchResultErrorEntry struct { _ struct{} `type:"structure"` // An error code representing why the action failed on this entry. // // Code is a required field Code string `type:"string" required:"true"` // The Id of an entry in a batch request. // // Id is a required field Id string `type:"string" required:"true"` // A message explaining why the action failed on this entry. Message string `type:"string"` // Specifies whether the error happened due to the caller of the batch API action. // // SenderFault is a required field SenderFault bool `type:"boolean" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s BatchResultErrorEntry) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s BatchResultErrorEntry) GoString() string { return s.String() } // SetCode sets the Code field's value. func (s BatchResultErrorEntry) SetCode(v string) BatchResultErrorEntry { s.Code = &v return s } // SetId sets the Id field's value. func (s BatchResultErrorEntry) SetId(v string) BatchResultErrorEntry { s.Id = &v return s } // SetMessage sets the Message field's value. func (s BatchResultErrorEntry) SetMessage(v string) BatchResultErrorEntry { s.Message = &v return s } // SetSenderFault sets the SenderFault field's value. func (s BatchResultErrorEntry) SetSenderFault(v bool) BatchResultErrorEntry { s.SenderFault = &v return s } type CancelMessageMoveTaskInput struct { _ struct{} `type:"structure"` // An identifier associated with a message movement task. // // TaskHandle is a required field TaskHandle string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CancelMessageMoveTaskInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CancelMessageMoveTaskInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s CancelMessageMoveTaskInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CancelMessageMoveTaskInput"} if s.TaskHandle == nil { invalidParams.Add(request.NewErrParamRequired("TaskHandle")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetTaskHandle sets the TaskHandle field's value. func (s CancelMessageMoveTaskInput) SetTaskHandle(v string) CancelMessageMoveTaskInput { s.TaskHandle = &v return s } type CancelMessageMoveTaskOutput struct { _ struct{} `type:"structure"` // The approximate number of messages already moved to the destination queue. ApproximateNumberOfMessagesMoved int64 `type:"long"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CancelMessageMoveTaskOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CancelMessageMoveTaskOutput) GoString() string { return s.String() } // SetApproximateNumberOfMessagesMoved sets the ApproximateNumberOfMessagesMoved field's value. func (s CancelMessageMoveTaskOutput) SetApproximateNumberOfMessagesMoved(v int64) CancelMessageMoveTaskOutput { s.ApproximateNumberOfMessagesMoved = &v return s } type ChangeMessageVisibilityBatchInput struct { _ struct{} `type:"structure"` // Lists the receipt handles of the messages for which the visibility timeout // must be changed. // // Entries is a required field Entries []ChangeMessageVisibilityBatchRequestEntry `type:"list" flattened:"true" required:"true"` // The URL of the Amazon SQS queue whose messages' visibility is changed. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityBatchInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityBatchInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ChangeMessageVisibilityBatchInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ChangeMessageVisibilityBatchInput"} if s.Entries == nil { invalidParams.Add(request.NewErrParamRequired("Entries")) } if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.Entries != nil { for i, v := range s.Entries { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "Entries", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetEntries sets the Entries field's value. func (s ChangeMessageVisibilityBatchInput) SetEntries(v []ChangeMessageVisibilityBatchRequestEntry) ChangeMessageVisibilityBatchInput { s.Entries = v return s } // SetQueueUrl sets the QueueUrl field's value. func (s ChangeMessageVisibilityBatchInput) SetQueueUrl(v string) ChangeMessageVisibilityBatchInput { s.QueueUrl = &v return s } // For each message in the batch, the response contains a ChangeMessageVisibilityBatchResultEntry // tag if the message succeeds or a BatchResultErrorEntry tag if the message // fails. type ChangeMessageVisibilityBatchOutput struct { _ struct{} `type:"structure"` // A list of BatchResultErrorEntry items. // // Failed is a required field Failed []BatchResultErrorEntry `type:"list" flattened:"true" required:"true"` // A list of ChangeMessageVisibilityBatchResultEntry items. // // Successful is a required field Successful []ChangeMessageVisibilityBatchResultEntry `type:"list" flattened:"true" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityBatchOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityBatchOutput) GoString() string { return s.String() } // SetFailed sets the Failed field's value. func (s ChangeMessageVisibilityBatchOutput) SetFailed(v []BatchResultErrorEntry) ChangeMessageVisibilityBatchOutput { s.Failed = v return s } // SetSuccessful sets the Successful field's value. func (s ChangeMessageVisibilityBatchOutput) SetSuccessful(v []ChangeMessageVisibilityBatchResultEntry) ChangeMessageVisibilityBatchOutput { s.Successful = v return s } // Encloses a receipt handle and an entry ID for each message in ChangeMessageVisibilityBatch. type ChangeMessageVisibilityBatchRequestEntry struct { _ struct{} `type:"structure"` // An identifier for this particular receipt handle used to communicate the // result. // // The Ids of a batch request need to be unique within a request. // // This identifier can have up to 80 characters. The following characters are // accepted: alphanumeric characters, hyphens(-), and underscores (_). // // Id is a required field Id string `type:"string" required:"true"` // A receipt handle. // // ReceiptHandle is a required field ReceiptHandle string `type:"string" required:"true"` // The new value (in seconds) for the message's visibility timeout. VisibilityTimeout int64 `type:"integer"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityBatchRequestEntry) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityBatchRequestEntry) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ChangeMessageVisibilityBatchRequestEntry) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ChangeMessageVisibilityBatchRequestEntry"} if s.Id == nil { invalidParams.Add(request.NewErrParamRequired("Id")) } if s.ReceiptHandle == nil { invalidParams.Add(request.NewErrParamRequired("ReceiptHandle")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetId sets the Id field's value. func (s ChangeMessageVisibilityBatchRequestEntry) SetId(v string) ChangeMessageVisibilityBatchRequestEntry { s.Id = &v return s } // SetReceiptHandle sets the ReceiptHandle field's value. func (s ChangeMessageVisibilityBatchRequestEntry) SetReceiptHandle(v string) ChangeMessageVisibilityBatchRequestEntry { s.ReceiptHandle = &v return s } // SetVisibilityTimeout sets the VisibilityTimeout field's value. func (s ChangeMessageVisibilityBatchRequestEntry) SetVisibilityTimeout(v int64) ChangeMessageVisibilityBatchRequestEntry { s.VisibilityTimeout = &v return s } // Encloses the Id of an entry in ChangeMessageVisibilityBatch. type ChangeMessageVisibilityBatchResultEntry struct { _ struct{} `type:"structure"` // Represents a message whose visibility timeout has been changed successfully. // // Id is a required field Id string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityBatchResultEntry) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityBatchResultEntry) GoString() string { return s.String() } // SetId sets the Id field's value. func (s ChangeMessageVisibilityBatchResultEntry) SetId(v string) ChangeMessageVisibilityBatchResultEntry { s.Id = &v return s } type ChangeMessageVisibilityInput struct { _ struct{} `type:"structure"` // The URL of the Amazon SQS queue whose message's visibility is changed. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` // The receipt handle associated with the message, whose visibility timeout // is changed. This parameter is returned by the ReceiveMessage action. // // ReceiptHandle is a required field ReceiptHandle string `type:"string" required:"true"` // The new value for the message's visibility timeout (in seconds). Values range: // 0 to 43200. Maximum: 12 hours. // // VisibilityTimeout is a required field VisibilityTimeout int64 `type:"integer" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ChangeMessageVisibilityInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ChangeMessageVisibilityInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.ReceiptHandle == nil { invalidParams.Add(request.NewErrParamRequired("ReceiptHandle")) } if s.VisibilityTimeout == nil { invalidParams.Add(request.NewErrParamRequired("VisibilityTimeout")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetQueueUrl sets the QueueUrl field's value. func (s ChangeMessageVisibilityInput) SetQueueUrl(v string) ChangeMessageVisibilityInput { s.QueueUrl = &v return s } // SetReceiptHandle sets the ReceiptHandle field's value. func (s ChangeMessageVisibilityInput) SetReceiptHandle(v string) ChangeMessageVisibilityInput { s.ReceiptHandle = &v return s } // SetVisibilityTimeout sets the VisibilityTimeout field's value. func (s ChangeMessageVisibilityInput) SetVisibilityTimeout(v int64) ChangeMessageVisibilityInput { s.VisibilityTimeout = &v return s } type ChangeMessageVisibilityOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ChangeMessageVisibilityOutput) GoString() string { return s.String() } type CreateQueueInput struct { _ struct{} `type:"structure"` // A map of attributes with their corresponding values. // // The following lists the names, descriptions, and values of the special request // parameters that the CreateQueue action uses: // // * DelaySeconds – The length of time, in seconds, for which the delivery // of all messages in the queue is delayed. Valid values: An integer from // 0 to 900 seconds (15 minutes). Default: 0. // // * MaximumMessageSize – The limit of how many bytes a message can contain // before Amazon SQS rejects it. Valid values: An integer from 1,024 bytes // (1 KiB) to 262,144 bytes (256 KiB). Default: 262,144 (256 KiB). // // * MessageRetentionPeriod – The length of time, in seconds, for which // Amazon SQS retains a message. Valid values: An integer from 60 seconds // (1 minute) to 1,209,600 seconds (14 days). Default: 345,600 (4 days). // When you change a queue's attributes, the change can take up to 60 seconds // for most of the attributes to propagate throughout the Amazon SQS system. // Changes made to the MessageRetentionPeriod attribute can take up to 15 // minutes and will impact existing messages in the queue potentially causing // them to be expired and deleted if the MessageRetentionPeriod is reduced // below the age of existing messages. // // * Policy – The queue's policy. A valid Amazon Web Services policy. For // more information about policy structure, see Overview of Amazon Web Services // IAM Policies (https://docs.aws.amazon.com/IAM/latest/UserGuide/PoliciesOverview.html) // in the IAM User Guide. // // * ReceiveMessageWaitTimeSeconds – The length of time, in seconds, for // which a ReceiveMessage action waits for a message to arrive. Valid values: // An integer from 0 to 20 (seconds). Default: 0. // // * VisibilityTimeout – The visibility timeout for the queue, in seconds. // Valid values: An integer from 0 to 43,200 (12 hours). Default: 30. For // more information about the visibility timeout, see Visibility Timeout // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html) // in the Amazon SQS Developer Guide. // // The following attributes apply only to dead-letter queues: (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html) // // * RedrivePolicy – The string that includes the parameters for the dead-letter // queue functionality of the source queue as a JSON object. The parameters // are as follows: deadLetterTargetArn – The Amazon Resource Name (ARN) // of the dead-letter queue to which Amazon SQS moves messages after the // value of maxReceiveCount is exceeded. maxReceiveCount – The number of // times a message is delivered to the source queue before being moved to // the dead-letter queue. Default: 10. When the ReceiveCount for a message // exceeds the maxReceiveCount for a queue, Amazon SQS moves the message // to the dead-letter-queue. // // * RedriveAllowPolicy – The string that includes the parameters for the // permissions for the dead-letter queue redrive permission and which source // queues can specify dead-letter queues as a JSON object. The parameters // are as follows: redrivePermission – The permission type that defines // which source queues can specify the current queue as the dead-letter queue. // Valid values are: allowAll – (Default) Any source queues in this Amazon // Web Services account in the same Region can specify this queue as the // dead-letter queue. denyAll – No source queues can specify this queue // as the dead-letter queue. byQueue – Only queues specified by the sourceQueueArns // parameter can specify this queue as the dead-letter queue. sourceQueueArns // – The Amazon Resource Names (ARN)s of the source queues that can specify // this queue as the dead-letter queue and redrive messages. You can specify // this parameter only when the redrivePermission parameter is set to byQueue. // You can specify up to 10 source queue ARNs. To allow more than 10 source // queues to specify dead-letter queues, set the redrivePermission parameter // to allowAll. // // The dead-letter queue of a FIFO queue must also be a FIFO queue. Similarly, // the dead-letter queue of a standard queue must also be a standard queue. // // The following attributes apply only to server-side-encryption (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html): // // * KmsMasterKeyId – The ID of an Amazon Web Services managed customer // master key (CMK) for Amazon SQS or a custom CMK. For more information, // see Key Terms (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html#sqs-sse-key-terms). // While the alias of the Amazon Web Services managed CMK for Amazon SQS // is always alias/aws/sqs, the alias of a custom CMK can, for example, be // alias/MyAlias . For more examples, see KeyId (https://docs.aws.amazon.com/kms/latest/APIReference/API_DescribeKey.html#API_DescribeKey_RequestParameters) // in the Key Management Service API Reference. // // * KmsDataKeyReusePeriodSeconds – The length of time, in seconds, for // which Amazon SQS can reuse a data key (https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html#data-keys) // to encrypt or decrypt messages before calling KMS again. An integer representing // seconds, between 60 seconds (1 minute) and 86,400 seconds (24 hours). // Default: 300 (5 minutes). A shorter time period provides better security // but results in more calls to KMS which might incur charges after Free // Tier. For more information, see How Does the Data Key Reuse Period Work? // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html#sqs-how-does-the-data-key-reuse-period-work) // // * SqsManagedSseEnabled – Enables server-side queue encryption using // SQS owned encryption keys. Only one server-side encryption option is supported // per queue (for example, SSE-KMS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sse-existing-queue.html) // or SSE-SQS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sqs-sse-queue.html)). // // The following attributes apply only to FIFO (first-in-first-out) queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues.html): // // * FifoQueue – Designates a queue as FIFO. Valid values are true and // false. If you don't specify the FifoQueue attribute, Amazon SQS creates // a standard queue. You can provide this attribute only during queue creation. // You can't change it for an existing queue. When you set this attribute, // you must also provide the MessageGroupId for your messages explicitly. // For more information, see FIFO queue logic (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues-understanding-logic.html) // in the Amazon SQS Developer Guide. // // * ContentBasedDeduplication – Enables content-based deduplication. Valid // values are true and false. For more information, see Exactly-once processing // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues-exactly-once-processing.html) // in the Amazon SQS Developer Guide. Note the following: Every message must // have a unique MessageDeduplicationId. You may provide a MessageDeduplicationId // explicitly. If you aren't able to provide a MessageDeduplicationId and // you enable ContentBasedDeduplication for your queue, Amazon SQS uses a // SHA-256 hash to generate the MessageDeduplicationId using the body of // the message (but not the attributes of the message). If you don't provide // a MessageDeduplicationId and the queue doesn't have ContentBasedDeduplication // set, the action fails with an error. If the queue has ContentBasedDeduplication // set, your MessageDeduplicationId overrides the generated one. When ContentBasedDeduplication // is in effect, messages with identical content sent within the deduplication // interval are treated as duplicates and only one copy of the message is // delivered. If you send one message with ContentBasedDeduplication enabled // and then another message with a MessageDeduplicationId that is the same // as the one generated for the first MessageDeduplicationId, the two messages // are treated as duplicates and only one copy of the message is delivered. // // The following attributes apply only to high throughput for FIFO queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/high-throughput-fifo.html): // // * DeduplicationScope – Specifies whether message deduplication occurs // at the message group or queue level. Valid values are messageGroup and // queue. // // * FifoThroughputLimit – Specifies whether the FIFO queue throughput // quota applies to the entire queue or per message group. Valid values are // perQueue and perMessageGroupId. The perMessageGroupId value is allowed // only when the value for DeduplicationScope is messageGroup. // // To enable high throughput for FIFO queues, do the following: // // * Set DeduplicationScope to messageGroup. // // * Set FifoThroughputLimit to perMessageGroupId. // // If you set these attributes to anything other than the values shown for enabling // high throughput, normal throughput is in effect and deduplication occurs // as specified. // // For information on throughput quotas, see Quotas related to messages (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/quotas-messages.html) // in the Amazon SQS Developer Guide. Attributes map[string]string `type:"map" flattened:"true"` // The name of the new queue. The following limits apply to this name: // // A queue name can have up to 80 characters. // // * Valid values: alphanumeric characters, hyphens (-), and underscores // (_). // // * A FIFO queue name must end with the .fifo suffix. // // Queue URLs and names are case-sensitive. // // QueueName is a required field QueueName string `type:"string" required:"true"` // Add cost allocation tags to the specified Amazon SQS queue. For an overview, // see Tagging Your Amazon SQS Queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-queue-tags.html) // in the Amazon SQS Developer Guide. // // When you use queue tags, keep the following guidelines in mind: // // Adding more than 50 tags to a queue isn't recommended. // // * Tags don't have any semantic meaning. Amazon SQS interprets tags as // character strings. // // * Tags are case-sensitive. // // * A new tag with a key identical to that of an existing tag overwrites // the existing tag. // // For a full list of tag restrictions, see Quotas related to queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-limits.html#limits-queues) // in the Amazon SQS Developer Guide. // // To be able to tag a queue on creation, you must have the sqs:CreateQueue // and sqs:TagQueue permissions. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a username (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. Tags map[string]string `locationName:"tags" type:"map" flattened:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateQueueInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateQueueInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s CreateQueueInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreateQueueInput"} if s.QueueName == nil { invalidParams.Add(request.NewErrParamRequired("QueueName")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetAttributes sets the Attributes field's value. func (s CreateQueueInput) SetAttributes(v map[string]string) CreateQueueInput { s.Attributes = v return s } // SetQueueName sets the QueueName field's value. func (s CreateQueueInput) SetQueueName(v string) CreateQueueInput { s.QueueName = &v return s } // SetTags sets the Tags field's value. func (s CreateQueueInput) SetTags(v map[string]string) CreateQueueInput { s.Tags = v return s } // Returns the QueueUrl attribute of the created queue. type CreateQueueOutput struct { _ struct{} `type:"structure"` // The URL of the created Amazon SQS queue. QueueUrl string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateQueueOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CreateQueueOutput) GoString() string { return s.String() } // SetQueueUrl sets the QueueUrl field's value. func (s CreateQueueOutput) SetQueueUrl(v string) CreateQueueOutput { s.QueueUrl = &v return s } type DeleteMessageBatchInput struct { _ struct{} `type:"structure"` // Lists the receipt handles for the messages to be deleted. // // Entries is a required field Entries []DeleteMessageBatchRequestEntry `type:"list" flattened:"true" required:"true"` // The URL of the Amazon SQS queue from which messages are deleted. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageBatchInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageBatchInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s DeleteMessageBatchInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteMessageBatchInput"} if s.Entries == nil { invalidParams.Add(request.NewErrParamRequired("Entries")) } if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.Entries != nil { for i, v := range s.Entries { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "Entries", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetEntries sets the Entries field's value. func (s DeleteMessageBatchInput) SetEntries(v []DeleteMessageBatchRequestEntry) DeleteMessageBatchInput { s.Entries = v return s } // SetQueueUrl sets the QueueUrl field's value. func (s DeleteMessageBatchInput) SetQueueUrl(v string) DeleteMessageBatchInput { s.QueueUrl = &v return s } // For each message in the batch, the response contains a DeleteMessageBatchResultEntry // tag if the message is deleted or a BatchResultErrorEntry tag if the message // can't be deleted. type DeleteMessageBatchOutput struct { _ struct{} `type:"structure"` // A list of BatchResultErrorEntry items. // // Failed is a required field Failed []BatchResultErrorEntry `type:"list" flattened:"true" required:"true"` // A list of DeleteMessageBatchResultEntry items. // // Successful is a required field Successful []DeleteMessageBatchResultEntry `type:"list" flattened:"true" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageBatchOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageBatchOutput) GoString() string { return s.String() } // SetFailed sets the Failed field's value. func (s DeleteMessageBatchOutput) SetFailed(v []BatchResultErrorEntry) DeleteMessageBatchOutput { s.Failed = v return s } // SetSuccessful sets the Successful field's value. func (s DeleteMessageBatchOutput) SetSuccessful(v []DeleteMessageBatchResultEntry) DeleteMessageBatchOutput { s.Successful = v return s } // Encloses a receipt handle and an identifier for it. type DeleteMessageBatchRequestEntry struct { _ struct{} `type:"structure"` // The identifier for this particular receipt handle. This is used to communicate // the result. // // The Ids of a batch request need to be unique within a request. // // This identifier can have up to 80 characters. The following characters are // accepted: alphanumeric characters, hyphens(-), and underscores (_). // // Id is a required field Id string `type:"string" required:"true"` // A receipt handle. // // ReceiptHandle is a required field ReceiptHandle string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageBatchRequestEntry) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageBatchRequestEntry) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s DeleteMessageBatchRequestEntry) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteMessageBatchRequestEntry"} if s.Id == nil { invalidParams.Add(request.NewErrParamRequired("Id")) } if s.ReceiptHandle == nil { invalidParams.Add(request.NewErrParamRequired("ReceiptHandle")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetId sets the Id field's value. func (s DeleteMessageBatchRequestEntry) SetId(v string) DeleteMessageBatchRequestEntry { s.Id = &v return s } // SetReceiptHandle sets the ReceiptHandle field's value. func (s DeleteMessageBatchRequestEntry) SetReceiptHandle(v string) DeleteMessageBatchRequestEntry { s.ReceiptHandle = &v return s } // Encloses the Id of an entry in DeleteMessageBatch. type DeleteMessageBatchResultEntry struct { _ struct{} `type:"structure"` // Represents a successfully deleted message. // // Id is a required field Id string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageBatchResultEntry) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageBatchResultEntry) GoString() string { return s.String() } // SetId sets the Id field's value. func (s DeleteMessageBatchResultEntry) SetId(v string) DeleteMessageBatchResultEntry { s.Id = &v return s } type DeleteMessageInput struct { _ struct{} `type:"structure"` // The URL of the Amazon SQS queue from which messages are deleted. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` // The receipt handle associated with the message to delete. // // ReceiptHandle is a required field ReceiptHandle string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s DeleteMessageInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteMessageInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.ReceiptHandle == nil { invalidParams.Add(request.NewErrParamRequired("ReceiptHandle")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetQueueUrl sets the QueueUrl field's value. func (s DeleteMessageInput) SetQueueUrl(v string) DeleteMessageInput { s.QueueUrl = &v return s } // SetReceiptHandle sets the ReceiptHandle field's value. func (s DeleteMessageInput) SetReceiptHandle(v string) DeleteMessageInput { s.ReceiptHandle = &v return s } type DeleteMessageOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteMessageOutput) GoString() string { return s.String() } type DeleteQueueInput struct { _ struct{} `type:"structure"` // The URL of the Amazon SQS queue to delete. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteQueueInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteQueueInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s DeleteQueueInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteQueueInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetQueueUrl sets the QueueUrl field's value. func (s DeleteQueueInput) SetQueueUrl(v string) DeleteQueueInput { s.QueueUrl = &v return s } type DeleteQueueOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteQueueOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteQueueOutput) GoString() string { return s.String() } // The batch request doesn't contain any entries. type EmptyBatchRequest struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s EmptyBatchRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s EmptyBatchRequest) GoString() string { return s.String() } func newErrorEmptyBatchRequest(v protocol.ResponseMetadata) error { return &EmptyBatchRequest{ RespMetadata: v, } } func newQueryCompatibleErrorEmptyBatchRequest(v protocol.ResponseMetadata, code string) error { return &EmptyBatchRequest{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s EmptyBatchRequest) Code() string { if s.Code_ != nil { return s.Code_ } return "EmptyBatchRequest" } // Message returns the exception's message. func (s EmptyBatchRequest) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s EmptyBatchRequest) OrigErr() error { return nil } func (s EmptyBatchRequest) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s EmptyBatchRequest) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s EmptyBatchRequest) RequestID() string { return s.RespMetadata.RequestID } type GetQueueAttributesInput struct { _ struct{} `type:"structure"` // A list of attributes for which to retrieve information. // // The AttributeNames parameter is optional, but if you don't specify values // for this parameter, the request returns empty results. // // In the future, new attributes might be added. If you write code that calls // this action, we recommend that you structure your code so that it can handle // new attributes gracefully. // // The following attributes are supported: // // The ApproximateNumberOfMessagesDelayed, ApproximateNumberOfMessagesNotVisible, // and ApproximateNumberOfMessages metrics may not achieve consistency until // at least 1 minute after the producers stop sending messages. This period // is required for the queue metadata to reach eventual consistency. // // * All – Returns all values. // // * ApproximateNumberOfMessages – Returns the approximate number of messages // available for retrieval from the queue. // // * ApproximateNumberOfMessagesDelayed – Returns the approximate number // of messages in the queue that are delayed and not available for reading // immediately. This can happen when the queue is configured as a delay queue // or when a message has been sent with a delay parameter. // // * ApproximateNumberOfMessagesNotVisible – Returns the approximate number // of messages that are in flight. Messages are considered to be in flight // if they have been sent to a client but have not yet been deleted or have // not yet reached the end of their visibility window. // // * CreatedTimestamp – Returns the time when the queue was created in // seconds (epoch time (http://en.wikipedia.org/wiki/Unix_time)). // // * DelaySeconds – Returns the default delay on the queue in seconds. // // * LastModifiedTimestamp – Returns the time when the queue was last changed // in seconds (epoch time (http://en.wikipedia.org/wiki/Unix_time)). // // * MaximumMessageSize – Returns the limit of how many bytes a message // can contain before Amazon SQS rejects it. // // * MessageRetentionPeriod – Returns the length of time, in seconds, for // which Amazon SQS retains a message. When you change a queue's attributes, // the change can take up to 60 seconds for most of the attributes to propagate // throughout the Amazon SQS system. Changes made to the MessageRetentionPeriod // attribute can take up to 15 minutes and will impact existing messages // in the queue potentially causing them to be expired and deleted if the // MessageRetentionPeriod is reduced below the age of existing messages. // // * Policy – Returns the policy of the queue. // // * QueueArn – Returns the Amazon resource name (ARN) of the queue. // // * ReceiveMessageWaitTimeSeconds – Returns the length of time, in seconds, // for which the ReceiveMessage action waits for a message to arrive. // // * VisibilityTimeout – Returns the visibility timeout for the queue. // For more information about the visibility timeout, see Visibility Timeout // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html) // in the Amazon SQS Developer Guide. // // The following attributes apply only to dead-letter queues: (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html) // // * RedrivePolicy – The string that includes the parameters for the dead-letter // queue functionality of the source queue as a JSON object. The parameters // are as follows: deadLetterTargetArn – The Amazon Resource Name (ARN) // of the dead-letter queue to which Amazon SQS moves messages after the // value of maxReceiveCount is exceeded. maxReceiveCount – The number of // times a message is delivered to the source queue before being moved to // the dead-letter queue. Default: 10. When the ReceiveCount for a message // exceeds the maxReceiveCount for a queue, Amazon SQS moves the message // to the dead-letter-queue. // // * RedriveAllowPolicy – The string that includes the parameters for the // permissions for the dead-letter queue redrive permission and which source // queues can specify dead-letter queues as a JSON object. The parameters // are as follows: redrivePermission – The permission type that defines // which source queues can specify the current queue as the dead-letter queue. // Valid values are: allowAll – (Default) Any source queues in this Amazon // Web Services account in the same Region can specify this queue as the // dead-letter queue. denyAll – No source queues can specify this queue // as the dead-letter queue. byQueue – Only queues specified by the sourceQueueArns // parameter can specify this queue as the dead-letter queue. sourceQueueArns // – The Amazon Resource Names (ARN)s of the source queues that can specify // this queue as the dead-letter queue and redrive messages. You can specify // this parameter only when the redrivePermission parameter is set to byQueue. // You can specify up to 10 source queue ARNs. To allow more than 10 source // queues to specify dead-letter queues, set the redrivePermission parameter // to allowAll. // // The dead-letter queue of a FIFO queue must also be a FIFO queue. Similarly, // the dead-letter queue of a standard queue must also be a standard queue. // // The following attributes apply only to server-side-encryption (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html): // // * KmsMasterKeyId – Returns the ID of an Amazon Web Services managed // customer master key (CMK) for Amazon SQS or a custom CMK. For more information, // see Key Terms (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html#sqs-sse-key-terms). // // * KmsDataKeyReusePeriodSeconds – Returns the length of time, in seconds, // for which Amazon SQS can reuse a data key to encrypt or decrypt messages // before calling KMS again. For more information, see How Does the Data // Key Reuse Period Work? (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html#sqs-how-does-the-data-key-reuse-period-work). // // * SqsManagedSseEnabled – Returns information about whether the queue // is using SSE-SQS encryption using SQS owned encryption keys. Only one // server-side encryption option is supported per queue (for example, SSE-KMS // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sse-existing-queue.html) // or SSE-SQS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sqs-sse-queue.html)). // // The following attributes apply only to FIFO (first-in-first-out) queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues.html): // // * FifoQueue – Returns information about whether the queue is FIFO. For // more information, see FIFO queue logic (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues-understanding-logic.html) // in the Amazon SQS Developer Guide. To determine whether a queue is FIFO // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues.html), // you can check whether QueueName ends with the .fifo suffix. // // * ContentBasedDeduplication – Returns whether content-based deduplication // is enabled for the queue. For more information, see Exactly-once processing // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues-exactly-once-processing.html) // in the Amazon SQS Developer Guide. // // The following attributes apply only to high throughput for FIFO queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/high-throughput-fifo.html): // // * DeduplicationScope – Specifies whether message deduplication occurs // at the message group or queue level. Valid values are messageGroup and // queue. // // * FifoThroughputLimit – Specifies whether the FIFO queue throughput // quota applies to the entire queue or per message group. Valid values are // perQueue and perMessageGroupId. The perMessageGroupId value is allowed // only when the value for DeduplicationScope is messageGroup. // // To enable high throughput for FIFO queues, do the following: // // * Set DeduplicationScope to messageGroup. // // * Set FifoThroughputLimit to perMessageGroupId. // // If you set these attributes to anything other than the values shown for enabling // high throughput, normal throughput is in effect and deduplication occurs // as specified. // // For information on throughput quotas, see Quotas related to messages (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/quotas-messages.html) // in the Amazon SQS Developer Guide. AttributeNames []string `type:"list" flattened:"true" enum:"QueueAttributeName"` // The URL of the Amazon SQS queue whose attribute information is retrieved. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetQueueAttributesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetQueueAttributesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s GetQueueAttributesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetQueueAttributesInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetAttributeNames sets the AttributeNames field's value. func (s GetQueueAttributesInput) SetAttributeNames(v []string) GetQueueAttributesInput { s.AttributeNames = v return s } // SetQueueUrl sets the QueueUrl field's value. func (s GetQueueAttributesInput) SetQueueUrl(v string) GetQueueAttributesInput { s.QueueUrl = &v return s } // A list of returned queue attributes. type GetQueueAttributesOutput struct { _ struct{} `type:"structure"` // A map of attributes to their respective values. Attributes map[string]string `type:"map" flattened:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetQueueAttributesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetQueueAttributesOutput) GoString() string { return s.String() } // SetAttributes sets the Attributes field's value. func (s GetQueueAttributesOutput) SetAttributes(v map[string]string) GetQueueAttributesOutput { s.Attributes = v return s } type GetQueueUrlInput struct { _ struct{} `type:"structure"` // The name of the queue whose URL must be fetched. Maximum 80 characters. Valid // values: alphanumeric characters, hyphens (-), and underscores (_). // // Queue URLs and names are case-sensitive. // // QueueName is a required field QueueName string `type:"string" required:"true"` // The Amazon Web Services account ID of the account that created the queue. QueueOwnerAWSAccountId string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetQueueUrlInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetQueueUrlInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s GetQueueUrlInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetQueueUrlInput"} if s.QueueName == nil { invalidParams.Add(request.NewErrParamRequired("QueueName")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetQueueName sets the QueueName field's value. func (s GetQueueUrlInput) SetQueueName(v string) GetQueueUrlInput { s.QueueName = &v return s } // SetQueueOwnerAWSAccountId sets the QueueOwnerAWSAccountId field's value. func (s GetQueueUrlInput) SetQueueOwnerAWSAccountId(v string) GetQueueUrlInput { s.QueueOwnerAWSAccountId = &v return s } // For more information, see Interpreting Responses (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-api-responses.html) // in the Amazon SQS Developer Guide. type GetQueueUrlOutput struct { _ struct{} `type:"structure"` // The URL of the queue. QueueUrl string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetQueueUrlOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetQueueUrlOutput) GoString() string { return s.String() } // SetQueueUrl sets the QueueUrl field's value. func (s GetQueueUrlOutput) SetQueueUrl(v string) GetQueueUrlOutput { s.QueueUrl = &v return s } // The accountId is invalid. type InvalidAddress struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidAddress) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidAddress) GoString() string { return s.String() } func newErrorInvalidAddress(v protocol.ResponseMetadata) error { return &InvalidAddress{ RespMetadata: v, } } func newQueryCompatibleErrorInvalidAddress(v protocol.ResponseMetadata, code string) error { return &InvalidAddress{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s InvalidAddress) Code() string { if s.Code_ != nil { return s.Code_ } return "InvalidAddress" } // Message returns the exception's message. func (s InvalidAddress) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidAddress) OrigErr() error { return nil } func (s InvalidAddress) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidAddress) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidAddress) RequestID() string { return s.RespMetadata.RequestID } // The specified attribute doesn't exist. type InvalidAttributeName struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidAttributeName) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidAttributeName) GoString() string { return s.String() } func newErrorInvalidAttributeName(v protocol.ResponseMetadata) error { return &InvalidAttributeName{ RespMetadata: v, } } func newQueryCompatibleErrorInvalidAttributeName(v protocol.ResponseMetadata, code string) error { return &InvalidAttributeName{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s InvalidAttributeName) Code() string { if s.Code_ != nil { return s.Code_ } return "InvalidAttributeName" } // Message returns the exception's message. func (s InvalidAttributeName) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidAttributeName) OrigErr() error { return nil } func (s InvalidAttributeName) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidAttributeName) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidAttributeName) RequestID() string { return s.RespMetadata.RequestID } // A queue attribute value is invalid. type InvalidAttributeValue struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidAttributeValue) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidAttributeValue) GoString() string { return s.String() } func newErrorInvalidAttributeValue(v protocol.ResponseMetadata) error { return &InvalidAttributeValue{ RespMetadata: v, } } func newQueryCompatibleErrorInvalidAttributeValue(v protocol.ResponseMetadata, code string) error { return &InvalidAttributeValue{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s InvalidAttributeValue) Code() string { if s.Code_ != nil { return s.Code_ } return "InvalidAttributeValue" } // Message returns the exception's message. func (s InvalidAttributeValue) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidAttributeValue) OrigErr() error { return nil } func (s InvalidAttributeValue) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidAttributeValue) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidAttributeValue) RequestID() string { return s.RespMetadata.RequestID } // The Id of a batch entry in a batch request doesn't abide by the specification. type InvalidBatchEntryId struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidBatchEntryId) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidBatchEntryId) GoString() string { return s.String() } func newErrorInvalidBatchEntryId(v protocol.ResponseMetadata) error { return &InvalidBatchEntryId{ RespMetadata: v, } } func newQueryCompatibleErrorInvalidBatchEntryId(v protocol.ResponseMetadata, code string) error { return &InvalidBatchEntryId{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s InvalidBatchEntryId) Code() string { if s.Code_ != nil { return s.Code_ } return "InvalidBatchEntryId" } // Message returns the exception's message. func (s InvalidBatchEntryId) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidBatchEntryId) OrigErr() error { return nil } func (s InvalidBatchEntryId) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidBatchEntryId) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidBatchEntryId) RequestID() string { return s.RespMetadata.RequestID } // The specified receipt handle isn't valid for the current version. // // Deprecated: exception has been included in ReceiptHandleIsInvalid type InvalidIdFormat struct { _ struct{} `deprecated:"true" type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidIdFormat) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidIdFormat) GoString() string { return s.String() } func newErrorInvalidIdFormat(v protocol.ResponseMetadata) error { return &InvalidIdFormat{ RespMetadata: v, } } func newQueryCompatibleErrorInvalidIdFormat(v protocol.ResponseMetadata, code string) error { return &InvalidIdFormat{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s InvalidIdFormat) Code() string { if s.Code_ != nil { return s.Code_ } return "InvalidIdFormat" } // Message returns the exception's message. func (s InvalidIdFormat) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidIdFormat) OrigErr() error { return nil } func (s InvalidIdFormat) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidIdFormat) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidIdFormat) RequestID() string { return s.RespMetadata.RequestID } // The message contains characters outside the allowed set. type InvalidMessageContents struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidMessageContents) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidMessageContents) GoString() string { return s.String() } func newErrorInvalidMessageContents(v protocol.ResponseMetadata) error { return &InvalidMessageContents{ RespMetadata: v, } } func newQueryCompatibleErrorInvalidMessageContents(v protocol.ResponseMetadata, code string) error { return &InvalidMessageContents{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s InvalidMessageContents) Code() string { if s.Code_ != nil { return s.Code_ } return "InvalidMessageContents" } // Message returns the exception's message. func (s InvalidMessageContents) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidMessageContents) OrigErr() error { return nil } func (s InvalidMessageContents) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidMessageContents) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidMessageContents) RequestID() string { return s.RespMetadata.RequestID } // When the request to a queue is not HTTPS and SigV4. type InvalidSecurity struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidSecurity) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidSecurity) GoString() string { return s.String() } func newErrorInvalidSecurity(v protocol.ResponseMetadata) error { return &InvalidSecurity{ RespMetadata: v, } } func newQueryCompatibleErrorInvalidSecurity(v protocol.ResponseMetadata, code string) error { return &InvalidSecurity{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s InvalidSecurity) Code() string { if s.Code_ != nil { return s.Code_ } return "InvalidSecurity" } // Message returns the exception's message. func (s InvalidSecurity) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidSecurity) OrigErr() error { return nil } func (s InvalidSecurity) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidSecurity) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidSecurity) RequestID() string { return s.RespMetadata.RequestID } // The caller doesn't have the required KMS access. type KmsAccessDenied struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsAccessDenied) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsAccessDenied) GoString() string { return s.String() } func newErrorKmsAccessDenied(v protocol.ResponseMetadata) error { return &KmsAccessDenied{ RespMetadata: v, } } func newQueryCompatibleErrorKmsAccessDenied(v protocol.ResponseMetadata, code string) error { return &KmsAccessDenied{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s KmsAccessDenied) Code() string { if s.Code_ != nil { return s.Code_ } return "KmsAccessDenied" } // Message returns the exception's message. func (s KmsAccessDenied) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s KmsAccessDenied) OrigErr() error { return nil } func (s KmsAccessDenied) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s KmsAccessDenied) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s KmsAccessDenied) RequestID() string { return s.RespMetadata.RequestID } // The request was denied due to request throttling. type KmsDisabled struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsDisabled) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsDisabled) GoString() string { return s.String() } func newErrorKmsDisabled(v protocol.ResponseMetadata) error { return &KmsDisabled{ RespMetadata: v, } } func newQueryCompatibleErrorKmsDisabled(v protocol.ResponseMetadata, code string) error { return &KmsDisabled{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s KmsDisabled) Code() string { if s.Code_ != nil { return s.Code_ } return "KmsDisabled" } // Message returns the exception's message. func (s KmsDisabled) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s KmsDisabled) OrigErr() error { return nil } func (s KmsDisabled) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s KmsDisabled) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s KmsDisabled) RequestID() string { return s.RespMetadata.RequestID } // The request was rejected for one of the following reasons: // // - The KeyUsage value of the KMS key is incompatible with the API operation. // // - The encryption algorithm or signing algorithm specified for the operation // is incompatible with the type of key material in the KMS key (KeySpec). type KmsInvalidKeyUsage struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsInvalidKeyUsage) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsInvalidKeyUsage) GoString() string { return s.String() } func newErrorKmsInvalidKeyUsage(v protocol.ResponseMetadata) error { return &KmsInvalidKeyUsage{ RespMetadata: v, } } func newQueryCompatibleErrorKmsInvalidKeyUsage(v protocol.ResponseMetadata, code string) error { return &KmsInvalidKeyUsage{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s KmsInvalidKeyUsage) Code() string { if s.Code_ != nil { return s.Code_ } return "KmsInvalidKeyUsage" } // Message returns the exception's message. func (s KmsInvalidKeyUsage) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s KmsInvalidKeyUsage) OrigErr() error { return nil } func (s KmsInvalidKeyUsage) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s KmsInvalidKeyUsage) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s KmsInvalidKeyUsage) RequestID() string { return s.RespMetadata.RequestID } // The request was rejected because the state of the specified resource is not // valid for this request. type KmsInvalidState struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsInvalidState) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsInvalidState) GoString() string { return s.String() } func newErrorKmsInvalidState(v protocol.ResponseMetadata) error { return &KmsInvalidState{ RespMetadata: v, } } func newQueryCompatibleErrorKmsInvalidState(v protocol.ResponseMetadata, code string) error { return &KmsInvalidState{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s KmsInvalidState) Code() string { if s.Code_ != nil { return s.Code_ } return "KmsInvalidState" } // Message returns the exception's message. func (s KmsInvalidState) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s KmsInvalidState) OrigErr() error { return nil } func (s KmsInvalidState) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s KmsInvalidState) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s KmsInvalidState) RequestID() string { return s.RespMetadata.RequestID } // The request was rejected because the specified entity or resource could not // be found. type KmsNotFound struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsNotFound) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsNotFound) GoString() string { return s.String() } func newErrorKmsNotFound(v protocol.ResponseMetadata) error { return &KmsNotFound{ RespMetadata: v, } } func newQueryCompatibleErrorKmsNotFound(v protocol.ResponseMetadata, code string) error { return &KmsNotFound{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s KmsNotFound) Code() string { if s.Code_ != nil { return s.Code_ } return "KmsNotFound" } // Message returns the exception's message. func (s KmsNotFound) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s KmsNotFound) OrigErr() error { return nil } func (s KmsNotFound) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s KmsNotFound) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s KmsNotFound) RequestID() string { return s.RespMetadata.RequestID } // The request was rejected because the specified key policy isn't syntactically // or semantically correct. type KmsOptInRequired struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsOptInRequired) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsOptInRequired) GoString() string { return s.String() } func newErrorKmsOptInRequired(v protocol.ResponseMetadata) error { return &KmsOptInRequired{ RespMetadata: v, } } func newQueryCompatibleErrorKmsOptInRequired(v protocol.ResponseMetadata, code string) error { return &KmsOptInRequired{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s KmsOptInRequired) Code() string { if s.Code_ != nil { return s.Code_ } return "KmsOptInRequired" } // Message returns the exception's message. func (s KmsOptInRequired) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s KmsOptInRequired) OrigErr() error { return nil } func (s KmsOptInRequired) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s KmsOptInRequired) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s KmsOptInRequired) RequestID() string { return s.RespMetadata.RequestID } // Amazon Web Services KMS throttles requests for the following conditions. type KmsThrottled struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsThrottled) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s KmsThrottled) GoString() string { return s.String() } func newErrorKmsThrottled(v protocol.ResponseMetadata) error { return &KmsThrottled{ RespMetadata: v, } } func newQueryCompatibleErrorKmsThrottled(v protocol.ResponseMetadata, code string) error { return &KmsThrottled{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s KmsThrottled) Code() string { if s.Code_ != nil { return s.Code_ } return "KmsThrottled" } // Message returns the exception's message. func (s KmsThrottled) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s KmsThrottled) OrigErr() error { return nil } func (s KmsThrottled) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s KmsThrottled) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s KmsThrottled) RequestID() string { return s.RespMetadata.RequestID } type ListDeadLetterSourceQueuesInput struct { _ struct{} `type:"structure"` // Maximum number of results to include in the response. Value range is 1 to // 1000. You must set MaxResults to receive a value for NextToken in the response. MaxResults int64 `type:"integer"` // Pagination token to request the next set of results. NextToken string `type:"string"` // The URL of a dead-letter queue. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListDeadLetterSourceQueuesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListDeadLetterSourceQueuesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ListDeadLetterSourceQueuesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListDeadLetterSourceQueuesInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s ListDeadLetterSourceQueuesInput) SetMaxResults(v int64) ListDeadLetterSourceQueuesInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s ListDeadLetterSourceQueuesInput) SetNextToken(v string) ListDeadLetterSourceQueuesInput { s.NextToken = &v return s } // SetQueueUrl sets the QueueUrl field's value. func (s ListDeadLetterSourceQueuesInput) SetQueueUrl(v string) ListDeadLetterSourceQueuesInput { s.QueueUrl = &v return s } // A list of your dead letter source queues. type ListDeadLetterSourceQueuesOutput struct { _ struct{} `type:"structure"` // Pagination token to include in the next request. Token value is null if there // are no additional results to request, or if you did not set MaxResults in // the request. NextToken string `type:"string"` // A list of source queue URLs that have the RedrivePolicy queue attribute configured // with a dead-letter queue. // // QueueUrls is a required field QueueUrls []string `locationName:"queueUrls" type:"list" flattened:"true" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListDeadLetterSourceQueuesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListDeadLetterSourceQueuesOutput) GoString() string { return s.String() } // SetNextToken sets the NextToken field's value. func (s ListDeadLetterSourceQueuesOutput) SetNextToken(v string) ListDeadLetterSourceQueuesOutput { s.NextToken = &v return s } // SetQueueUrls sets the QueueUrls field's value. func (s ListDeadLetterSourceQueuesOutput) SetQueueUrls(v []string) ListDeadLetterSourceQueuesOutput { s.QueueUrls = v return s } type ListMessageMoveTasksInput struct { _ struct{} `type:"structure"` // The maximum number of results to include in the response. The default is // 1, which provides the most recent message movement task. The upper limit // is 10. MaxResults int64 `type:"integer"` // The ARN of the queue whose message movement tasks are to be listed. // // SourceArn is a required field SourceArn string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMessageMoveTasksInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMessageMoveTasksInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ListMessageMoveTasksInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListMessageMoveTasksInput"} if s.SourceArn == nil { invalidParams.Add(request.NewErrParamRequired("SourceArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s ListMessageMoveTasksInput) SetMaxResults(v int64) ListMessageMoveTasksInput { s.MaxResults = &v return s } // SetSourceArn sets the SourceArn field's value. func (s ListMessageMoveTasksInput) SetSourceArn(v string) ListMessageMoveTasksInput { s.SourceArn = &v return s } type ListMessageMoveTasksOutput struct { _ struct{} `type:"structure"` // A list of message movement tasks and their attributes. Results []ListMessageMoveTasksResultEntry `type:"list" flattened:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMessageMoveTasksOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMessageMoveTasksOutput) GoString() string { return s.String() } // SetResults sets the Results field's value. func (s ListMessageMoveTasksOutput) SetResults(v []ListMessageMoveTasksResultEntry) ListMessageMoveTasksOutput { s.Results = v return s } // Contains the details of a message movement task. type ListMessageMoveTasksResultEntry struct { _ struct{} `type:"structure"` // The approximate number of messages already moved to the destination queue. ApproximateNumberOfMessagesMoved int64 `type:"long"` // The number of messages to be moved from the source queue. This number is // obtained at the time of starting the message movement task and is only included // after the message movement task is selected to start. ApproximateNumberOfMessagesToMove int64 `type:"long"` // The ARN of the destination queue if it has been specified in the StartMessageMoveTask // request. If a DestinationArn has not been specified in the StartMessageMoveTask // request, this field value will be NULL. DestinationArn string `type:"string"` // The task failure reason (only included if the task status is FAILED). FailureReason string `type:"string"` // The number of messages to be moved per second (the message movement rate), // if it has been specified in the StartMessageMoveTask request. If a MaxNumberOfMessagesPerSecond // has not been specified in the StartMessageMoveTask request, this field value // will be NULL. MaxNumberOfMessagesPerSecond int64 `type:"integer"` // The ARN of the queue that contains the messages to be moved to another queue. SourceArn string `type:"string"` // The timestamp of starting the message movement task. StartedTimestamp int64 `type:"long"` // The status of the message movement task. Possible values are: RUNNING, COMPLETED, // CANCELLING, CANCELLED, and FAILED. Status string `type:"string"` // An identifier associated with a message movement task. When this field is // returned in the response of the ListMessageMoveTasks action, it is only populated // for tasks that are in RUNNING status. TaskHandle string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMessageMoveTasksResultEntry) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListMessageMoveTasksResultEntry) GoString() string { return s.String() } // SetApproximateNumberOfMessagesMoved sets the ApproximateNumberOfMessagesMoved field's value. func (s ListMessageMoveTasksResultEntry) SetApproximateNumberOfMessagesMoved(v int64) ListMessageMoveTasksResultEntry { s.ApproximateNumberOfMessagesMoved = &v return s } // SetApproximateNumberOfMessagesToMove sets the ApproximateNumberOfMessagesToMove field's value. func (s ListMessageMoveTasksResultEntry) SetApproximateNumberOfMessagesToMove(v int64) ListMessageMoveTasksResultEntry { s.ApproximateNumberOfMessagesToMove = &v return s } // SetDestinationArn sets the DestinationArn field's value. func (s ListMessageMoveTasksResultEntry) SetDestinationArn(v string) ListMessageMoveTasksResultEntry { s.DestinationArn = &v return s } // SetFailureReason sets the FailureReason field's value. func (s ListMessageMoveTasksResultEntry) SetFailureReason(v string) ListMessageMoveTasksResultEntry { s.FailureReason = &v return s } // SetMaxNumberOfMessagesPerSecond sets the MaxNumberOfMessagesPerSecond field's value. func (s ListMessageMoveTasksResultEntry) SetMaxNumberOfMessagesPerSecond(v int64) ListMessageMoveTasksResultEntry { s.MaxNumberOfMessagesPerSecond = &v return s } // SetSourceArn sets the SourceArn field's value. func (s ListMessageMoveTasksResultEntry) SetSourceArn(v string) ListMessageMoveTasksResultEntry { s.SourceArn = &v return s } // SetStartedTimestamp sets the StartedTimestamp field's value. func (s ListMessageMoveTasksResultEntry) SetStartedTimestamp(v int64) ListMessageMoveTasksResultEntry { s.StartedTimestamp = &v return s } // SetStatus sets the Status field's value. func (s ListMessageMoveTasksResultEntry) SetStatus(v string) ListMessageMoveTasksResultEntry { s.Status = &v return s } // SetTaskHandle sets the TaskHandle field's value. func (s ListMessageMoveTasksResultEntry) SetTaskHandle(v string) ListMessageMoveTasksResultEntry { s.TaskHandle = &v return s } type ListQueueTagsInput struct { _ struct{} `type:"structure"` // The URL of the queue. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListQueueTagsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListQueueTagsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ListQueueTagsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListQueueTagsInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetQueueUrl sets the QueueUrl field's value. func (s ListQueueTagsInput) SetQueueUrl(v string) ListQueueTagsInput { s.QueueUrl = &v return s } type ListQueueTagsOutput struct { _ struct{} `type:"structure"` // The list of all tags added to the specified queue. Tags map[string]string `type:"map" flattened:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListQueueTagsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListQueueTagsOutput) GoString() string { return s.String() } // SetTags sets the Tags field's value. func (s ListQueueTagsOutput) SetTags(v map[string]string) ListQueueTagsOutput { s.Tags = v return s } type ListQueuesInput struct { _ struct{} `type:"structure"` // Maximum number of results to include in the response. Value range is 1 to // 1000. You must set MaxResults to receive a value for NextToken in the response. MaxResults int64 `type:"integer"` // Pagination token to request the next set of results. NextToken string `type:"string"` // A string to use for filtering the list results. Only those queues whose name // begins with the specified string are returned. // // Queue URLs and names are case-sensitive. QueueNamePrefix string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListQueuesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListQueuesInput) GoString() string { return s.String() } // SetMaxResults sets the MaxResults field's value. func (s ListQueuesInput) SetMaxResults(v int64) ListQueuesInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s ListQueuesInput) SetNextToken(v string) ListQueuesInput { s.NextToken = &v return s } // SetQueueNamePrefix sets the QueueNamePrefix field's value. func (s ListQueuesInput) SetQueueNamePrefix(v string) ListQueuesInput { s.QueueNamePrefix = &v return s } // A list of your queues. type ListQueuesOutput struct { _ struct{} `type:"structure"` // Pagination token to include in the next request. Token value is null if there // are no additional results to request, or if you did not set MaxResults in // the request. NextToken string `type:"string"` // A list of queue URLs, up to 1,000 entries, or the value of MaxResults that // you sent in the request. QueueUrls []string `type:"list" flattened:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListQueuesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListQueuesOutput) GoString() string { return s.String() } // SetNextToken sets the NextToken field's value. func (s ListQueuesOutput) SetNextToken(v string) ListQueuesOutput { s.NextToken = &v return s } // SetQueueUrls sets the QueueUrls field's value. func (s ListQueuesOutput) SetQueueUrls(v []string) ListQueuesOutput { s.QueueUrls = v return s } // An Amazon SQS message. type Message struct { _ struct{} `type:"structure"` // A map of the attributes requested in ReceiveMessage to their respective values. // Supported attributes: // // ApproximateReceiveCount // // * ApproximateFirstReceiveTimestamp // // * MessageDeduplicationId // // * MessageGroupId // // * SenderId // // * SentTimestamp // // * SequenceNumber // // ApproximateFirstReceiveTimestamp and SentTimestamp are each returned as an // integer representing the epoch time (http://en.wikipedia.org/wiki/Unix_time) // in milliseconds. Attributes map[string]string `type:"map" flattened:"true"` // The message's contents (not URL-encoded). Body string `type:"string"` // An MD5 digest of the non-URL-encoded message body string. MD5OfBody string `type:"string"` // An MD5 digest of the non-URL-encoded message attribute string. You can use // this attribute to verify that Amazon SQS received the message correctly. // Amazon SQS URL-decodes the message before creating the MD5 digest. For information // about MD5, see RFC1321 (https://www.ietf.org/rfc/rfc1321.txt). MD5OfMessageAttributes string `type:"string"` // Each message attribute consists of a Name, Type, and Value. For more information, // see Amazon SQS message attributes (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes) // in the Amazon SQS Developer Guide. MessageAttributes map[string]MessageAttributeValue `type:"map" flattened:"true"` // A unique identifier for the message. A MessageIdis considered unique across // all Amazon Web Services accounts for an extended period of time. MessageId string `type:"string"` // An identifier associated with the act of receiving the message. A new receipt // handle is returned every time you receive a message. When deleting a message, // you provide the last received receipt handle to delete the message. ReceiptHandle string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Message) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Message) GoString() string { return s.String() } // SetAttributes sets the Attributes field's value. func (s Message) SetAttributes(v map[string]string) Message { s.Attributes = v return s } // SetBody sets the Body field's value. func (s Message) SetBody(v string) Message { s.Body = &v return s } // SetMD5OfBody sets the MD5OfBody field's value. func (s Message) SetMD5OfBody(v string) Message { s.MD5OfBody = &v return s } // SetMD5OfMessageAttributes sets the MD5OfMessageAttributes field's value. func (s Message) SetMD5OfMessageAttributes(v string) Message { s.MD5OfMessageAttributes = &v return s } // SetMessageAttributes sets the MessageAttributes field's value. func (s Message) SetMessageAttributes(v map[string]MessageAttributeValue) Message { s.MessageAttributes = v return s } // SetMessageId sets the MessageId field's value. func (s Message) SetMessageId(v string) Message { s.MessageId = &v return s } // SetReceiptHandle sets the ReceiptHandle field's value. func (s Message) SetReceiptHandle(v string) Message { s.ReceiptHandle = &v return s } // The user-specified message attribute value. For string data types, the Value // attribute has the same restrictions on the content as the message body. For // more information, see SendMessage. // // Name, type, value and the message body must not be empty or null. All parts // of the message attribute, including Name, Type, and Value, are part of the // message size restriction (256 KiB or 262,144 bytes). type MessageAttributeValue struct { _ struct{} `type:"structure"` // Not implemented. Reserved for future use. BinaryListValues [][]byte `type:"list" flattened:"true"` // Binary type attributes can store any binary data, such as compressed data, // encrypted data, or images. // BinaryValue is automatically base64 encoded/decoded by the SDK. BinaryValue []byte `type:"blob"` // Amazon SQS supports the following logical data types: String, Number, and // Binary. For the Number data type, you must use StringValue. // // You can also append custom labels. For more information, see Amazon SQS Message // Attributes (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes) // in the Amazon SQS Developer Guide. // // DataType is a required field DataType string `type:"string" required:"true"` // Not implemented. Reserved for future use. StringListValues []string `type:"list" flattened:"true"` // Strings are Unicode with UTF-8 binary encoding. For a list of code values, // see ASCII Printable Characters (http://en.wikipedia.org/wiki/ASCII#ASCII_printable_characters). StringValue string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MessageAttributeValue) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MessageAttributeValue) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s MessageAttributeValue) Validate() error { invalidParams := request.ErrInvalidParams{Context: "MessageAttributeValue"} if s.DataType == nil { invalidParams.Add(request.NewErrParamRequired("DataType")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetBinaryListValues sets the BinaryListValues field's value. func (s MessageAttributeValue) SetBinaryListValues(v [][]byte) MessageAttributeValue { s.BinaryListValues = v return s } // SetBinaryValue sets the BinaryValue field's value. func (s MessageAttributeValue) SetBinaryValue(v []byte) MessageAttributeValue { s.BinaryValue = v return s } // SetDataType sets the DataType field's value. func (s MessageAttributeValue) SetDataType(v string) MessageAttributeValue { s.DataType = &v return s } // SetStringListValues sets the StringListValues field's value. func (s MessageAttributeValue) SetStringListValues(v []string) MessageAttributeValue { s.StringListValues = v return s } // SetStringValue sets the StringValue field's value. func (s MessageAttributeValue) SetStringValue(v string) MessageAttributeValue { s.StringValue = &v return s } // The specified message isn't in flight. type MessageNotInflight struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MessageNotInflight) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MessageNotInflight) GoString() string { return s.String() } func newErrorMessageNotInflight(v protocol.ResponseMetadata) error { return &MessageNotInflight{ RespMetadata: v, } } func newQueryCompatibleErrorMessageNotInflight(v protocol.ResponseMetadata, code string) error { return &MessageNotInflight{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s MessageNotInflight) Code() string { if s.Code_ != nil { return s.Code_ } return "MessageNotInflight" } // Message returns the exception's message. func (s MessageNotInflight) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s MessageNotInflight) OrigErr() error { return nil } func (s MessageNotInflight) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s MessageNotInflight) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s MessageNotInflight) RequestID() string { return s.RespMetadata.RequestID } // The user-specified message system attribute value. For string data types, // the Value attribute has the same restrictions on the content as the message // body. For more information, see SendMessage. // // Name, type, value and the message body must not be empty or null. type MessageSystemAttributeValue struct { _ struct{} `type:"structure"` // Not implemented. Reserved for future use. BinaryListValues [][]byte `type:"list" flattened:"true"` // Binary type attributes can store any binary data, such as compressed data, // encrypted data, or images. // BinaryValue is automatically base64 encoded/decoded by the SDK. BinaryValue []byte `type:"blob"` // Amazon SQS supports the following logical data types: String, Number, and // Binary. For the Number data type, you must use StringValue. // // You can also append custom labels. For more information, see Amazon SQS Message // Attributes (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes) // in the Amazon SQS Developer Guide. // // DataType is a required field DataType string `type:"string" required:"true"` // Not implemented. Reserved for future use. StringListValues []string `type:"list" flattened:"true"` // Strings are Unicode with UTF-8 binary encoding. For a list of code values, // see ASCII Printable Characters (http://en.wikipedia.org/wiki/ASCII#ASCII_printable_characters). StringValue string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MessageSystemAttributeValue) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MessageSystemAttributeValue) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s MessageSystemAttributeValue) Validate() error { invalidParams := request.ErrInvalidParams{Context: "MessageSystemAttributeValue"} if s.DataType == nil { invalidParams.Add(request.NewErrParamRequired("DataType")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetBinaryListValues sets the BinaryListValues field's value. func (s MessageSystemAttributeValue) SetBinaryListValues(v [][]byte) MessageSystemAttributeValue { s.BinaryListValues = v return s } // SetBinaryValue sets the BinaryValue field's value. func (s MessageSystemAttributeValue) SetBinaryValue(v []byte) MessageSystemAttributeValue { s.BinaryValue = v return s } // SetDataType sets the DataType field's value. func (s MessageSystemAttributeValue) SetDataType(v string) MessageSystemAttributeValue { s.DataType = &v return s } // SetStringListValues sets the StringListValues field's value. func (s MessageSystemAttributeValue) SetStringListValues(v []string) MessageSystemAttributeValue { s.StringListValues = v return s } // SetStringValue sets the StringValue field's value. func (s MessageSystemAttributeValue) SetStringValue(v string) MessageSystemAttributeValue { s.StringValue = &v return s } // The specified action violates a limit. For example, ReceiveMessage returns // this error if the maximum number of in flight messages is reached and AddPermission // returns this error if the maximum number of permissions for the queue is // reached. type OverLimit struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s OverLimit) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s OverLimit) GoString() string { return s.String() } func newErrorOverLimit(v protocol.ResponseMetadata) error { return &OverLimit{ RespMetadata: v, } } func newQueryCompatibleErrorOverLimit(v protocol.ResponseMetadata, code string) error { return &OverLimit{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s OverLimit) Code() string { if s.Code_ != nil { return s.Code_ } return "OverLimit" } // Message returns the exception's message. func (s OverLimit) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s OverLimit) OrigErr() error { return nil } func (s OverLimit) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s OverLimit) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s OverLimit) RequestID() string { return s.RespMetadata.RequestID } // Indicates that the specified queue previously received a PurgeQueue request // within the last 60 seconds (the time it can take to delete the messages in // the queue). type PurgeQueueInProgress struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PurgeQueueInProgress) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PurgeQueueInProgress) GoString() string { return s.String() } func newErrorPurgeQueueInProgress(v protocol.ResponseMetadata) error { return &PurgeQueueInProgress{ RespMetadata: v, } } func newQueryCompatibleErrorPurgeQueueInProgress(v protocol.ResponseMetadata, code string) error { return &PurgeQueueInProgress{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s PurgeQueueInProgress) Code() string { if s.Code_ != nil { return s.Code_ } return "PurgeQueueInProgress" } // Message returns the exception's message. func (s PurgeQueueInProgress) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s PurgeQueueInProgress) OrigErr() error { return nil } func (s PurgeQueueInProgress) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s PurgeQueueInProgress) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s PurgeQueueInProgress) RequestID() string { return s.RespMetadata.RequestID } type PurgeQueueInput struct { _ struct{} `type:"structure"` // The URL of the queue from which the PurgeQueue action deletes messages. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PurgeQueueInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PurgeQueueInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s PurgeQueueInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "PurgeQueueInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetQueueUrl sets the QueueUrl field's value. func (s PurgeQueueInput) SetQueueUrl(v string) PurgeQueueInput { s.QueueUrl = &v return s } type PurgeQueueOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PurgeQueueOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PurgeQueueOutput) GoString() string { return s.String() } // You must wait 60 seconds after deleting a queue before you can create another // queue with the same name. type QueueDeletedRecently struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s QueueDeletedRecently) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s QueueDeletedRecently) GoString() string { return s.String() } func newErrorQueueDeletedRecently(v protocol.ResponseMetadata) error { return &QueueDeletedRecently{ RespMetadata: v, } } func newQueryCompatibleErrorQueueDeletedRecently(v protocol.ResponseMetadata, code string) error { return &QueueDeletedRecently{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s QueueDeletedRecently) Code() string { if s.Code_ != nil { return s.Code_ } return "QueueDeletedRecently" } // Message returns the exception's message. func (s QueueDeletedRecently) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s QueueDeletedRecently) OrigErr() error { return nil } func (s QueueDeletedRecently) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s QueueDeletedRecently) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s QueueDeletedRecently) RequestID() string { return s.RespMetadata.RequestID } // The specified queue doesn't exist. type QueueDoesNotExist struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s QueueDoesNotExist) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s QueueDoesNotExist) GoString() string { return s.String() } func newErrorQueueDoesNotExist(v protocol.ResponseMetadata) error { return &QueueDoesNotExist{ RespMetadata: v, } } func newQueryCompatibleErrorQueueDoesNotExist(v protocol.ResponseMetadata, code string) error { return &QueueDoesNotExist{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s QueueDoesNotExist) Code() string { if s.Code_ != nil { return s.Code_ } return "QueueDoesNotExist" } // Message returns the exception's message. func (s QueueDoesNotExist) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s QueueDoesNotExist) OrigErr() error { return nil } func (s QueueDoesNotExist) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s QueueDoesNotExist) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s QueueDoesNotExist) RequestID() string { return s.RespMetadata.RequestID } // A queue with this name already exists. Amazon SQS returns this error only // if the request includes attributes whose values differ from those of the // existing queue. type QueueNameExists struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s QueueNameExists) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s QueueNameExists) GoString() string { return s.String() } func newErrorQueueNameExists(v protocol.ResponseMetadata) error { return &QueueNameExists{ RespMetadata: v, } } func newQueryCompatibleErrorQueueNameExists(v protocol.ResponseMetadata, code string) error { return &QueueNameExists{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s QueueNameExists) Code() string { if s.Code_ != nil { return s.Code_ } return "QueueNameExists" } // Message returns the exception's message. func (s QueueNameExists) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s QueueNameExists) OrigErr() error { return nil } func (s QueueNameExists) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s QueueNameExists) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s QueueNameExists) RequestID() string { return s.RespMetadata.RequestID } // The specified receipt handle isn't valid. type ReceiptHandleIsInvalid struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ReceiptHandleIsInvalid) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ReceiptHandleIsInvalid) GoString() string { return s.String() } func newErrorReceiptHandleIsInvalid(v protocol.ResponseMetadata) error { return &ReceiptHandleIsInvalid{ RespMetadata: v, } } func newQueryCompatibleErrorReceiptHandleIsInvalid(v protocol.ResponseMetadata, code string) error { return &ReceiptHandleIsInvalid{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s ReceiptHandleIsInvalid) Code() string { if s.Code_ != nil { return s.Code_ } return "ReceiptHandleIsInvalid" } // Message returns the exception's message. func (s ReceiptHandleIsInvalid) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s ReceiptHandleIsInvalid) OrigErr() error { return nil } func (s ReceiptHandleIsInvalid) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s ReceiptHandleIsInvalid) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s ReceiptHandleIsInvalid) RequestID() string { return s.RespMetadata.RequestID } type ReceiveMessageInput struct { _ struct{} `type:"structure"` // // This parameter has been deprecated but will be supported for backward compatibility. // To provide attribute names, you are encouraged to use MessageSystemAttributeNames. // // A list of attributes that need to be returned along with each message. These // attributes include: // // All – Returns all values. // // * ApproximateFirstReceiveTimestamp – Returns the time the message was // first received from the queue (epoch time (http://en.wikipedia.org/wiki/Unix_time) // in milliseconds). // // * ApproximateReceiveCount – Returns the number of times a message has // been received across all queues but not deleted. // // * AWSTraceHeader – Returns the X-Ray trace header string. // // * SenderId For a user, returns the user ID, for example ABCDEFGHI1JKLMNOPQ23R. // For an IAM role, returns the IAM role ID, for example ABCDE1F2GH3I4JK5LMNOP:i-a123b456. // // * SentTimestamp – Returns the time the message was sent to the queue // (epoch time (http://en.wikipedia.org/wiki/Unix_time) in milliseconds). // // * SqsManagedSseEnabled – Enables server-side queue encryption using // SQS owned encryption keys. Only one server-side encryption option is supported // per queue (for example, SSE-KMS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sse-existing-queue.html) // or SSE-SQS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sqs-sse-queue.html)). // // * MessageDeduplicationId – Returns the value provided by the producer // that calls the SendMessage action. // // * MessageGroupId – Returns the value provided by the producer that calls // the SendMessage action. Messages with the same MessageGroupId are returned // in sequence. // // * SequenceNumber – Returns the value provided by Amazon SQS. // // Deprecated: AttributeNames has been replaced by MessageSystemAttributeNames AttributeNames []string `deprecated:"true" type:"list" flattened:"true" enum:"QueueAttributeName"` // The maximum number of messages to return. Amazon SQS never returns more messages // than this value (however, fewer messages might be returned). Valid values: // 1 to 10. Default: 1. MaxNumberOfMessages int64 `type:"integer"` // The name of the message attribute, where N is the index. // // * The name can contain alphanumeric characters and the underscore (_), // hyphen (-), and period (.). // // * The name is case-sensitive and must be unique among all attribute names // for the message. // // * The name must not start with AWS-reserved prefixes such as AWS. or Amazon. // (or any casing variants). // // * The name must not start or end with a period (.), and it should not // have periods in succession (..). // // * The name can be up to 256 characters long. // // When using ReceiveMessage, you can send a list of attribute names to receive, // or you can return all of the attributes by specifying All or .* in your request. // You can also use all message attributes starting with a prefix, for example // bar.. MessageAttributeNames []string `type:"list" flattened:"true"` // A list of attributes that need to be returned along with each message. These // attributes include: // // * All – Returns all values. // // * ApproximateFirstReceiveTimestamp – Returns the time the message was // first received from the queue (epoch time (http://en.wikipedia.org/wiki/Unix_time) // in milliseconds). // // * ApproximateReceiveCount – Returns the number of times a message has // been received across all queues but not deleted. // // * AWSTraceHeader – Returns the X-Ray trace header string. // // * SenderId For a user, returns the user ID, for example ABCDEFGHI1JKLMNOPQ23R. // For an IAM role, returns the IAM role ID, for example ABCDE1F2GH3I4JK5LMNOP:i-a123b456. // // * SentTimestamp – Returns the time the message was sent to the queue // (epoch time (http://en.wikipedia.org/wiki/Unix_time) in milliseconds). // // * SqsManagedSseEnabled – Enables server-side queue encryption using // SQS owned encryption keys. Only one server-side encryption option is supported // per queue (for example, SSE-KMS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sse-existing-queue.html) // or SSE-SQS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sqs-sse-queue.html)). // // * MessageDeduplicationId – Returns the value provided by the producer // that calls the SendMessage action. // // * MessageGroupId – Returns the value provided by the producer that calls // the SendMessage action. Messages with the same MessageGroupId are returned // in sequence. // // * SequenceNumber – Returns the value provided by Amazon SQS. MessageSystemAttributeNames []string `type:"list" flattened:"true" enum:"MessageSystemAttributeName"` // The URL of the Amazon SQS queue from which messages are received. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` // This parameter applies only to FIFO (first-in-first-out) queues. // // The token used for deduplication of ReceiveMessage calls. If a networking // issue occurs after a ReceiveMessage action, and instead of a response you // receive a generic error, it is possible to retry the same action with an // identical ReceiveRequestAttemptId to retrieve the same set of messages, even // if their visibility timeout has not yet expired. // // * You can use ReceiveRequestAttemptId only for 5 minutes after a ReceiveMessage // action. // // * When you set FifoQueue, a caller of the ReceiveMessage action can provide // a ReceiveRequestAttemptId explicitly. // // * It is possible to retry the ReceiveMessage action with the same ReceiveRequestAttemptId // if none of the messages have been modified (deleted or had their visibility // changes). // // * During a visibility timeout, subsequent calls with the same ReceiveRequestAttemptId // return the same messages and receipt handles. If a retry occurs within // the deduplication interval, it resets the visibility timeout. For more // information, see Visibility Timeout (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html) // in the Amazon SQS Developer Guide. If a caller of the ReceiveMessage action // still processes messages when the visibility timeout expires and messages // become visible, another worker consuming from the same queue can receive // the same messages and therefore process duplicates. Also, if a consumer // whose message processing time is longer than the visibility timeout tries // to delete the processed messages, the action fails with an error. To mitigate // this effect, ensure that your application observes a safe threshold before // the visibility timeout expires and extend the visibility timeout as necessary. // // * While messages with a particular MessageGroupId are invisible, no more // messages belonging to the same MessageGroupId are returned until the visibility // timeout expires. You can still receive messages with another MessageGroupId // as long as it is also visible. // // * If a caller of ReceiveMessage can't track the ReceiveRequestAttemptId, // no retries work until the original visibility timeout expires. As a result, // delays might occur but the messages in the queue remain in a strict order. // // The maximum length of ReceiveRequestAttemptId is 128 characters. ReceiveRequestAttemptId // can contain alphanumeric characters (a-z, A-Z, 0-9) and punctuation (!"#$%&'()+,-./:;<=>?@[\]^_`{\|}~). // // For best practices of using ReceiveRequestAttemptId, see Using the ReceiveRequestAttemptId // Request Parameter (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/using-receiverequestattemptid-request-parameter.html) // in the Amazon SQS Developer Guide. ReceiveRequestAttemptId string `type:"string"` // The duration (in seconds) that the received messages are hidden from subsequent // retrieve requests after being retrieved by a ReceiveMessage request. VisibilityTimeout int64 `type:"integer"` // The duration (in seconds) for which the call waits for a message to arrive // in the queue before returning. If a message is available, the call returns // sooner than WaitTimeSeconds. If no messages are available and the wait time // expires, the call does not return a message list. // // To avoid HTTP errors, ensure that the HTTP response timeout for ReceiveMessage // requests is longer than the WaitTimeSeconds parameter. For example, with // the Java SDK, you can set HTTP transport settings using the NettyNioAsyncHttpClient // (https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/http/nio/netty/NettyNioAsyncHttpClient.html) // for asynchronous clients, or the ApacheHttpClient (https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/http/apache/ApacheHttpClient.html) // for synchronous clients. WaitTimeSeconds int64 `type:"integer"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ReceiveMessageInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ReceiveMessageInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ReceiveMessageInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ReceiveMessageInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetAttributeNames sets the AttributeNames field's value. func (s ReceiveMessageInput) SetAttributeNames(v []string) ReceiveMessageInput { s.AttributeNames = v return s } // SetMaxNumberOfMessages sets the MaxNumberOfMessages field's value. func (s ReceiveMessageInput) SetMaxNumberOfMessages(v int64) ReceiveMessageInput { s.MaxNumberOfMessages = &v return s } // SetMessageAttributeNames sets the MessageAttributeNames field's value. func (s ReceiveMessageInput) SetMessageAttributeNames(v []string) ReceiveMessageInput { s.MessageAttributeNames = v return s } // SetMessageSystemAttributeNames sets the MessageSystemAttributeNames field's value. func (s ReceiveMessageInput) SetMessageSystemAttributeNames(v []string) ReceiveMessageInput { s.MessageSystemAttributeNames = v return s } // SetQueueUrl sets the QueueUrl field's value. func (s ReceiveMessageInput) SetQueueUrl(v string) ReceiveMessageInput { s.QueueUrl = &v return s } // SetReceiveRequestAttemptId sets the ReceiveRequestAttemptId field's value. func (s ReceiveMessageInput) SetReceiveRequestAttemptId(v string) ReceiveMessageInput { s.ReceiveRequestAttemptId = &v return s } // SetVisibilityTimeout sets the VisibilityTimeout field's value. func (s ReceiveMessageInput) SetVisibilityTimeout(v int64) ReceiveMessageInput { s.VisibilityTimeout = &v return s } // SetWaitTimeSeconds sets the WaitTimeSeconds field's value. func (s ReceiveMessageInput) SetWaitTimeSeconds(v int64) ReceiveMessageInput { s.WaitTimeSeconds = &v return s } // A list of received messages. type ReceiveMessageOutput struct { _ struct{} `type:"structure"` // A list of messages. Messages []Message `type:"list" flattened:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ReceiveMessageOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ReceiveMessageOutput) GoString() string { return s.String() } // SetMessages sets the Messages field's value. func (s ReceiveMessageOutput) SetMessages(v []Message) ReceiveMessageOutput { s.Messages = v return s } type RemovePermissionInput struct { _ struct{} `type:"structure"` // The identification of the permission to remove. This is the label added using // the AddPermission action. // // Label is a required field Label string `type:"string" required:"true"` // The URL of the Amazon SQS queue from which permissions are removed. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RemovePermissionInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RemovePermissionInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s RemovePermissionInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "RemovePermissionInput"} if s.Label == nil { invalidParams.Add(request.NewErrParamRequired("Label")) } if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetLabel sets the Label field's value. func (s RemovePermissionInput) SetLabel(v string) RemovePermissionInput { s.Label = &v return s } // SetQueueUrl sets the QueueUrl field's value. func (s RemovePermissionInput) SetQueueUrl(v string) RemovePermissionInput { s.QueueUrl = &v return s } type RemovePermissionOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RemovePermissionOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RemovePermissionOutput) GoString() string { return s.String() } // The request was denied due to request throttling. // // - The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // - A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // - Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. type RequestThrottled struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RequestThrottled) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RequestThrottled) GoString() string { return s.String() } func newErrorRequestThrottled(v protocol.ResponseMetadata) error { return &RequestThrottled{ RespMetadata: v, } } func newQueryCompatibleErrorRequestThrottled(v protocol.ResponseMetadata, code string) error { return &RequestThrottled{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s RequestThrottled) Code() string { if s.Code_ != nil { return s.Code_ } return "RequestThrottled" } // Message returns the exception's message. func (s RequestThrottled) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s RequestThrottled) OrigErr() error { return nil } func (s RequestThrottled) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s RequestThrottled) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s RequestThrottled) RequestID() string { return s.RespMetadata.RequestID } // One or more specified resources don't exist. type ResourceNotFoundException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ResourceNotFoundException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ResourceNotFoundException) GoString() string { return s.String() } func newErrorResourceNotFoundException(v protocol.ResponseMetadata) error { return &ResourceNotFoundException{ RespMetadata: v, } } func newQueryCompatibleErrorResourceNotFoundException(v protocol.ResponseMetadata, code string) error { return &ResourceNotFoundException{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s ResourceNotFoundException) Code() string { if s.Code_ != nil { return s.Code_ } return "ResourceNotFoundException" } // Message returns the exception's message. func (s ResourceNotFoundException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s ResourceNotFoundException) OrigErr() error { return nil } func (s ResourceNotFoundException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s ResourceNotFoundException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s ResourceNotFoundException) RequestID() string { return s.RespMetadata.RequestID } type SendMessageBatchInput struct { _ struct{} `type:"structure"` // A list of SendMessageBatchRequestEntry items. // // Entries is a required field Entries []SendMessageBatchRequestEntry `type:"list" flattened:"true" required:"true"` // The URL of the Amazon SQS queue to which batched messages are sent. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageBatchInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageBatchInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s SendMessageBatchInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SendMessageBatchInput"} if s.Entries == nil { invalidParams.Add(request.NewErrParamRequired("Entries")) } if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.Entries != nil { for i, v := range s.Entries { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "Entries", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetEntries sets the Entries field's value. func (s SendMessageBatchInput) SetEntries(v []SendMessageBatchRequestEntry) SendMessageBatchInput { s.Entries = v return s } // SetQueueUrl sets the QueueUrl field's value. func (s SendMessageBatchInput) SetQueueUrl(v string) SendMessageBatchInput { s.QueueUrl = &v return s } // For each message in the batch, the response contains a SendMessageBatchResultEntry // tag if the message succeeds or a BatchResultErrorEntry tag if the message // fails. type SendMessageBatchOutput struct { _ struct{} `type:"structure"` // A list of BatchResultErrorEntry items with error details about each message // that can't be enqueued. // // Failed is a required field Failed []BatchResultErrorEntry `type:"list" flattened:"true" required:"true"` // A list of SendMessageBatchResultEntry items. // // Successful is a required field Successful []SendMessageBatchResultEntry `type:"list" flattened:"true" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageBatchOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageBatchOutput) GoString() string { return s.String() } // SetFailed sets the Failed field's value. func (s SendMessageBatchOutput) SetFailed(v []BatchResultErrorEntry) SendMessageBatchOutput { s.Failed = v return s } // SetSuccessful sets the Successful field's value. func (s SendMessageBatchOutput) SetSuccessful(v []SendMessageBatchResultEntry) SendMessageBatchOutput { s.Successful = v return s } // Contains the details of a single Amazon SQS message along with an Id. type SendMessageBatchRequestEntry struct { _ struct{} `type:"structure"` // The length of time, in seconds, for which a specific message is delayed. // Valid values: 0 to 900. Maximum: 15 minutes. Messages with a positive DelaySeconds // value become available for processing after the delay period is finished. // If you don't specify a value, the default value for the queue is applied. // // When you set FifoQueue, you can't set DelaySeconds per message. You can set // this parameter only on a queue level. DelaySeconds int64 `type:"integer"` // An identifier for a message in this batch used to communicate the result. // // The Ids of a batch request need to be unique within a request. // // This identifier can have up to 80 characters. The following characters are // accepted: alphanumeric characters, hyphens(-), and underscores (_). // // Id is a required field Id string `type:"string" required:"true"` // Each message attribute consists of a Name, Type, and Value. For more information, // see Amazon SQS message attributes (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes) // in the Amazon SQS Developer Guide. MessageAttributes map[string]MessageAttributeValue `type:"map" flattened:"true"` // The body of the message. // // MessageBody is a required field MessageBody string `type:"string" required:"true"` // This parameter applies only to FIFO (first-in-first-out) queues. // // The token used for deduplication of messages within a 5-minute minimum deduplication // interval. If a message with a particular MessageDeduplicationId is sent successfully, // subsequent messages with the same MessageDeduplicationId are accepted successfully // but aren't delivered. For more information, see Exactly-once processing (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues-exactly-once-processing.html) // in the Amazon SQS Developer Guide. // // Every message must have a unique MessageDeduplicationId, You may provide // a MessageDeduplicationId explicitly. If you aren't able to provide a MessageDeduplicationId // and you enable ContentBasedDeduplication for your queue, Amazon SQS uses // a SHA-256 hash to generate the MessageDeduplicationId using the body of // the message (but not the attributes of the message). If you don't provide // a MessageDeduplicationId and the queue doesn't have ContentBasedDeduplication // set, the action fails with an error. If the queue has ContentBasedDeduplication // set, your MessageDeduplicationId overrides the generated one. // // * When ContentBasedDeduplication is in effect, messages with identical // content sent within the deduplication interval are treated as duplicates // and only one copy of the message is delivered. // // * If you send one message with ContentBasedDeduplication enabled and then // another message with a MessageDeduplicationId that is the same as the // one generated for the first MessageDeduplicationId, the two messages are // treated as duplicates and only one copy of the message is delivered. // // The MessageDeduplicationId is available to the consumer of the message (this // can be useful for troubleshooting delivery issues). // // If a message is sent successfully but the acknowledgement is lost and the // message is resent with the same MessageDeduplicationId after the deduplication // interval, Amazon SQS can't detect duplicate messages. // // Amazon SQS continues to keep track of the message deduplication ID even after // the message is received and deleted. // // The length of MessageDeduplicationId is 128 characters. MessageDeduplicationId // can contain alphanumeric characters (a-z, A-Z, 0-9) and punctuation (!"#$%&'()+,-./:;<=>?@[\]^_`{\|}~). // // For best practices of using MessageDeduplicationId, see Using the MessageDeduplicationId // Property (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/using-messagededuplicationid-property.html) // in the Amazon SQS Developer Guide. MessageDeduplicationId string `type:"string"` // This parameter applies only to FIFO (first-in-first-out) queues. // // The tag that specifies that a message belongs to a specific message group. // Messages that belong to the same message group are processed in a FIFO manner // (however, messages in different message groups might be processed out of // order). To interleave multiple ordered streams within a single queue, use // MessageGroupId values (for example, session data for multiple users). In // this scenario, multiple consumers can process the queue, but the session // data of each user is processed in a FIFO fashion. // // * You must associate a non-empty MessageGroupId with a message. If you // don't provide a MessageGroupId, the action fails. // // * ReceiveMessage might return messages with multiple MessageGroupId values. // For each MessageGroupId, the messages are sorted by time sent. The caller // can't specify a MessageGroupId. // // The length of MessageGroupId is 128 characters. Valid values: alphanumeric // characters and punctuation (!"#$%&'()+,-./:;<=>?@[\]^_`{\|}~). // // For best practices of using MessageGroupId, see Using the MessageGroupId // Property (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/using-messagegroupid-property.html) // in the Amazon SQS Developer Guide. // // MessageGroupId is required for FIFO queues. You can't use it for Standard // queues. MessageGroupId string `type:"string"` // The message system attribute to send Each message system attribute consists // of a Name, Type, and Value. // // * Currently, the only supported message system attribute is AWSTraceHeader. // Its type must be String and its value must be a correctly formatted X-Ray // trace header string. // // * The size of a message system attribute doesn't count towards the total // size of a message. MessageSystemAttributes map[string]MessageSystemAttributeValue `type:"map" flattened:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageBatchRequestEntry) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageBatchRequestEntry) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s SendMessageBatchRequestEntry) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SendMessageBatchRequestEntry"} if s.Id == nil { invalidParams.Add(request.NewErrParamRequired("Id")) } if s.MessageBody == nil { invalidParams.Add(request.NewErrParamRequired("MessageBody")) } if s.MessageAttributes != nil { for i, v := range s.MessageAttributes { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "MessageAttributes", i), err.(request.ErrInvalidParams)) } } } if s.MessageSystemAttributes != nil { for i, v := range s.MessageSystemAttributes { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "MessageSystemAttributes", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDelaySeconds sets the DelaySeconds field's value. func (s SendMessageBatchRequestEntry) SetDelaySeconds(v int64) SendMessageBatchRequestEntry { s.DelaySeconds = &v return s } // SetId sets the Id field's value. func (s SendMessageBatchRequestEntry) SetId(v string) SendMessageBatchRequestEntry { s.Id = &v return s } // SetMessageAttributes sets the MessageAttributes field's value. func (s SendMessageBatchRequestEntry) SetMessageAttributes(v map[string]MessageAttributeValue) SendMessageBatchRequestEntry { s.MessageAttributes = v return s } // SetMessageBody sets the MessageBody field's value. func (s SendMessageBatchRequestEntry) SetMessageBody(v string) SendMessageBatchRequestEntry { s.MessageBody = &v return s } // SetMessageDeduplicationId sets the MessageDeduplicationId field's value. func (s SendMessageBatchRequestEntry) SetMessageDeduplicationId(v string) SendMessageBatchRequestEntry { s.MessageDeduplicationId = &v return s } // SetMessageGroupId sets the MessageGroupId field's value. func (s SendMessageBatchRequestEntry) SetMessageGroupId(v string) SendMessageBatchRequestEntry { s.MessageGroupId = &v return s } // SetMessageSystemAttributes sets the MessageSystemAttributes field's value. func (s SendMessageBatchRequestEntry) SetMessageSystemAttributes(v map[string]MessageSystemAttributeValue) SendMessageBatchRequestEntry { s.MessageSystemAttributes = v return s } // Encloses a MessageId for a successfully-enqueued message in a SendMessageBatch. type SendMessageBatchResultEntry struct { _ struct{} `type:"structure"` // An identifier for the message in this batch. // // Id is a required field Id string `type:"string" required:"true"` // An MD5 digest of the non-URL-encoded message attribute string. You can use // this attribute to verify that Amazon SQS received the message correctly. // Amazon SQS URL-decodes the message before creating the MD5 digest. For information // about MD5, see RFC1321 (https://www.ietf.org/rfc/rfc1321.txt). MD5OfMessageAttributes string `type:"string"` // An MD5 digest of the non-URL-encoded message body string. You can use this // attribute to verify that Amazon SQS received the message correctly. Amazon // SQS URL-decodes the message before creating the MD5 digest. For information // about MD5, see RFC1321 (https://www.ietf.org/rfc/rfc1321.txt). // // MD5OfMessageBody is a required field MD5OfMessageBody string `type:"string" required:"true"` // An MD5 digest of the non-URL-encoded message system attribute string. You // can use this attribute to verify that Amazon SQS received the message correctly. // Amazon SQS URL-decodes the message before creating the MD5 digest. For information // about MD5, see RFC1321 (https://www.ietf.org/rfc/rfc1321.txt). MD5OfMessageSystemAttributes string `type:"string"` // An identifier for the message. // // MessageId is a required field MessageId string `type:"string" required:"true"` // This parameter applies only to FIFO (first-in-first-out) queues. // // The large, non-consecutive number that Amazon SQS assigns to each message. // // The length of SequenceNumber is 128 bits. As SequenceNumber continues to // increase for a particular MessageGroupId. SequenceNumber string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageBatchResultEntry) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageBatchResultEntry) GoString() string { return s.String() } // SetId sets the Id field's value. func (s SendMessageBatchResultEntry) SetId(v string) SendMessageBatchResultEntry { s.Id = &v return s } // SetMD5OfMessageAttributes sets the MD5OfMessageAttributes field's value. func (s SendMessageBatchResultEntry) SetMD5OfMessageAttributes(v string) SendMessageBatchResultEntry { s.MD5OfMessageAttributes = &v return s } // SetMD5OfMessageBody sets the MD5OfMessageBody field's value. func (s SendMessageBatchResultEntry) SetMD5OfMessageBody(v string) SendMessageBatchResultEntry { s.MD5OfMessageBody = &v return s } // SetMD5OfMessageSystemAttributes sets the MD5OfMessageSystemAttributes field's value. func (s SendMessageBatchResultEntry) SetMD5OfMessageSystemAttributes(v string) SendMessageBatchResultEntry { s.MD5OfMessageSystemAttributes = &v return s } // SetMessageId sets the MessageId field's value. func (s SendMessageBatchResultEntry) SetMessageId(v string) SendMessageBatchResultEntry { s.MessageId = &v return s } // SetSequenceNumber sets the SequenceNumber field's value. func (s SendMessageBatchResultEntry) SetSequenceNumber(v string) SendMessageBatchResultEntry { s.SequenceNumber = &v return s } type SendMessageInput struct { _ struct{} `type:"structure"` // The length of time, in seconds, for which to delay a specific message. Valid // values: 0 to 900. Maximum: 15 minutes. Messages with a positive DelaySeconds // value become available for processing after the delay period is finished. // If you don't specify a value, the default value for the queue applies. // // When you set FifoQueue, you can't set DelaySeconds per message. You can set // this parameter only on a queue level. DelaySeconds int64 `type:"integer"` // Each message attribute consists of a Name, Type, and Value. For more information, // see Amazon SQS message attributes (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes) // in the Amazon SQS Developer Guide. MessageAttributes map[string]MessageAttributeValue `type:"map" flattened:"true"` // The message to send. The minimum size is one character. The maximum size // is 256 KiB. // // A message can include only XML, JSON, and unformatted text. The following // Unicode characters are allowed. For more information, see the W3C specification // for characters (http://www.w3.org/TR/REC-xml/#charsets). // // #x9 \| #xA \| #xD \| #x20 to #xD7FF \| #xE000 to #xFFFD \| #x10000 to #x10FFFF // // Amazon SQS does not throw an exception or completely reject the message if // it contains invalid characters. Instead, it replaces those invalid characters // with U+FFFD before storing the message in the queue, as long as the message // body contains at least one valid character. // // MessageBody is a required field MessageBody string `type:"string" required:"true"` // This parameter applies only to FIFO (first-in-first-out) queues. // // The token used for deduplication of sent messages. If a message with a particular // MessageDeduplicationId is sent successfully, any messages sent with the same // MessageDeduplicationId are accepted successfully but aren't delivered during // the 5-minute deduplication interval. For more information, see Exactly-once // processing (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues-exactly-once-processing.html) // in the Amazon SQS Developer Guide. // // Every message must have a unique MessageDeduplicationId, You may provide // a MessageDeduplicationId explicitly. If you aren't able to provide a MessageDeduplicationId // and you enable ContentBasedDeduplication for your queue, Amazon SQS uses // a SHA-256 hash to generate the MessageDeduplicationId using the body of // the message (but not the attributes of the message). If you don't provide // a MessageDeduplicationId and the queue doesn't have ContentBasedDeduplication // set, the action fails with an error. If the queue has ContentBasedDeduplication // set, your MessageDeduplicationId overrides the generated one. // // * When ContentBasedDeduplication is in effect, messages with identical // content sent within the deduplication interval are treated as duplicates // and only one copy of the message is delivered. // // * If you send one message with ContentBasedDeduplication enabled and then // another message with a MessageDeduplicationId that is the same as the // one generated for the first MessageDeduplicationId, the two messages are // treated as duplicates and only one copy of the message is delivered. // // The MessageDeduplicationId is available to the consumer of the message (this // can be useful for troubleshooting delivery issues). // // If a message is sent successfully but the acknowledgement is lost and the // message is resent with the same MessageDeduplicationId after the deduplication // interval, Amazon SQS can't detect duplicate messages. // // Amazon SQS continues to keep track of the message deduplication ID even after // the message is received and deleted. // // The maximum length of MessageDeduplicationId is 128 characters. MessageDeduplicationId // can contain alphanumeric characters (a-z, A-Z, 0-9) and punctuation (!"#$%&'()+,-./:;<=>?@[\]^_`{\|}~). // // For best practices of using MessageDeduplicationId, see Using the MessageDeduplicationId // Property (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/using-messagededuplicationid-property.html) // in the Amazon SQS Developer Guide. MessageDeduplicationId string `type:"string"` // This parameter applies only to FIFO (first-in-first-out) queues. // // The tag that specifies that a message belongs to a specific message group. // Messages that belong to the same message group are processed in a FIFO manner // (however, messages in different message groups might be processed out of // order). To interleave multiple ordered streams within a single queue, use // MessageGroupId values (for example, session data for multiple users). In // this scenario, multiple consumers can process the queue, but the session // data of each user is processed in a FIFO fashion. // // * You must associate a non-empty MessageGroupId with a message. If you // don't provide a MessageGroupId, the action fails. // // * ReceiveMessage might return messages with multiple MessageGroupId values. // For each MessageGroupId, the messages are sorted by time sent. The caller // can't specify a MessageGroupId. // // The maximum length of MessageGroupId is 128 characters. Valid values: alphanumeric // characters and punctuation (!"#$%&'()+,-./:;<=>?@[\]^_`{\|}~). // // For best practices of using MessageGroupId, see Using the MessageGroupId // Property (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/using-messagegroupid-property.html) // in the Amazon SQS Developer Guide. // // MessageGroupId is required for FIFO queues. You can't use it for Standard // queues. MessageGroupId string `type:"string"` // The message system attribute to send. Each message system attribute consists // of a Name, Type, and Value. // // * Currently, the only supported message system attribute is AWSTraceHeader. // Its type must be String and its value must be a correctly formatted X-Ray // trace header string. // // * The size of a message system attribute doesn't count towards the total // size of a message. MessageSystemAttributes map[string]MessageSystemAttributeValue `type:"map" flattened:"true"` // The URL of the Amazon SQS queue to which a message is sent. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s SendMessageInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SendMessageInput"} if s.MessageBody == nil { invalidParams.Add(request.NewErrParamRequired("MessageBody")) } if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.MessageAttributes != nil { for i, v := range s.MessageAttributes { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "MessageAttributes", i), err.(request.ErrInvalidParams)) } } } if s.MessageSystemAttributes != nil { for i, v := range s.MessageSystemAttributes { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "MessageSystemAttributes", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDelaySeconds sets the DelaySeconds field's value. func (s SendMessageInput) SetDelaySeconds(v int64) SendMessageInput { s.DelaySeconds = &v return s } // SetMessageAttributes sets the MessageAttributes field's value. func (s SendMessageInput) SetMessageAttributes(v map[string]MessageAttributeValue) SendMessageInput { s.MessageAttributes = v return s } // SetMessageBody sets the MessageBody field's value. func (s SendMessageInput) SetMessageBody(v string) SendMessageInput { s.MessageBody = &v return s } // SetMessageDeduplicationId sets the MessageDeduplicationId field's value. func (s SendMessageInput) SetMessageDeduplicationId(v string) SendMessageInput { s.MessageDeduplicationId = &v return s } // SetMessageGroupId sets the MessageGroupId field's value. func (s SendMessageInput) SetMessageGroupId(v string) SendMessageInput { s.MessageGroupId = &v return s } // SetMessageSystemAttributes sets the MessageSystemAttributes field's value. func (s SendMessageInput) SetMessageSystemAttributes(v map[string]MessageSystemAttributeValue) SendMessageInput { s.MessageSystemAttributes = v return s } // SetQueueUrl sets the QueueUrl field's value. func (s SendMessageInput) SetQueueUrl(v string) SendMessageInput { s.QueueUrl = &v return s } // The MD5OfMessageBody and MessageId elements. type SendMessageOutput struct { _ struct{} `type:"structure"` // An MD5 digest of the non-URL-encoded message attribute string. You can use // this attribute to verify that Amazon SQS received the message correctly. // Amazon SQS URL-decodes the message before creating the MD5 digest. For information // about MD5, see RFC1321 (https://www.ietf.org/rfc/rfc1321.txt). MD5OfMessageAttributes string `type:"string"` // An MD5 digest of the non-URL-encoded message body string. You can use this // attribute to verify that Amazon SQS received the message correctly. Amazon // SQS URL-decodes the message before creating the MD5 digest. For information // about MD5, see RFC1321 (https://www.ietf.org/rfc/rfc1321.txt). MD5OfMessageBody string `type:"string"` // An MD5 digest of the non-URL-encoded message system attribute string. You // can use this attribute to verify that Amazon SQS received the message correctly. // Amazon SQS URL-decodes the message before creating the MD5 digest. MD5OfMessageSystemAttributes string `type:"string"` // An attribute containing the MessageId of the message sent to the queue. For // more information, see Queue and Message Identifiers (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-queue-message-identifiers.html) // in the Amazon SQS Developer Guide. MessageId string `type:"string"` // This parameter applies only to FIFO (first-in-first-out) queues. // // The large, non-consecutive number that Amazon SQS assigns to each message. // // The length of SequenceNumber is 128 bits. SequenceNumber continues to increase // for a particular MessageGroupId. SequenceNumber string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendMessageOutput) GoString() string { return s.String() } // SetMD5OfMessageAttributes sets the MD5OfMessageAttributes field's value. func (s SendMessageOutput) SetMD5OfMessageAttributes(v string) SendMessageOutput { s.MD5OfMessageAttributes = &v return s } // SetMD5OfMessageBody sets the MD5OfMessageBody field's value. func (s SendMessageOutput) SetMD5OfMessageBody(v string) SendMessageOutput { s.MD5OfMessageBody = &v return s } // SetMD5OfMessageSystemAttributes sets the MD5OfMessageSystemAttributes field's value. func (s SendMessageOutput) SetMD5OfMessageSystemAttributes(v string) SendMessageOutput { s.MD5OfMessageSystemAttributes = &v return s } // SetMessageId sets the MessageId field's value. func (s SendMessageOutput) SetMessageId(v string) SendMessageOutput { s.MessageId = &v return s } // SetSequenceNumber sets the SequenceNumber field's value. func (s SendMessageOutput) SetSequenceNumber(v string) SendMessageOutput { s.SequenceNumber = &v return s } type SetQueueAttributesInput struct { _ struct{} `type:"structure"` // A map of attributes to set. // // The following lists the names, descriptions, and values of the special request // parameters that the SetQueueAttributes action uses: // // * DelaySeconds – The length of time, in seconds, for which the delivery // of all messages in the queue is delayed. Valid values: An integer from // 0 to 900 (15 minutes). Default: 0. // // * MaximumMessageSize – The limit of how many bytes a message can contain // before Amazon SQS rejects it. Valid values: An integer from 1,024 bytes // (1 KiB) up to 262,144 bytes (256 KiB). Default: 262,144 (256 KiB). // // * MessageRetentionPeriod – The length of time, in seconds, for which // Amazon SQS retains a message. Valid values: An integer representing seconds, // from 60 (1 minute) to 1,209,600 (14 days). Default: 345,600 (4 days). // When you change a queue's attributes, the change can take up to 60 seconds // for most of the attributes to propagate throughout the Amazon SQS system. // Changes made to the MessageRetentionPeriod attribute can take up to 15 // minutes and will impact existing messages in the queue potentially causing // them to be expired and deleted if the MessageRetentionPeriod is reduced // below the age of existing messages. // // * Policy – The queue's policy. A valid Amazon Web Services policy. For // more information about policy structure, see Overview of Amazon Web Services // IAM Policies (https://docs.aws.amazon.com/IAM/latest/UserGuide/PoliciesOverview.html) // in the Identity and Access Management User Guide. // // * ReceiveMessageWaitTimeSeconds – The length of time, in seconds, for // which a ReceiveMessage action waits for a message to arrive. Valid values: // An integer from 0 to 20 (seconds). Default: 0. // // * VisibilityTimeout – The visibility timeout for the queue, in seconds. // Valid values: An integer from 0 to 43,200 (12 hours). Default: 30. For // more information about the visibility timeout, see Visibility Timeout // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-visibility-timeout.html) // in the Amazon SQS Developer Guide. // // The following attributes apply only to dead-letter queues: (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html) // // * RedrivePolicy – The string that includes the parameters for the dead-letter // queue functionality of the source queue as a JSON object. The parameters // are as follows: deadLetterTargetArn – The Amazon Resource Name (ARN) // of the dead-letter queue to which Amazon SQS moves messages after the // value of maxReceiveCount is exceeded. maxReceiveCount – The number of // times a message is delivered to the source queue before being moved to // the dead-letter queue. Default: 10. When the ReceiveCount for a message // exceeds the maxReceiveCount for a queue, Amazon SQS moves the message // to the dead-letter-queue. // // * RedriveAllowPolicy – The string that includes the parameters for the // permissions for the dead-letter queue redrive permission and which source // queues can specify dead-letter queues as a JSON object. The parameters // are as follows: redrivePermission – The permission type that defines // which source queues can specify the current queue as the dead-letter queue. // Valid values are: allowAll – (Default) Any source queues in this Amazon // Web Services account in the same Region can specify this queue as the // dead-letter queue. denyAll – No source queues can specify this queue // as the dead-letter queue. byQueue – Only queues specified by the sourceQueueArns // parameter can specify this queue as the dead-letter queue. sourceQueueArns // – The Amazon Resource Names (ARN)s of the source queues that can specify // this queue as the dead-letter queue and redrive messages. You can specify // this parameter only when the redrivePermission parameter is set to byQueue. // You can specify up to 10 source queue ARNs. To allow more than 10 source // queues to specify dead-letter queues, set the redrivePermission parameter // to allowAll. // // The dead-letter queue of a FIFO queue must also be a FIFO queue. Similarly, // the dead-letter queue of a standard queue must also be a standard queue. // // The following attributes apply only to server-side-encryption (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html): // // * KmsMasterKeyId – The ID of an Amazon Web Services managed customer // master key (CMK) for Amazon SQS or a custom CMK. For more information, // see Key Terms (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html#sqs-sse-key-terms). // While the alias of the AWS-managed CMK for Amazon SQS is always alias/aws/sqs, // the alias of a custom CMK can, for example, be alias/MyAlias . For more // examples, see KeyId (https://docs.aws.amazon.com/kms/latest/APIReference/API_DescribeKey.html#API_DescribeKey_RequestParameters) // in the Key Management Service API Reference. // // * KmsDataKeyReusePeriodSeconds – The length of time, in seconds, for // which Amazon SQS can reuse a data key (https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html#data-keys) // to encrypt or decrypt messages before calling KMS again. An integer representing // seconds, between 60 seconds (1 minute) and 86,400 seconds (24 hours). // Default: 300 (5 minutes). A shorter time period provides better security // but results in more calls to KMS which might incur charges after Free // Tier. For more information, see How Does the Data Key Reuse Period Work? // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-server-side-encryption.html#sqs-how-does-the-data-key-reuse-period-work). // // * SqsManagedSseEnabled – Enables server-side queue encryption using // SQS owned encryption keys. Only one server-side encryption option is supported // per queue (for example, SSE-KMS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sse-existing-queue.html) // or SSE-SQS (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-sqs-sse-queue.html)). // // The following attribute applies only to FIFO (first-in-first-out) queues // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues.html): // // * ContentBasedDeduplication – Enables content-based deduplication. For // more information, see Exactly-once processing (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/FIFO-queues-exactly-once-processing.html) // in the Amazon SQS Developer Guide. Note the following: Every message must // have a unique MessageDeduplicationId. You may provide a MessageDeduplicationId // explicitly. If you aren't able to provide a MessageDeduplicationId and // you enable ContentBasedDeduplication for your queue, Amazon SQS uses a // SHA-256 hash to generate the MessageDeduplicationId using the body of // the message (but not the attributes of the message). If you don't provide // a MessageDeduplicationId and the queue doesn't have ContentBasedDeduplication // set, the action fails with an error. If the queue has ContentBasedDeduplication // set, your MessageDeduplicationId overrides the generated one. When ContentBasedDeduplication // is in effect, messages with identical content sent within the deduplication // interval are treated as duplicates and only one copy of the message is // delivered. If you send one message with ContentBasedDeduplication enabled // and then another message with a MessageDeduplicationId that is the same // as the one generated for the first MessageDeduplicationId, the two messages // are treated as duplicates and only one copy of the message is delivered. // // The following attributes apply only to high throughput for FIFO queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/high-throughput-fifo.html): // // * DeduplicationScope – Specifies whether message deduplication occurs // at the message group or queue level. Valid values are messageGroup and // queue. // // * FifoThroughputLimit – Specifies whether the FIFO queue throughput // quota applies to the entire queue or per message group. Valid values are // perQueue and perMessageGroupId. The perMessageGroupId value is allowed // only when the value for DeduplicationScope is messageGroup. // // To enable high throughput for FIFO queues, do the following: // // * Set DeduplicationScope to messageGroup. // // * Set FifoThroughputLimit to perMessageGroupId. // // If you set these attributes to anything other than the values shown for enabling // high throughput, normal throughput is in effect and deduplication occurs // as specified. // // For information on throughput quotas, see Quotas related to messages (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/quotas-messages.html) // in the Amazon SQS Developer Guide. // // Attributes is a required field Attributes map[string]string `type:"map" flattened:"true" required:"true"` // The URL of the Amazon SQS queue whose attributes are set. // // Queue URLs and names are case-sensitive. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SetQueueAttributesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SetQueueAttributesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s SetQueueAttributesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SetQueueAttributesInput"} if s.Attributes == nil { invalidParams.Add(request.NewErrParamRequired("Attributes")) } if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetAttributes sets the Attributes field's value. func (s SetQueueAttributesInput) SetAttributes(v map[string]string) SetQueueAttributesInput { s.Attributes = v return s } // SetQueueUrl sets the QueueUrl field's value. func (s SetQueueAttributesInput) SetQueueUrl(v string) SetQueueAttributesInput { s.QueueUrl = &v return s } type SetQueueAttributesOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SetQueueAttributesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SetQueueAttributesOutput) GoString() string { return s.String() } type StartMessageMoveTaskInput struct { _ struct{} `type:"structure"` // The ARN of the queue that receives the moved messages. You can use this field // to specify the destination queue where you would like to redrive messages. // If this field is left blank, the messages will be redriven back to their // respective original source queues. DestinationArn string `type:"string"` // The number of messages to be moved per second (the message movement rate). // You can use this field to define a fixed message movement rate. The maximum // value for messages per second is 500. If this field is left blank, the system // will optimize the rate based on the queue message backlog size, which may // vary throughout the duration of the message movement task. MaxNumberOfMessagesPerSecond int64 `type:"integer"` // The ARN of the queue that contains the messages to be moved to another queue. // Currently, only ARNs of dead-letter queues (DLQs) whose sources are other // Amazon SQS queues are accepted. DLQs whose sources are non-SQS queues, such // as Lambda or Amazon SNS topics, are not currently supported. // // SourceArn is a required field SourceArn string `type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartMessageMoveTaskInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartMessageMoveTaskInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s StartMessageMoveTaskInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "StartMessageMoveTaskInput"} if s.SourceArn == nil { invalidParams.Add(request.NewErrParamRequired("SourceArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDestinationArn sets the DestinationArn field's value. func (s StartMessageMoveTaskInput) SetDestinationArn(v string) StartMessageMoveTaskInput { s.DestinationArn = &v return s } // SetMaxNumberOfMessagesPerSecond sets the MaxNumberOfMessagesPerSecond field's value. func (s StartMessageMoveTaskInput) SetMaxNumberOfMessagesPerSecond(v int64) StartMessageMoveTaskInput { s.MaxNumberOfMessagesPerSecond = &v return s } // SetSourceArn sets the SourceArn field's value. func (s StartMessageMoveTaskInput) SetSourceArn(v string) StartMessageMoveTaskInput { s.SourceArn = &v return s } type StartMessageMoveTaskOutput struct { _ struct{} `type:"structure"` // An identifier associated with a message movement task. You can use this identifier // to cancel a specified message movement task using the CancelMessageMoveTask // action. TaskHandle string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartMessageMoveTaskOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartMessageMoveTaskOutput) GoString() string { return s.String() } // SetTaskHandle sets the TaskHandle field's value. func (s StartMessageMoveTaskOutput) SetTaskHandle(v string) StartMessageMoveTaskOutput { s.TaskHandle = &v return s } type TagQueueInput struct { _ struct{} `type:"structure"` // The URL of the queue. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` // The list of tags to be added to the specified queue. // // Tags is a required field Tags map[string]string `type:"map" flattened:"true" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TagQueueInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TagQueueInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s TagQueueInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "TagQueueInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.Tags == nil { invalidParams.Add(request.NewErrParamRequired("Tags")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetQueueUrl sets the QueueUrl field's value. func (s TagQueueInput) SetQueueUrl(v string) TagQueueInput { s.QueueUrl = &v return s } // SetTags sets the Tags field's value. func (s TagQueueInput) SetTags(v map[string]string) TagQueueInput { s.Tags = v return s } type TagQueueOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TagQueueOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TagQueueOutput) GoString() string { return s.String() } // The batch request contains more entries than permissible. type TooManyEntriesInBatchRequest struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TooManyEntriesInBatchRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TooManyEntriesInBatchRequest) GoString() string { return s.String() } func newErrorTooManyEntriesInBatchRequest(v protocol.ResponseMetadata) error { return &TooManyEntriesInBatchRequest{ RespMetadata: v, } } func newQueryCompatibleErrorTooManyEntriesInBatchRequest(v protocol.ResponseMetadata, code string) error { return &TooManyEntriesInBatchRequest{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s TooManyEntriesInBatchRequest) Code() string { if s.Code_ != nil { return s.Code_ } return "TooManyEntriesInBatchRequest" } // Message returns the exception's message. func (s TooManyEntriesInBatchRequest) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s TooManyEntriesInBatchRequest) OrigErr() error { return nil } func (s TooManyEntriesInBatchRequest) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s TooManyEntriesInBatchRequest) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s TooManyEntriesInBatchRequest) RequestID() string { return s.RespMetadata.RequestID } // Error code 400. Unsupported operation. type UnsupportedOperation struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ string Message_ string `locationName:"message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UnsupportedOperation) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UnsupportedOperation) GoString() string { return s.String() } func newErrorUnsupportedOperation(v protocol.ResponseMetadata) error { return &UnsupportedOperation{ RespMetadata: v, } } func newQueryCompatibleErrorUnsupportedOperation(v protocol.ResponseMetadata, code string) error { return &UnsupportedOperation{ RespMetadata: v, Code_: &code, } } // Code returns the exception type name. func (s UnsupportedOperation) Code() string { if s.Code_ != nil { return s.Code_ } return "UnsupportedOperation" } // Message returns the exception's message. func (s UnsupportedOperation) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s UnsupportedOperation) OrigErr() error { return nil } func (s UnsupportedOperation) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s UnsupportedOperation) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s UnsupportedOperation) RequestID() string { return s.RespMetadata.RequestID } type UntagQueueInput struct { _ struct{} `type:"structure"` // The URL of the queue. // // QueueUrl is a required field QueueUrl string `type:"string" required:"true"` // The list of tags to be removed from the specified queue. // // TagKeys is a required field TagKeys []string `type:"list" flattened:"true" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UntagQueueInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UntagQueueInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s UntagQueueInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "UntagQueueInput"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.TagKeys == nil { invalidParams.Add(request.NewErrParamRequired("TagKeys")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetQueueUrl sets the QueueUrl field's value. func (s UntagQueueInput) SetQueueUrl(v string) UntagQueueInput { s.QueueUrl = &v return s } // SetTagKeys sets the TagKeys field's value. func (s UntagQueueInput) SetTagKeys(v []string) *UntagQueueInput { s.TagKeys = v return s } type UntagQueueOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UntagQueueOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UntagQueueOutput) GoString() string { return s.String() } const ( // MessageSystemAttributeNameAll is a MessageSystemAttributeName enum value MessageSystemAttributeNameAll = "All" // MessageSystemAttributeNameSenderId is a MessageSystemAttributeName enum value MessageSystemAttributeNameSenderId = "SenderId" // MessageSystemAttributeNameSentTimestamp is a MessageSystemAttributeName enum value MessageSystemAttributeNameSentTimestamp = "SentTimestamp" // MessageSystemAttributeNameApproximateReceiveCount is a MessageSystemAttributeName enum value MessageSystemAttributeNameApproximateReceiveCount = "ApproximateReceiveCount" // MessageSystemAttributeNameApproximateFirstReceiveTimestamp is a MessageSystemAttributeName enum value MessageSystemAttributeNameApproximateFirstReceiveTimestamp = "ApproximateFirstReceiveTimestamp" // MessageSystemAttributeNameSequenceNumber is a MessageSystemAttributeName enum value MessageSystemAttributeNameSequenceNumber = "SequenceNumber" // MessageSystemAttributeNameMessageDeduplicationId is a MessageSystemAttributeName enum value MessageSystemAttributeNameMessageDeduplicationId = "MessageDeduplicationId" // MessageSystemAttributeNameMessageGroupId is a MessageSystemAttributeName enum value MessageSystemAttributeNameMessageGroupId = "MessageGroupId" // MessageSystemAttributeNameAwstraceHeader is a MessageSystemAttributeName enum value MessageSystemAttributeNameAwstraceHeader = "AWSTraceHeader" // MessageSystemAttributeNameDeadLetterQueueSourceArn is a MessageSystemAttributeName enum value MessageSystemAttributeNameDeadLetterQueueSourceArn = "DeadLetterQueueSourceArn" ) // MessageSystemAttributeName_Values returns all elements of the MessageSystemAttributeName enum func MessageSystemAttributeName_Values() []string { return []string{ MessageSystemAttributeNameAll, MessageSystemAttributeNameSenderId, MessageSystemAttributeNameSentTimestamp, MessageSystemAttributeNameApproximateReceiveCount, MessageSystemAttributeNameApproximateFirstReceiveTimestamp, MessageSystemAttributeNameSequenceNumber, MessageSystemAttributeNameMessageDeduplicationId, MessageSystemAttributeNameMessageGroupId, MessageSystemAttributeNameAwstraceHeader, MessageSystemAttributeNameDeadLetterQueueSourceArn, } } const ( // MessageSystemAttributeNameForSendsAwstraceHeader is a MessageSystemAttributeNameForSends enum value MessageSystemAttributeNameForSendsAwstraceHeader = "AWSTraceHeader" ) // MessageSystemAttributeNameForSends_Values returns all elements of the MessageSystemAttributeNameForSends enum func MessageSystemAttributeNameForSends_Values() []string { return []string{ MessageSystemAttributeNameForSendsAwstraceHeader, } } const ( // QueueAttributeNameAll is a QueueAttributeName enum value QueueAttributeNameAll = "All" // QueueAttributeNamePolicy is a QueueAttributeName enum value QueueAttributeNamePolicy = "Policy" // QueueAttributeNameVisibilityTimeout is a QueueAttributeName enum value QueueAttributeNameVisibilityTimeout = "VisibilityTimeout" // QueueAttributeNameMaximumMessageSize is a QueueAttributeName enum value QueueAttributeNameMaximumMessageSize = "MaximumMessageSize" // QueueAttributeNameMessageRetentionPeriod is a QueueAttributeName enum value QueueAttributeNameMessageRetentionPeriod = "MessageRetentionPeriod" // QueueAttributeNameApproximateNumberOfMessages is a QueueAttributeName enum value QueueAttributeNameApproximateNumberOfMessages = "ApproximateNumberOfMessages" // QueueAttributeNameApproximateNumberOfMessagesNotVisible is a QueueAttributeName enum value QueueAttributeNameApproximateNumberOfMessagesNotVisible = "ApproximateNumberOfMessagesNotVisible" // QueueAttributeNameCreatedTimestamp is a QueueAttributeName enum value QueueAttributeNameCreatedTimestamp = "CreatedTimestamp" // QueueAttributeNameLastModifiedTimestamp is a QueueAttributeName enum value QueueAttributeNameLastModifiedTimestamp = "LastModifiedTimestamp" // QueueAttributeNameQueueArn is a QueueAttributeName enum value QueueAttributeNameQueueArn = "QueueArn" // QueueAttributeNameApproximateNumberOfMessagesDelayed is a QueueAttributeName enum value QueueAttributeNameApproximateNumberOfMessagesDelayed = "ApproximateNumberOfMessagesDelayed" // QueueAttributeNameDelaySeconds is a QueueAttributeName enum value QueueAttributeNameDelaySeconds = "DelaySeconds" // QueueAttributeNameReceiveMessageWaitTimeSeconds is a QueueAttributeName enum value QueueAttributeNameReceiveMessageWaitTimeSeconds = "ReceiveMessageWaitTimeSeconds" // QueueAttributeNameRedrivePolicy is a QueueAttributeName enum value QueueAttributeNameRedrivePolicy = "RedrivePolicy" // QueueAttributeNameFifoQueue is a QueueAttributeName enum value QueueAttributeNameFifoQueue = "FifoQueue" // QueueAttributeNameContentBasedDeduplication is a QueueAttributeName enum value QueueAttributeNameContentBasedDeduplication = "ContentBasedDeduplication" // QueueAttributeNameKmsMasterKeyId is a QueueAttributeName enum value QueueAttributeNameKmsMasterKeyId = "KmsMasterKeyId" // QueueAttributeNameKmsDataKeyReusePeriodSeconds is a QueueAttributeName enum value QueueAttributeNameKmsDataKeyReusePeriodSeconds = "KmsDataKeyReusePeriodSeconds" // QueueAttributeNameDeduplicationScope is a QueueAttributeName enum value QueueAttributeNameDeduplicationScope = "DeduplicationScope" // QueueAttributeNameFifoThroughputLimit is a QueueAttributeName enum value QueueAttributeNameFifoThroughputLimit = "FifoThroughputLimit" // QueueAttributeNameRedriveAllowPolicy is a QueueAttributeName enum value QueueAttributeNameRedriveAllowPolicy = "RedriveAllowPolicy" // QueueAttributeNameSqsManagedSseEnabled is a QueueAttributeName enum value QueueAttributeNameSqsManagedSseEnabled = "SqsManagedSseEnabled" ) // QueueAttributeName_Values returns all elements of the QueueAttributeName enum func QueueAttributeName_Values() []string { return []string{ QueueAttributeNameAll, QueueAttributeNamePolicy, QueueAttributeNameVisibilityTimeout, QueueAttributeNameMaximumMessageSize, QueueAttributeNameMessageRetentionPeriod, QueueAttributeNameApproximateNumberOfMessages, QueueAttributeNameApproximateNumberOfMessagesNotVisible, QueueAttributeNameCreatedTimestamp, QueueAttributeNameLastModifiedTimestamp, QueueAttributeNameQueueArn, QueueAttributeNameApproximateNumberOfMessagesDelayed, QueueAttributeNameDelaySeconds, QueueAttributeNameReceiveMessageWaitTimeSeconds, QueueAttributeNameRedrivePolicy, QueueAttributeNameFifoQueue, QueueAttributeNameContentBasedDeduplication, QueueAttributeNameKmsMasterKeyId, QueueAttributeNameKmsDataKeyReusePeriodSeconds, QueueAttributeNameDeduplicationScope, QueueAttributeNameFifoThroughputLimit, QueueAttributeNameRedriveAllowPolicy, QueueAttributeNameSqsManagedSseEnabled, } }	341.58 KB	2025-05-25 12:27
📄 checksums.go package sqs import ( "crypto/md5" "encoding/hex" "fmt" "strings" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/awserr" "github.com/aws/aws-sdk-go/aws/request" ) var ( errChecksumMissingBody = fmt.Errorf("cannot compute checksum. missing body") errChecksumMissingMD5 = fmt.Errorf("cannot verify checksum. missing response MD5") ) func setupChecksumValidation(r request.Request) { if aws.BoolValue(r.Config.DisableComputeChecksums) { return } switch r.Operation.Name { case opSendMessage: r.Handlers.Unmarshal.PushBack(verifySendMessage) case opSendMessageBatch: r.Handlers.Unmarshal.PushBack(verifySendMessageBatch) case opReceiveMessage: r.Handlers.Unmarshal.PushBack(verifyReceiveMessage) } } func verifySendMessage(r request.Request) { if r.DataFilled() && r.ParamsFilled() { in := r.Params.(SendMessageInput) out := r.Data.(SendMessageOutput) err := checksumsMatch(in.MessageBody, out.MD5OfMessageBody) if err != nil { setChecksumError(r, err.Error()) } } } func verifySendMessageBatch(r request.Request) { if r.DataFilled() && r.ParamsFilled() { entries := map[string]SendMessageBatchResultEntry{} ids := []string{} out := r.Data.(SendMessageBatchOutput) for _, entry := range out.Successful { entries[entry.Id] = entry } in := r.Params.(SendMessageBatchInput) for _, entry := range in.Entries { if e, ok := entries[entry.Id]; ok { if err := checksumsMatch(entry.MessageBody, e.MD5OfMessageBody); err != nil { ids = append(ids, e.MessageId) } } } if len(ids) > 0 { setChecksumError(r, "invalid messages: %s", strings.Join(ids, ", ")) } } } func verifyReceiveMessage(r request.Request) { if r.DataFilled() && r.ParamsFilled() { ids := []string{} out := r.Data.(ReceiveMessageOutput) for i, msg := range out.Messages { err := checksumsMatch(msg.Body, msg.MD5OfBody) if err != nil { if msg.MessageId == nil { if r.Config.Logger != nil { r.Config.Logger.Log(fmt.Sprintf( "WARN: SQS.ReceiveMessage failed checksum request id: %s, message %d has no message ID.", r.RequestID, i, )) } continue } ids = append(ids, msg.MessageId) } } if len(ids) > 0 { setChecksumError(r, "invalid messages: %s", strings.Join(ids, ", ")) } } } func checksumsMatch(body, expectedMD5 string) error { if body == nil { return errChecksumMissingBody } else if expectedMD5 == nil { return errChecksumMissingMD5 } msum := md5.Sum([]byte(body)) sum := hex.EncodeToString(msum[:]) if sum != expectedMD5 { return fmt.Errorf("expected MD5 checksum '%s', got '%s'", expectedMD5, sum) } return nil } func setChecksumError(r *request.Request, format string, args ...interface{}) { r.Retryable = aws.Bool(true) r.Error = awserr.New("InvalidChecksum", fmt.Sprintf(format, args...), nil) }	2.82 KB	2025-05-25 12:27
📄 checksums_test.go package sqs_test import ( "bytes" "io/ioutil" "net/http" "strings" "testing" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/awserr" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/awstesting/unit" "github.com/aws/aws-sdk-go/service/sqs" ) var svc = func() sqs.SQS { s := sqs.New(unit.Session, &aws.Config{ DisableParamValidation: aws.Bool(true), }) s.Handlers.Send.Clear() return s }() func TestSendMessageChecksum(t testing.T) { req, _ := svc.SendMessageRequest(&sqs.SendMessageInput{ MessageBody: aws.String("test"), }) req.Handlers.Send.PushBack(func(r request.Request) { body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.SendMessageOutput{ MD5OfMessageBody: aws.String("098f6bcd4621d373cade4e832627b4f6"), MessageId: aws.String("12345"), } }) err := req.Send() if err != nil { t.Errorf("expect no error, got %v", err) } } func TestSendMessageChecksumInvalid(t testing.T) { req, _ := svc.SendMessageRequest(&sqs.SendMessageInput{ MessageBody: aws.String("test"), }) req.Handlers.Send.PushBack(func(r request.Request) { body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.SendMessageOutput{ MD5OfMessageBody: aws.String("000"), MessageId: aws.String("12345"), } }) err := req.Send() if err == nil { t.Fatalf("expect error, got nil") } if e, a := "InvalidChecksum", err.(awserr.Error).Code(); e != a { t.Errorf("expect %v, got %v", e, a) } if e, a := err.(awserr.Error).Message(), "expected MD5 checksum '000', got '098f6bcd4621d373cade4e832627b4f6'"; !strings.Contains(a, e) { t.Errorf("expect %v to be in %v, was not", e, a) } } func TestSendMessageChecksumInvalidNoValidation(t testing.T) { s := sqs.New(unit.Session, &aws.Config{ DisableParamValidation: aws.Bool(true), DisableComputeChecksums: aws.Bool(true), }) s.Handlers.Send.Clear() req, _ := s.SendMessageRequest(&sqs.SendMessageInput{ MessageBody: aws.String("test"), }) req.Handlers.Send.PushBack(func(r request.Request) { body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.SendMessageOutput{ MD5OfMessageBody: aws.String("000"), MessageId: aws.String("12345"), } }) err := req.Send() if err != nil { t.Errorf("expect no error, got %v", err) } } func TestSendMessageChecksumNoInput(t testing.T) { req, _ := svc.SendMessageRequest(&sqs.SendMessageInput{}) req.Handlers.Send.PushBack(func(r request.Request) { body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.SendMessageOutput{} }) err := req.Send() if err == nil { t.Fatalf("expect error, got nil") } if e, a := "InvalidChecksum", err.(awserr.Error).Code(); e != a { t.Errorf("expect %v, got %v", e, a) } if e, a := err.(awserr.Error).Message(), "cannot compute checksum. missing body"; !strings.Contains(a, e) { t.Errorf("expect %v to be in %v, was not", e, a) } } func TestSendMessageChecksumNoOutput(t testing.T) { req, _ := svc.SendMessageRequest(&sqs.SendMessageInput{ MessageBody: aws.String("test"), }) req.Handlers.Send.PushBack(func(r request.Request) { body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.SendMessageOutput{} }) err := req.Send() if err == nil { t.Fatalf("expect error, got nil") } if e, a := "InvalidChecksum", err.(awserr.Error).Code(); e != a { t.Errorf("expect %v, got %v", e, a) } if e, a := err.(awserr.Error).Message(), "cannot verify checksum. missing response MD5"; !strings.Contains(a, e) { t.Errorf("expect %v to be in %v, was not", e, a) } } func TestRecieveMessageChecksum(t testing.T) { req, _ := svc.ReceiveMessageRequest(&sqs.ReceiveMessageInput{}) req.Handlers.Send.PushBack(func(r request.Request) { md5 := "098f6bcd4621d373cade4e832627b4f6" body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.ReceiveMessageOutput{ Messages: []sqs.Message{ {Body: aws.String("test"), MD5OfBody: &md5}, {Body: aws.String("test"), MD5OfBody: &md5}, {Body: aws.String("test"), MD5OfBody: &md5}, {Body: aws.String("test"), MD5OfBody: &md5}, }, } }) err := req.Send() if err != nil { t.Errorf("expect no error, got %v", err) } } func TestRecieveMessageChecksumInvalid(t testing.T) { req, _ := svc.ReceiveMessageRequest(&sqs.ReceiveMessageInput{}) req.Handlers.Send.PushBack(func(r request.Request) { md5 := "098f6bcd4621d373cade4e832627b4f6" body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.ReceiveMessageOutput{ Messages: []sqs.Message{ {Body: aws.String("test"), MD5OfBody: &md5}, {Body: aws.String("test"), MD5OfBody: aws.String("000"), MessageId: aws.String("123")}, {Body: aws.String("test"), MD5OfBody: aws.String("000"), MessageId: aws.String("456")}, {Body: aws.String("test"), MD5OfBody: aws.String("000")}, {Body: aws.String("test"), MD5OfBody: &md5}, }, } }) err := req.Send() if err == nil { t.Fatalf("expect error, got nil") } if e, a := "InvalidChecksum", err.(awserr.Error).Code(); e != a { t.Errorf("expect %v, got %v", e, a) } if e, a := err.(awserr.Error).Message(), "invalid messages: 123, 456"; !strings.Contains(a, e) { t.Errorf("expect %v to be in %v, was not", e, a) } } func TestSendMessageBatchChecksum(t testing.T) { req, _ := svc.SendMessageBatchRequest(&sqs.SendMessageBatchInput{ Entries: []sqs.SendMessageBatchRequestEntry{ {Id: aws.String("1"), MessageBody: aws.String("test")}, {Id: aws.String("2"), MessageBody: aws.String("test")}, {Id: aws.String("3"), MessageBody: aws.String("test")}, {Id: aws.String("4"), MessageBody: aws.String("test")}, }, }) req.Handlers.Send.PushBack(func(r request.Request) { md5 := "098f6bcd4621d373cade4e832627b4f6" body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.SendMessageBatchOutput{ Successful: []sqs.SendMessageBatchResultEntry{ {MD5OfMessageBody: &md5, MessageId: aws.String("123"), Id: aws.String("1")}, {MD5OfMessageBody: &md5, MessageId: aws.String("456"), Id: aws.String("2")}, {MD5OfMessageBody: &md5, MessageId: aws.String("789"), Id: aws.String("3")}, {MD5OfMessageBody: &md5, MessageId: aws.String("012"), Id: aws.String("4")}, }, } }) err := req.Send() if err != nil { t.Errorf("expect no error, got %v", err) } } func TestSendMessageBatchChecksumFailed(t testing.T) { req, _ := svc.SendMessageBatchRequest(&sqs.SendMessageBatchInput{ Entries: []sqs.SendMessageBatchRequestEntry{ {Id: aws.String("1"), MessageBody: aws.String("test")}, {Id: aws.String("2"), MessageBody: aws.String("test")}, {Id: aws.String("3"), MessageBody: aws.String("test")}, {Id: aws.String("4"), MessageBody: aws.String("test")}, }, }) req.Handlers.Send.PushBack(func(r request.Request) { body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.SendMessageBatchOutput{ Failed: []sqs.BatchResultErrorEntry{ { Id: aws.String("1"), Code: aws.String("test"), Message: aws.String("test"), SenderFault: aws.Bool(false), }, { Id: aws.String("2"), Code: aws.String("test"), Message: aws.String("test"), SenderFault: aws.Bool(false), }, { Id: aws.String("3"), Code: aws.String("test"), Message: aws.String("test"), SenderFault: aws.Bool(false), }, { Id: aws.String("4"), Code: aws.String("test"), Message: aws.String("test"), SenderFault: aws.Bool(false), }, }, } }) if err := req.Send(); err != nil { t.Errorf("expect no error, got %v", err) } } func TestSendMessageBatchChecksumInvalid(t testing.T) { req, _ := svc.SendMessageBatchRequest(&sqs.SendMessageBatchInput{ Entries: []sqs.SendMessageBatchRequestEntry{ {Id: aws.String("1"), MessageBody: aws.String("test")}, {Id: aws.String("2"), MessageBody: aws.String("test")}, {Id: aws.String("3"), MessageBody: aws.String("test")}, {Id: aws.String("4"), MessageBody: aws.String("test")}, }, }) req.Handlers.Send.PushBack(func(r request.Request) { md5 := "098f6bcd4621d373cade4e832627b4f6" body := ioutil.NopCloser(bytes.NewReader([]byte(""))) r.HTTPResponse = &http.Response{StatusCode: 200, Body: body} r.Data = &sqs.SendMessageBatchOutput{ Successful: []*sqs.SendMessageBatchResultEntry{ {MD5OfMessageBody: &md5, MessageId: aws.String("123"), Id: aws.String("1")}, {MD5OfMessageBody: aws.String("000"), MessageId: aws.String("456"), Id: aws.String("2")}, {MD5OfMessageBody: aws.String("000"), MessageId: aws.String("789"), Id: aws.String("3")}, {MD5OfMessageBody: &md5, MessageId: aws.String("012"), Id: aws.String("4")}, }, } }) err := req.Send() if err == nil { t.Fatalf("expect error, got nil") } if e, a := "InvalidChecksum", err.(awserr.Error).Code(); e != a { t.Errorf("expect %v, got %v", e, a) } if e, a := err.(awserr.Error).Message(), "invalid messages: 456, 789"; !strings.Contains(a, e) { t.Errorf("expect %v to be in %v, was not", e, a) } }	9.46 KB	2025-05-25 12:27
📄 customizations.go package sqs import "github.com/aws/aws-sdk-go/aws/request" func init() { initRequest = func(r *request.Request) { setupChecksumValidation(r) } }	151 B	2025-05-25 12:27
📄 doc.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. // Package sqs provides the client and types for making API // requests to Amazon Simple Queue Service. // // Welcome to the Amazon SQS API Reference. // // Amazon SQS is a reliable, highly-scalable hosted queue for storing messages // as they travel between applications or microservices. Amazon SQS moves data // between distributed application components and helps you decouple these components. // // For information on the permissions you need to use this API, see Identity // and access management (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-authentication-and-access-control.html) // in the Amazon SQS Developer Guide. // // You can use Amazon Web Services SDKs (http://aws.amazon.com/tools/#sdk) to // access Amazon SQS using your favorite programming language. The SDKs perform // tasks such as the following automatically: // // - Cryptographically sign your service requests // // - Retry requests // // - Handle error responses // // Additional information // // - Amazon SQS Product Page (http://aws.amazon.com/sqs/) // // - Amazon SQS Developer Guide Making API Requests (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-making-api-requests.html) // Amazon SQS Message Attributes (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes) // Amazon SQS Dead-Letter Queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html) // // - Amazon SQS in the Command Line Interface (http://docs.aws.amazon.com/cli/latest/reference/sqs/index.html) // // - Amazon Web Services General Reference Regions and Endpoints (https://docs.aws.amazon.com/general/latest/gr/rande.html#sqs_region) // // See https://docs.aws.amazon.com/goto/WebAPI/sqs-2012-11-05 for more information on this service. // // See sqs package documentation for more information. // https://docs.aws.amazon.com/sdk-for-go/api/service/sqs/ // // # Using the Client // // To contact Amazon Simple Queue Service with the SDK use the New function to create // a new service client. With that client you can make API requests to the service. // These clients are safe to use concurrently. // // See the SDK's documentation for more information on how to use the SDK. // https://docs.aws.amazon.com/sdk-for-go/api/ // // See aws.Config documentation for more information on configuring SDK clients. // https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config // // See the Amazon Simple Queue Service client SQS for more // information on creating client for this service. // https://docs.aws.amazon.com/sdk-for-go/api/service/sqs/#New package sqs	2.72 KB	2025-05-25 12:27
📄 errors.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package sqs import ( "github.com/aws/aws-sdk-go/private/protocol" ) const ( // ErrCodeBatchEntryIdsNotDistinct for service response error code // "AWS.SimpleQueueService.BatchEntryIdsNotDistinct". // // Two or more batch entries in the request have the same Id. ErrCodeBatchEntryIdsNotDistinct = "AWS.SimpleQueueService.BatchEntryIdsNotDistinct" // ErrCodeBatchRequestTooLong for service response error code // "AWS.SimpleQueueService.BatchRequestTooLong". // // The length of all the messages put together is more than the limit. ErrCodeBatchRequestTooLong = "AWS.SimpleQueueService.BatchRequestTooLong" // ErrCodeEmptyBatchRequest for service response error code // "AWS.SimpleQueueService.EmptyBatchRequest". // // The batch request doesn't contain any entries. ErrCodeEmptyBatchRequest = "AWS.SimpleQueueService.EmptyBatchRequest" // ErrCodeInvalidAddress for service response error code // "InvalidAddress". // // The accountId is invalid. ErrCodeInvalidAddress = "InvalidAddress" // ErrCodeInvalidAttributeName for service response error code // "InvalidAttributeName". // // The specified attribute doesn't exist. ErrCodeInvalidAttributeName = "InvalidAttributeName" // ErrCodeInvalidAttributeValue for service response error code // "InvalidAttributeValue". // // A queue attribute value is invalid. ErrCodeInvalidAttributeValue = "InvalidAttributeValue" // ErrCodeInvalidBatchEntryId for service response error code // "AWS.SimpleQueueService.InvalidBatchEntryId". // // The Id of a batch entry in a batch request doesn't abide by the specification. ErrCodeInvalidBatchEntryId = "AWS.SimpleQueueService.InvalidBatchEntryId" // ErrCodeInvalidIdFormat for service response error code // "InvalidIdFormat". // // The specified receipt handle isn't valid for the current version. ErrCodeInvalidIdFormat = "InvalidIdFormat" // ErrCodeInvalidMessageContents for service response error code // "InvalidMessageContents". // // The message contains characters outside the allowed set. ErrCodeInvalidMessageContents = "InvalidMessageContents" // ErrCodeInvalidSecurity for service response error code // "InvalidSecurity". // // When the request to a queue is not HTTPS and SigV4. ErrCodeInvalidSecurity = "InvalidSecurity" // ErrCodeKmsAccessDenied for service response error code // "KmsAccessDenied". // // The caller doesn't have the required KMS access. ErrCodeKmsAccessDenied = "KmsAccessDenied" // ErrCodeKmsDisabled for service response error code // "KmsDisabled". // // The request was denied due to request throttling. ErrCodeKmsDisabled = "KmsDisabled" // ErrCodeKmsInvalidKeyUsage for service response error code // "KmsInvalidKeyUsage". // // The request was rejected for one of the following reasons: // // * The KeyUsage value of the KMS key is incompatible with the API operation. // // * The encryption algorithm or signing algorithm specified for the operation // is incompatible with the type of key material in the KMS key (KeySpec). ErrCodeKmsInvalidKeyUsage = "KmsInvalidKeyUsage" // ErrCodeKmsInvalidState for service response error code // "KmsInvalidState". // // The request was rejected because the state of the specified resource is not // valid for this request. ErrCodeKmsInvalidState = "KmsInvalidState" // ErrCodeKmsNotFound for service response error code // "KmsNotFound". // // The request was rejected because the specified entity or resource could not // be found. ErrCodeKmsNotFound = "KmsNotFound" // ErrCodeKmsOptInRequired for service response error code // "KmsOptInRequired". // // The request was rejected because the specified key policy isn't syntactically // or semantically correct. ErrCodeKmsOptInRequired = "KmsOptInRequired" // ErrCodeKmsThrottled for service response error code // "KmsThrottled". // // Amazon Web Services KMS throttles requests for the following conditions. ErrCodeKmsThrottled = "KmsThrottled" // ErrCodeMessageNotInflight for service response error code // "AWS.SimpleQueueService.MessageNotInflight". // // The specified message isn't in flight. ErrCodeMessageNotInflight = "AWS.SimpleQueueService.MessageNotInflight" // ErrCodeOverLimit for service response error code // "OverLimit". // // The specified action violates a limit. For example, ReceiveMessage returns // this error if the maximum number of in flight messages is reached and AddPermission // returns this error if the maximum number of permissions for the queue is // reached. ErrCodeOverLimit = "OverLimit" // ErrCodePurgeQueueInProgress for service response error code // "AWS.SimpleQueueService.PurgeQueueInProgress". // // Indicates that the specified queue previously received a PurgeQueue request // within the last 60 seconds (the time it can take to delete the messages in // the queue). ErrCodePurgeQueueInProgress = "AWS.SimpleQueueService.PurgeQueueInProgress" // ErrCodeQueueDeletedRecently for service response error code // "AWS.SimpleQueueService.QueueDeletedRecently". // // You must wait 60 seconds after deleting a queue before you can create another // queue with the same name. ErrCodeQueueDeletedRecently = "AWS.SimpleQueueService.QueueDeletedRecently" // ErrCodeQueueDoesNotExist for service response error code // "AWS.SimpleQueueService.NonExistentQueue". // // The specified queue doesn't exist. ErrCodeQueueDoesNotExist = "AWS.SimpleQueueService.NonExistentQueue" // ErrCodeQueueNameExists for service response error code // "QueueAlreadyExists". // // A queue with this name already exists. Amazon SQS returns this error only // if the request includes attributes whose values differ from those of the // existing queue. ErrCodeQueueNameExists = "QueueAlreadyExists" // ErrCodeReceiptHandleIsInvalid for service response error code // "ReceiptHandleIsInvalid". // // The specified receipt handle isn't valid. ErrCodeReceiptHandleIsInvalid = "ReceiptHandleIsInvalid" // ErrCodeRequestThrottled for service response error code // "RequestThrottled". // // The request was denied due to request throttling. // // * The rate of requests per second exceeds the Amazon Web Services KMS // request quota for an account and Region. // // * A burst or sustained high rate of requests to change the state of the // same KMS key. This condition is often known as a "hot key." // // * Requests for operations on KMS keys in a Amazon Web Services CloudHSM // key store might be throttled at a lower-than-expected rate when the Amazon // Web Services CloudHSM cluster associated with the Amazon Web Services // CloudHSM key store is processing numerous commands, including those unrelated // to the Amazon Web Services CloudHSM key store. ErrCodeRequestThrottled = "RequestThrottled" // ErrCodeResourceNotFoundException for service response error code // "ResourceNotFoundException". // // One or more specified resources don't exist. ErrCodeResourceNotFoundException = "ResourceNotFoundException" // ErrCodeTooManyEntriesInBatchRequest for service response error code // "AWS.SimpleQueueService.TooManyEntriesInBatchRequest". // // The batch request contains more entries than permissible. ErrCodeTooManyEntriesInBatchRequest = "AWS.SimpleQueueService.TooManyEntriesInBatchRequest" // ErrCodeUnsupportedOperation for service response error code // "AWS.SimpleQueueService.UnsupportedOperation". // // Error code 400. Unsupported operation. ErrCodeUnsupportedOperation = "AWS.SimpleQueueService.UnsupportedOperation" ) var exceptionFromCode = map[string]func(protocol.ResponseMetadata) error{ "BatchEntryIdsNotDistinct": newErrorBatchEntryIdsNotDistinct, "BatchRequestTooLong": newErrorBatchRequestTooLong, "EmptyBatchRequest": newErrorEmptyBatchRequest, "InvalidAddress": newErrorInvalidAddress, "InvalidAttributeName": newErrorInvalidAttributeName, "InvalidAttributeValue": newErrorInvalidAttributeValue, "InvalidBatchEntryId": newErrorInvalidBatchEntryId, "InvalidIdFormat": newErrorInvalidIdFormat, "InvalidMessageContents": newErrorInvalidMessageContents, "InvalidSecurity": newErrorInvalidSecurity, "KmsAccessDenied": newErrorKmsAccessDenied, "KmsDisabled": newErrorKmsDisabled, "KmsInvalidKeyUsage": newErrorKmsInvalidKeyUsage, "KmsInvalidState": newErrorKmsInvalidState, "KmsNotFound": newErrorKmsNotFound, "KmsOptInRequired": newErrorKmsOptInRequired, "KmsThrottled": newErrorKmsThrottled, "MessageNotInflight": newErrorMessageNotInflight, "OverLimit": newErrorOverLimit, "PurgeQueueInProgress": newErrorPurgeQueueInProgress, "QueueDeletedRecently": newErrorQueueDeletedRecently, "QueueDoesNotExist": newErrorQueueDoesNotExist, "QueueNameExists": newErrorQueueNameExists, "ReceiptHandleIsInvalid": newErrorReceiptHandleIsInvalid, "RequestThrottled": newErrorRequestThrottled, "ResourceNotFoundException": newErrorResourceNotFoundException, "TooManyEntriesInBatchRequest": newErrorTooManyEntriesInBatchRequest, "UnsupportedOperation": newErrorUnsupportedOperation, } var queryExceptionFromCode = map[string]func(protocol.ResponseMetadata, string) error{ "BatchEntryIdsNotDistinct": newQueryCompatibleErrorBatchEntryIdsNotDistinct, "BatchRequestTooLong": newQueryCompatibleErrorBatchRequestTooLong, "EmptyBatchRequest": newQueryCompatibleErrorEmptyBatchRequest, "InvalidAddress": newQueryCompatibleErrorInvalidAddress, "InvalidAttributeName": newQueryCompatibleErrorInvalidAttributeName, "InvalidAttributeValue": newQueryCompatibleErrorInvalidAttributeValue, "InvalidBatchEntryId": newQueryCompatibleErrorInvalidBatchEntryId, "InvalidIdFormat": newQueryCompatibleErrorInvalidIdFormat, "InvalidMessageContents": newQueryCompatibleErrorInvalidMessageContents, "InvalidSecurity": newQueryCompatibleErrorInvalidSecurity, "KmsAccessDenied": newQueryCompatibleErrorKmsAccessDenied, "KmsDisabled": newQueryCompatibleErrorKmsDisabled, "KmsInvalidKeyUsage": newQueryCompatibleErrorKmsInvalidKeyUsage, "KmsInvalidState": newQueryCompatibleErrorKmsInvalidState, "KmsNotFound": newQueryCompatibleErrorKmsNotFound, "KmsOptInRequired": newQueryCompatibleErrorKmsOptInRequired, "KmsThrottled": newQueryCompatibleErrorKmsThrottled, "MessageNotInflight": newQueryCompatibleErrorMessageNotInflight, "OverLimit": newQueryCompatibleErrorOverLimit, "PurgeQueueInProgress": newQueryCompatibleErrorPurgeQueueInProgress, "QueueDeletedRecently": newQueryCompatibleErrorQueueDeletedRecently, "QueueDoesNotExist": newQueryCompatibleErrorQueueDoesNotExist, "QueueNameExists": newQueryCompatibleErrorQueueNameExists, "ReceiptHandleIsInvalid": newQueryCompatibleErrorReceiptHandleIsInvalid, "RequestThrottled": newQueryCompatibleErrorRequestThrottled, "ResourceNotFoundException": newQueryCompatibleErrorResourceNotFoundException, "TooManyEntriesInBatchRequest": newQueryCompatibleErrorTooManyEntriesInBatchRequest, "UnsupportedOperation": newQueryCompatibleErrorUnsupportedOperation, }	11.38 KB	2025-05-25 12:27
📄 integ_test.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. //go:build go1.16 && integration // +build go1.16,integration package sqs_test import ( "context" "testing" "time" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/awserr" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/awstesting/integration" "github.com/aws/aws-sdk-go/service/sqs" ) var _ aws.Config var _ awserr.Error var _ request.Request func TestInteg_00_ListQueues(t testing.T) { ctx, cancelFn := context.WithTimeout(context.Background(), 5time.Second) defer cancelFn() sess := integration.SessionWithDefaultRegion("us-west-2") svc := sqs.New(sess) params := &sqs.ListQueuesInput{} _, err := svc.ListQueuesWithContext(ctx, params, func(r request.Request) { r.Handlers.Validate.RemoveByName("core.ValidateParametersHandler") }) if err != nil { t.Errorf("expect no error, got %v", err) } } func TestInteg_01_GetQueueUrl(t testing.T) { ctx, cancelFn := context.WithTimeout(context.Background(), 5time.Second) defer cancelFn() sess := integration.SessionWithDefaultRegion("us-west-2") svc := sqs.New(sess) params := &sqs.GetQueueUrlInput{ QueueName: aws.String("fake_queue"), } _, err := svc.GetQueueUrlWithContext(ctx, params, func(r request.Request) { r.Handlers.Validate.RemoveByName("core.ValidateParametersHandler") }) if err == nil { t.Fatalf("expect request to fail") } aerr, ok := err.(awserr.RequestFailure) if !ok { t.Fatalf("expect awserr, was %T", err) } if len(aerr.Code()) == 0 { t.Errorf("expect non-empty error code") } if len(aerr.Message()) == 0 { t.Errorf("expect non-empty error message") } if v := aerr.Code(); v == request.ErrCodeSerialization { t.Errorf("expect API error code got serialization failure") } }	1.76 KB	2025-05-25 12:27
📄 service.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package sqs import ( "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/client" "github.com/aws/aws-sdk-go/aws/client/metadata" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/aws/signer/v4" "github.com/aws/aws-sdk-go/private/protocol" "github.com/aws/aws-sdk-go/private/protocol/jsonrpc" ) // SQS provides the API operation methods for making requests to // Amazon Simple Queue Service. See this package's package overview docs // for details on the service. // // SQS methods are safe to use concurrently. It is not safe to // modify mutate any of the struct's properties though. type SQS struct { client.Client } // Used for custom client initialization logic var initClient func(client.Client) // Used for custom request initialization logic var initRequest func(request.Request) // Service information constants const ( ServiceName = "sqs" // Name of service. EndpointsID = ServiceName // ID to lookup a service endpoint with. ServiceID = "SQS" // ServiceID is a unique identifier of a specific service. ) // New creates a new instance of the SQS client with a session. // If additional configuration is needed for the client instance use the optional // aws.Config parameter to add your extra config. // // Example: // // mySession := session.Must(session.NewSession()) // // // Create a SQS client from just a session. // svc := sqs.New(mySession) // // // Create a SQS client with additional configuration // svc := sqs.New(mySession, aws.NewConfig().WithRegion("us-west-2")) func New(p client.ConfigProvider, cfgs ...aws.Config) SQS { c := p.ClientConfig(EndpointsID, cfgs...) if c.SigningNameDerived \|\| len(c.SigningName) == 0 { c.SigningName = EndpointsID // No Fallback } return newClient(c.Config, c.Handlers, c.PartitionID, c.Endpoint, c.SigningRegion, c.SigningName, c.ResolvedRegion) } // newClient creates, initializes and returns a new service client instance. func newClient(cfg aws.Config, handlers request.Handlers, partitionID, endpoint, signingRegion, signingName, resolvedRegion string) SQS { svc := &SQS{ Client: client.New( cfg, metadata.ClientInfo{ ServiceName: ServiceName, ServiceID: ServiceID, SigningName: signingName, SigningRegion: signingRegion, PartitionID: partitionID, Endpoint: endpoint, APIVersion: "2012-11-05", ResolvedRegion: resolvedRegion, JSONVersion: "1.0", TargetPrefix: "AmazonSQS", }, handlers, ), } // Handlers svc.Handlers.Sign.PushBackNamed(v4.SignRequestHandler) svc.Handlers.Build.PushBackNamed(jsonrpc.BuildHandler) svc.Handlers.Unmarshal.PushBackNamed(jsonrpc.UnmarshalHandler) svc.Handlers.UnmarshalMeta.PushBackNamed(jsonrpc.UnmarshalMetaHandler) svc.Handlers.UnmarshalError.PushBackNamed( protocol.NewUnmarshalErrorHandler(jsonrpc.NewUnmarshalTypedErrorWithOptions(exceptionFromCode, jsonrpc.WithQueryCompatibility(queryExceptionFromCode))).NamedHandler(), ) // Run custom client initialization if present if initClient != nil { initClient(svc.Client) } return svc } // newRequest creates a new request for a SQS operation and runs any // custom request initialization. func (c SQS) newRequest(op request.Operation, params, data interface{}) request.Request { req := c.NewRequest(op, params, data) // Run custom request initialization if present if initRequest != nil { initRequest(req) } return req }	3.45 KB	2025-05-25 12:27
📁 sqsiface	-	2025-05-25 12:27

Terminal