aws_gleam_sqs - v0.1.2

aws/services/sqs

Generated from com.amazonaws.sqs#AmazonSQS (awsJson1_0). DO NOT EDIT. Re-generate via the codegen subproject.

Types

AddPermissionError

</> 
pub type AddPermissionError {
  AddPermissionErrorInvalidAddress(value: InvalidAddress)
  AddPermissionErrorInvalidSecurity(value: InvalidSecurity)
  AddPermissionErrorOverLimit(value: OverLimit)
  AddPermissionErrorQueueDoesNotExist(value: QueueDoesNotExist)
  AddPermissionErrorRequestThrottled(value: RequestThrottled)
  AddPermissionErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  AddPermissionErrorTransport(reason: String)
  AddPermissionErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • AddPermissionErrorInvalidAddress(value: InvalidAddress)
  • AddPermissionErrorInvalidSecurity(value: InvalidSecurity)
  • AddPermissionErrorOverLimit(value: OverLimit)
  • AddPermissionErrorQueueDoesNotExist(value: QueueDoesNotExist)
  • AddPermissionErrorRequestThrottled(value: RequestThrottled)
  • AddPermissionErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • AddPermissionErrorTransport(reason: String)
  • AddPermissionErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

AddPermissionOutput

</> 
pub type AddPermissionOutput {
  AddPermissionOutput
}

Constructors 

  • AddPermissionOutput

AddPermissionRequest

</> 
pub type AddPermissionRequest {
  AddPermissionRequest(
    aws_account_ids: option.Option(List(String)),
    actions: option.Option(List(String)),
    label: option.Option(String),
    queue_url: option.Option(String),
  )
}

Constructors

BatchEntryIdsNotDistinct

</> 
pub type BatchEntryIdsNotDistinct {
  BatchEntryIdsNotDistinct(message: option.Option(String))
}

Constructors

BatchRequestTooLong

</> 
pub type BatchRequestTooLong {
  BatchRequestTooLong(message: option.Option(String))
}

Constructors

BatchResultErrorEntry

</> 
pub type BatchResultErrorEntry {
  BatchResultErrorEntry(
    code: option.Option(String),
    id: option.Option(String),
    message: option.Option(String),
    sender_fault: option.Option(Bool),
  )
}

Constructors

CancelMessageMoveTaskError

</> 
pub type CancelMessageMoveTaskError {
  CancelMessageMoveTaskErrorInvalidAddress(value: InvalidAddress)
  CancelMessageMoveTaskErrorInvalidSecurity(
    value: InvalidSecurity,
  )
  CancelMessageMoveTaskErrorRequestThrottled(
    value: RequestThrottled,
  )
  CancelMessageMoveTaskErrorResourceNotFoundException(
    value: ResourceNotFoundException,
  )
  CancelMessageMoveTaskErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  CancelMessageMoveTaskErrorTransport(reason: String)
  CancelMessageMoveTaskErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • CancelMessageMoveTaskErrorInvalidAddress(value: InvalidAddress)
  • CancelMessageMoveTaskErrorInvalidSecurity(value: InvalidSecurity)
  • CancelMessageMoveTaskErrorRequestThrottled(
  value: RequestThrottled,
)
  • CancelMessageMoveTaskErrorResourceNotFoundException(
  value: ResourceNotFoundException,
)
  • CancelMessageMoveTaskErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • CancelMessageMoveTaskErrorTransport(reason: String)
  • CancelMessageMoveTaskErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

CancelMessageMoveTaskRequest

</> 
pub type CancelMessageMoveTaskRequest {
  CancelMessageMoveTaskRequest(
    task_handle: option.Option(String),
  )
}

Constructors 

  • CancelMessageMoveTaskRequest(task_handle: option.Option(String))

CancelMessageMoveTaskResult

</> 
pub type CancelMessageMoveTaskResult {
  CancelMessageMoveTaskResult(
    approximate_number_of_messages_moved: option.Option(Int),
  )
}

Constructors 

  • CancelMessageMoveTaskResult(
  approximate_number_of_messages_moved: option.Option(Int),
)

ChangeMessageVisibilityBatchError

</> 
pub type ChangeMessageVisibilityBatchError {
  ChangeMessageVisibilityBatchErrorBatchEntryIdsNotDistinct(
    value: BatchEntryIdsNotDistinct,
  )
  ChangeMessageVisibilityBatchErrorEmptyBatchRequest(
    value: EmptyBatchRequest,
  )
  ChangeMessageVisibilityBatchErrorInvalidAddress(
    value: InvalidAddress,
  )
  ChangeMessageVisibilityBatchErrorInvalidBatchEntryId(
    value: InvalidBatchEntryId,
  )
  ChangeMessageVisibilityBatchErrorInvalidSecurity(
    value: InvalidSecurity,
  )
  ChangeMessageVisibilityBatchErrorQueueDoesNotExist(
    value: QueueDoesNotExist,
  )
  ChangeMessageVisibilityBatchErrorRequestThrottled(
    value: RequestThrottled,
  )
  ChangeMessageVisibilityBatchErrorTooManyEntriesInBatchRequest(
    value: TooManyEntriesInBatchRequest,
  )
  ChangeMessageVisibilityBatchErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  ChangeMessageVisibilityBatchErrorTransport(reason: String)
  ChangeMessageVisibilityBatchErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • ChangeMessageVisibilityBatchErrorBatchEntryIdsNotDistinct(
  value: BatchEntryIdsNotDistinct,
)
  • ChangeMessageVisibilityBatchErrorEmptyBatchRequest(
  value: EmptyBatchRequest,
)
  • ChangeMessageVisibilityBatchErrorInvalidAddress(
  value: InvalidAddress,
)
  • ChangeMessageVisibilityBatchErrorInvalidBatchEntryId(
  value: InvalidBatchEntryId,
)
  • ChangeMessageVisibilityBatchErrorInvalidSecurity(
  value: InvalidSecurity,
)
  • ChangeMessageVisibilityBatchErrorQueueDoesNotExist(
  value: QueueDoesNotExist,
)
  • ChangeMessageVisibilityBatchErrorRequestThrottled(
  value: RequestThrottled,
)
  • ChangeMessageVisibilityBatchErrorTooManyEntriesInBatchRequest(
  value: TooManyEntriesInBatchRequest,
)
  • ChangeMessageVisibilityBatchErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • ChangeMessageVisibilityBatchErrorTransport(reason: String)
  • ChangeMessageVisibilityBatchErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

ChangeMessageVisibilityBatchRequest

</> 
pub type ChangeMessageVisibilityBatchRequest {
  ChangeMessageVisibilityBatchRequest(
    entries: option.Option(
      List(ChangeMessageVisibilityBatchRequestEntry),
    ),
    queue_url: option.Option(String),
  )
}

Constructors

ChangeMessageVisibilityBatchRequestEntry

</> 
pub type ChangeMessageVisibilityBatchRequestEntry {
  ChangeMessageVisibilityBatchRequestEntry(
    id: option.Option(String),
    receipt_handle: option.Option(String),
    visibility_timeout: option.Option(Int),
  )
}

Constructors

ChangeMessageVisibilityBatchResult

</> 
pub type ChangeMessageVisibilityBatchResult {
  ChangeMessageVisibilityBatchResult(
    failed: option.Option(List(BatchResultErrorEntry)),
    successful: option.Option(
      List(ChangeMessageVisibilityBatchResultEntry),
    ),
  )
}

Constructors

ChangeMessageVisibilityBatchResultEntry

</> 
pub type ChangeMessageVisibilityBatchResultEntry {
  ChangeMessageVisibilityBatchResultEntry(
    id: option.Option(String),
  )
}

Constructors 

  • ChangeMessageVisibilityBatchResultEntry(
  id: option.Option(String),
)

ChangeMessageVisibilityError

</> 
pub type ChangeMessageVisibilityError {
  ChangeMessageVisibilityErrorInvalidAddress(
    value: InvalidAddress,
  )
  ChangeMessageVisibilityErrorInvalidSecurity(
    value: InvalidSecurity,
  )
  ChangeMessageVisibilityErrorMessageNotInflight(
    value: MessageNotInflight,
  )
  ChangeMessageVisibilityErrorQueueDoesNotExist(
    value: QueueDoesNotExist,
  )
  ChangeMessageVisibilityErrorReceiptHandleIsInvalid(
    value: ReceiptHandleIsInvalid,
  )
  ChangeMessageVisibilityErrorRequestThrottled(
    value: RequestThrottled,
  )
  ChangeMessageVisibilityErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  ChangeMessageVisibilityErrorTransport(reason: String)
  ChangeMessageVisibilityErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • ChangeMessageVisibilityErrorInvalidAddress(value: InvalidAddress)
  • ChangeMessageVisibilityErrorInvalidSecurity(
  value: InvalidSecurity,
)
  • ChangeMessageVisibilityErrorMessageNotInflight(
  value: MessageNotInflight,
)
  • ChangeMessageVisibilityErrorQueueDoesNotExist(
  value: QueueDoesNotExist,
)
  • ChangeMessageVisibilityErrorReceiptHandleIsInvalid(
  value: ReceiptHandleIsInvalid,
)
  • ChangeMessageVisibilityErrorRequestThrottled(
  value: RequestThrottled,
)
  • ChangeMessageVisibilityErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • ChangeMessageVisibilityErrorTransport(reason: String)
  • ChangeMessageVisibilityErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

ChangeMessageVisibilityOutput

</> 
pub type ChangeMessageVisibilityOutput {
  ChangeMessageVisibilityOutput
}

Constructors 

  • ChangeMessageVisibilityOutput

ChangeMessageVisibilityRequest

</> 
pub type ChangeMessageVisibilityRequest {
  ChangeMessageVisibilityRequest(
    queue_url: option.Option(String),
    receipt_handle: option.Option(String),
    visibility_timeout: option.Option(Int),
  )
}

Constructors

Client

opaque </> 
pub opaque type Client

CreateQueueError

</> 
pub type CreateQueueError {
  CreateQueueErrorInvalidAddress(value: InvalidAddress)
  CreateQueueErrorInvalidAttributeName(
    value: InvalidAttributeName,
  )
  CreateQueueErrorInvalidAttributeValue(
    value: InvalidAttributeValue,
  )
  CreateQueueErrorInvalidSecurity(value: InvalidSecurity)
  CreateQueueErrorQueueDeletedRecently(
    value: QueueDeletedRecently,
  )
  CreateQueueErrorQueueNameExists(value: QueueNameExists)
  CreateQueueErrorRequestThrottled(value: RequestThrottled)
  CreateQueueErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  CreateQueueErrorTransport(reason: String)
  CreateQueueErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

CreateQueueRequest

</> 
pub type CreateQueueRequest {
  CreateQueueRequest(
    attributes: option.Option(dict.Dict(String, String)),
    queue_name: option.Option(String),
    tags: option.Option(dict.Dict(String, String)),
  )
}

Constructors

CreateQueueResult

</> 
pub type CreateQueueResult {
  CreateQueueResult(queue_url: option.Option(String))
}

Constructors

DeleteMessageBatchError

</> 
pub type DeleteMessageBatchError {
  DeleteMessageBatchErrorBatchEntryIdsNotDistinct(
    value: BatchEntryIdsNotDistinct,
  )
  DeleteMessageBatchErrorEmptyBatchRequest(
    value: EmptyBatchRequest,
  )
  DeleteMessageBatchErrorInvalidAddress(value: InvalidAddress)
  DeleteMessageBatchErrorInvalidBatchEntryId(
    value: InvalidBatchEntryId,
  )
  DeleteMessageBatchErrorInvalidSecurity(value: InvalidSecurity)
  DeleteMessageBatchErrorQueueDoesNotExist(
    value: QueueDoesNotExist,
  )
  DeleteMessageBatchErrorRequestThrottled(
    value: RequestThrottled,
  )
  DeleteMessageBatchErrorTooManyEntriesInBatchRequest(
    value: TooManyEntriesInBatchRequest,
  )
  DeleteMessageBatchErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  DeleteMessageBatchErrorTransport(reason: String)
  DeleteMessageBatchErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

DeleteMessageBatchRequest

</> 
pub type DeleteMessageBatchRequest {
  DeleteMessageBatchRequest(
    entries: option.Option(List(DeleteMessageBatchRequestEntry)),
    queue_url: option.Option(String),
  )
}

Constructors

DeleteMessageBatchRequestEntry

</> 
pub type DeleteMessageBatchRequestEntry {
  DeleteMessageBatchRequestEntry(
    id: option.Option(String),
    receipt_handle: option.Option(String),
  )
}

Constructors

DeleteMessageBatchResult

</> 
pub type DeleteMessageBatchResult {
  DeleteMessageBatchResult(
    failed: option.Option(List(BatchResultErrorEntry)),
    successful: option.Option(List(DeleteMessageBatchResultEntry)),
  )
}

Constructors

DeleteMessageBatchResultEntry

</> 
pub type DeleteMessageBatchResultEntry {
  DeleteMessageBatchResultEntry(id: option.Option(String))
}

Constructors

DeleteMessageError

</> 
pub type DeleteMessageError {
  DeleteMessageErrorInvalidAddress(value: InvalidAddress)
  DeleteMessageErrorInvalidIdFormat(value: InvalidIdFormat)
  DeleteMessageErrorInvalidSecurity(value: InvalidSecurity)
  DeleteMessageErrorQueueDoesNotExist(value: QueueDoesNotExist)
  DeleteMessageErrorReceiptHandleIsInvalid(
    value: ReceiptHandleIsInvalid,
  )
  DeleteMessageErrorRequestThrottled(value: RequestThrottled)
  DeleteMessageErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  DeleteMessageErrorTransport(reason: String)
  DeleteMessageErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

DeleteMessageOutput

</> 
pub type DeleteMessageOutput {
  DeleteMessageOutput
}

Constructors 

  • DeleteMessageOutput

DeleteMessageRequest

</> 
pub type DeleteMessageRequest {
  DeleteMessageRequest(
    queue_url: option.Option(String),
    receipt_handle: option.Option(String),
  )
}

Constructors

DeleteQueueError

</> 
pub type DeleteQueueError {
  DeleteQueueErrorInvalidAddress(value: InvalidAddress)
  DeleteQueueErrorInvalidSecurity(value: InvalidSecurity)
  DeleteQueueErrorQueueDoesNotExist(value: QueueDoesNotExist)
  DeleteQueueErrorRequestThrottled(value: RequestThrottled)
  DeleteQueueErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  DeleteQueueErrorTransport(reason: String)
  DeleteQueueErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • DeleteQueueErrorInvalidAddress(value: InvalidAddress)
  • DeleteQueueErrorInvalidSecurity(value: InvalidSecurity)
  • DeleteQueueErrorQueueDoesNotExist(value: QueueDoesNotExist)
  • DeleteQueueErrorRequestThrottled(value: RequestThrottled)
  • DeleteQueueErrorUnsupportedOperation(value: UnsupportedOperation)
  • DeleteQueueErrorTransport(reason: String)
  • DeleteQueueErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

DeleteQueueOutput

</> 
pub type DeleteQueueOutput {
  DeleteQueueOutput
}

Constructors 

  • DeleteQueueOutput

DeleteQueueRequest

</> 
pub type DeleteQueueRequest {
  DeleteQueueRequest(queue_url: option.Option(String))
}

Constructors

EmptyBatchRequest

</> 
pub type EmptyBatchRequest {
  EmptyBatchRequest(message: option.Option(String))
}

Constructors

GetQueueAttributesError

</> 
pub type GetQueueAttributesError {
  GetQueueAttributesErrorInvalidAddress(value: InvalidAddress)
  GetQueueAttributesErrorInvalidAttributeName(
    value: InvalidAttributeName,
  )
  GetQueueAttributesErrorInvalidSecurity(value: InvalidSecurity)
  GetQueueAttributesErrorQueueDoesNotExist(
    value: QueueDoesNotExist,
  )
  GetQueueAttributesErrorRequestThrottled(
    value: RequestThrottled,
  )
  GetQueueAttributesErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  GetQueueAttributesErrorTransport(reason: String)
  GetQueueAttributesErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • GetQueueAttributesErrorInvalidAddress(value: InvalidAddress)
  • GetQueueAttributesErrorInvalidAttributeName(
  value: InvalidAttributeName,
)
  • GetQueueAttributesErrorInvalidSecurity(value: InvalidSecurity)
  • GetQueueAttributesErrorQueueDoesNotExist(
  value: QueueDoesNotExist,
)
  • GetQueueAttributesErrorRequestThrottled(value: RequestThrottled)
  • GetQueueAttributesErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • GetQueueAttributesErrorTransport(reason: String)
  • GetQueueAttributesErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

GetQueueAttributesRequest

</> 
pub type GetQueueAttributesRequest {
  GetQueueAttributesRequest(
    attribute_names: option.Option(List(QueueAttributeName)),
    queue_url: option.Option(String),
  )
}

Constructors

GetQueueAttributesResult

</> 
pub type GetQueueAttributesResult {
  GetQueueAttributesResult(
    attributes: option.Option(dict.Dict(String, String)),
  )
}

Constructors

GetQueueUrlError

</> 
pub type GetQueueUrlError {
  GetQueueUrlErrorInvalidAddress(value: InvalidAddress)
  GetQueueUrlErrorInvalidSecurity(value: InvalidSecurity)
  GetQueueUrlErrorQueueDoesNotExist(value: QueueDoesNotExist)
  GetQueueUrlErrorRequestThrottled(value: RequestThrottled)
  GetQueueUrlErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  GetQueueUrlErrorTransport(reason: String)
  GetQueueUrlErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • GetQueueUrlErrorInvalidAddress(value: InvalidAddress)
  • GetQueueUrlErrorInvalidSecurity(value: InvalidSecurity)
  • GetQueueUrlErrorQueueDoesNotExist(value: QueueDoesNotExist)
  • GetQueueUrlErrorRequestThrottled(value: RequestThrottled)
  • GetQueueUrlErrorUnsupportedOperation(value: UnsupportedOperation)
  • GetQueueUrlErrorTransport(reason: String)
  • GetQueueUrlErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

GetQueueUrlRequest

</> 
pub type GetQueueUrlRequest {
  GetQueueUrlRequest(
    queue_name: option.Option(String),
    queue_owner_aws_account_id: option.Option(String),
  )
}

Constructors

GetQueueUrlResult

</> 
pub type GetQueueUrlResult {
  GetQueueUrlResult(queue_url: option.Option(String))
}

Constructors

InvalidAddress

</> 
pub type InvalidAddress {
  InvalidAddress(message: option.Option(String))
}

Constructors

InvalidAttributeName

</> 
pub type InvalidAttributeName {
  InvalidAttributeName(message: option.Option(String))
}

Constructors

InvalidAttributeValue

</> 
pub type InvalidAttributeValue {
  InvalidAttributeValue(message: option.Option(String))
}

Constructors

InvalidBatchEntryId

</> 
pub type InvalidBatchEntryId {
  InvalidBatchEntryId(message: option.Option(String))
}

Constructors

InvalidIdFormat

</> 
pub type InvalidIdFormat {
  InvalidIdFormat
}

Constructors 

  • InvalidIdFormat

InvalidMessageContents

</> 
pub type InvalidMessageContents {
  InvalidMessageContents(message: option.Option(String))
}

Constructors

InvalidSecurity

</> 
pub type InvalidSecurity {
  InvalidSecurity(message: option.Option(String))
}

Constructors

KmsAccessDenied

</> 
pub type KmsAccessDenied {
  KmsAccessDenied(message: option.Option(String))
}

Constructors

KmsDisabled

</> 
pub type KmsDisabled {
  KmsDisabled(message: option.Option(String))
}

Constructors

KmsInvalidKeyUsage

</> 
pub type KmsInvalidKeyUsage {
  KmsInvalidKeyUsage(message: option.Option(String))
}

Constructors

KmsInvalidState

</> 
pub type KmsInvalidState {
  KmsInvalidState(message: option.Option(String))
}

Constructors

KmsNotFound

</> 
pub type KmsNotFound {
  KmsNotFound(message: option.Option(String))
}

Constructors

KmsOptInRequired

</> 
pub type KmsOptInRequired {
  KmsOptInRequired(message: option.Option(String))
}

Constructors

KmsThrottled

</> 
pub type KmsThrottled {
  KmsThrottled(message: option.Option(String))
}

Constructors

ListDeadLetterSourceQueuesError

</> 
pub type ListDeadLetterSourceQueuesError {
  ListDeadLetterSourceQueuesErrorInvalidAddress(
    value: InvalidAddress,
  )
  ListDeadLetterSourceQueuesErrorInvalidSecurity(
    value: InvalidSecurity,
  )
  ListDeadLetterSourceQueuesErrorQueueDoesNotExist(
    value: QueueDoesNotExist,
  )
  ListDeadLetterSourceQueuesErrorRequestThrottled(
    value: RequestThrottled,
  )
  ListDeadLetterSourceQueuesErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  ListDeadLetterSourceQueuesErrorTransport(reason: String)
  ListDeadLetterSourceQueuesErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • ListDeadLetterSourceQueuesErrorInvalidAddress(
  value: InvalidAddress,
)
  • ListDeadLetterSourceQueuesErrorInvalidSecurity(
  value: InvalidSecurity,
)
  • ListDeadLetterSourceQueuesErrorQueueDoesNotExist(
  value: QueueDoesNotExist,
)
  • ListDeadLetterSourceQueuesErrorRequestThrottled(
  value: RequestThrottled,
)
  • ListDeadLetterSourceQueuesErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • ListDeadLetterSourceQueuesErrorTransport(reason: String)
  • ListDeadLetterSourceQueuesErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

ListDeadLetterSourceQueuesRequest

</> 
pub type ListDeadLetterSourceQueuesRequest {
  ListDeadLetterSourceQueuesRequest(
    max_results: option.Option(Int),
    next_token: option.Option(String),
    queue_url: option.Option(String),
  )
}

Constructors

ListDeadLetterSourceQueuesResult

</> 
pub type ListDeadLetterSourceQueuesResult {
  ListDeadLetterSourceQueuesResult(
    next_token: option.Option(String),
    queue_urls: option.Option(List(String)),
  )
}

Constructors

ListMessageMoveTasksError

</> 
pub type ListMessageMoveTasksError {
  ListMessageMoveTasksErrorInvalidAddress(value: InvalidAddress)
  ListMessageMoveTasksErrorInvalidSecurity(
    value: InvalidSecurity,
  )
  ListMessageMoveTasksErrorRequestThrottled(
    value: RequestThrottled,
  )
  ListMessageMoveTasksErrorResourceNotFoundException(
    value: ResourceNotFoundException,
  )
  ListMessageMoveTasksErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  ListMessageMoveTasksErrorTransport(reason: String)
  ListMessageMoveTasksErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • ListMessageMoveTasksErrorInvalidAddress(value: InvalidAddress)
  • ListMessageMoveTasksErrorInvalidSecurity(value: InvalidSecurity)
  • ListMessageMoveTasksErrorRequestThrottled(
  value: RequestThrottled,
)
  • ListMessageMoveTasksErrorResourceNotFoundException(
  value: ResourceNotFoundException,
)
  • ListMessageMoveTasksErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • ListMessageMoveTasksErrorTransport(reason: String)
  • ListMessageMoveTasksErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

ListMessageMoveTasksRequest

</> 
pub type ListMessageMoveTasksRequest {
  ListMessageMoveTasksRequest(
    max_results: option.Option(Int),
    source_arn: option.Option(String),
  )
}

Constructors

ListMessageMoveTasksResult

</> 
pub type ListMessageMoveTasksResult {
  ListMessageMoveTasksResult(
    results: option.Option(List(ListMessageMoveTasksResultEntry)),
  )
}

Constructors

ListMessageMoveTasksResultEntry

</> 
pub type ListMessageMoveTasksResultEntry {
  ListMessageMoveTasksResultEntry(
    approximate_number_of_messages_moved: option.Option(Int),
    approximate_number_of_messages_to_move: option.Option(Int),
    destination_arn: option.Option(String),
    failure_reason: option.Option(String),
    max_number_of_messages_per_second: option.Option(Int),
    source_arn: option.Option(String),
    started_timestamp: option.Option(Int),
    status: option.Option(String),
    task_handle: option.Option(String),
  )
}

Constructors

ListQueueTagsError

</> 
pub type ListQueueTagsError {
  ListQueueTagsErrorInvalidAddress(value: InvalidAddress)
  ListQueueTagsErrorInvalidSecurity(value: InvalidSecurity)
  ListQueueTagsErrorQueueDoesNotExist(value: QueueDoesNotExist)
  ListQueueTagsErrorRequestThrottled(value: RequestThrottled)
  ListQueueTagsErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  ListQueueTagsErrorTransport(reason: String)
  ListQueueTagsErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • ListQueueTagsErrorInvalidAddress(value: InvalidAddress)
  • ListQueueTagsErrorInvalidSecurity(value: InvalidSecurity)
  • ListQueueTagsErrorQueueDoesNotExist(value: QueueDoesNotExist)
  • ListQueueTagsErrorRequestThrottled(value: RequestThrottled)
  • ListQueueTagsErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • ListQueueTagsErrorTransport(reason: String)
  • ListQueueTagsErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

ListQueueTagsRequest

</> 
pub type ListQueueTagsRequest {
  ListQueueTagsRequest(queue_url: option.Option(String))
}

Constructors

ListQueueTagsResult

</> 
pub type ListQueueTagsResult {
  ListQueueTagsResult(
    tags: option.Option(dict.Dict(String, String)),
  )
}

Constructors

ListQueuesError

</> 
pub type ListQueuesError {
  ListQueuesErrorInvalidAddress(value: InvalidAddress)
  ListQueuesErrorInvalidSecurity(value: InvalidSecurity)
  ListQueuesErrorRequestThrottled(value: RequestThrottled)
  ListQueuesErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  ListQueuesErrorTransport(reason: String)
  ListQueuesErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • ListQueuesErrorInvalidAddress(value: InvalidAddress)
  • ListQueuesErrorInvalidSecurity(value: InvalidSecurity)
  • ListQueuesErrorRequestThrottled(value: RequestThrottled)
  • ListQueuesErrorUnsupportedOperation(value: UnsupportedOperation)
  • ListQueuesErrorTransport(reason: String)
  • ListQueuesErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

ListQueuesRequest

</> 
pub type ListQueuesRequest {
  ListQueuesRequest(
    max_results: option.Option(Int),
    next_token: option.Option(String),
    queue_name_prefix: option.Option(String),
  )
}

Constructors

ListQueuesResult

</> 
pub type ListQueuesResult {
  ListQueuesResult(
    next_token: option.Option(String),
    queue_urls: option.Option(List(String)),
  )
}

Constructors

Message

</> 
pub type Message {
  Message(
    attributes: option.Option(dict.Dict(String, String)),
    body: option.Option(String),
    md5_of_body: option.Option(String),
    md5_of_message_attributes: option.Option(String),
    message_attributes: option.Option(
      dict.Dict(String, MessageAttributeValue),
    ),
    message_id: option.Option(String),
    receipt_handle: option.Option(String),
  )
}

Constructors

MessageAttributeValue

</> 
pub type MessageAttributeValue {
  MessageAttributeValue(
    binary_list_values: option.Option(List(BitArray)),
    binary_value: option.Option(BitArray),
    data_type: option.Option(String),
    string_list_values: option.Option(List(String)),
    string_value: option.Option(String),
  )
}

Constructors

MessageNotInflight

</> 
pub type MessageNotInflight {
  MessageNotInflight
}

Constructors 

  • MessageNotInflight

MessageSystemAttributeName

</> 
pub type MessageSystemAttributeName {
  MessageSystemAttributeNameAwstraceheader
  MessageSystemAttributeNameAll
  MessageSystemAttributeNameApproximatefirstreceivetimestamp
  MessageSystemAttributeNameApproximatereceivecount
  MessageSystemAttributeNameDeadletterqueuesourcearn
  MessageSystemAttributeNameMessagededuplicationid
  MessageSystemAttributeNameMessagegroupid
  MessageSystemAttributeNameSenderid
  MessageSystemAttributeNameSenttimestamp
  MessageSystemAttributeNameSequencenumber
}

Constructors 

  • MessageSystemAttributeNameAwstraceheader
  • MessageSystemAttributeNameAll
  • MessageSystemAttributeNameApproximatefirstreceivetimestamp
  • MessageSystemAttributeNameApproximatereceivecount
  • MessageSystemAttributeNameDeadletterqueuesourcearn
  • MessageSystemAttributeNameMessagededuplicationid
  • MessageSystemAttributeNameMessagegroupid
  • MessageSystemAttributeNameSenderid
  • MessageSystemAttributeNameSenttimestamp
  • MessageSystemAttributeNameSequencenumber

MessageSystemAttributeNameForSends

</> 
pub type MessageSystemAttributeNameForSends {
  MessageSystemAttributeNameForSendsAwstraceheader
}

Constructors 

  • MessageSystemAttributeNameForSendsAwstraceheader

MessageSystemAttributeValue

</> 
pub type MessageSystemAttributeValue {
  MessageSystemAttributeValue(
    binary_list_values: option.Option(List(BitArray)),
    binary_value: option.Option(BitArray),
    data_type: option.Option(String),
    string_list_values: option.Option(List(String)),
    string_value: option.Option(String),
  )
}

Constructors

OverLimit

</> 
pub type OverLimit {
  OverLimit(message: option.Option(String))
}

Constructors

PurgeQueueError

</> 
pub type PurgeQueueError {
  PurgeQueueErrorInvalidAddress(value: InvalidAddress)
  PurgeQueueErrorInvalidSecurity(value: InvalidSecurity)
  PurgeQueueErrorPurgeQueueInProgress(
    value: PurgeQueueInProgress,
  )
  PurgeQueueErrorQueueDoesNotExist(value: QueueDoesNotExist)
  PurgeQueueErrorRequestThrottled(value: RequestThrottled)
  PurgeQueueErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  PurgeQueueErrorTransport(reason: String)
  PurgeQueueErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

PurgeQueueInProgress

</> 
pub type PurgeQueueInProgress {
  PurgeQueueInProgress(message: option.Option(String))
}

Constructors

PurgeQueueOutput

</> 
pub type PurgeQueueOutput {
  PurgeQueueOutput
}

Constructors 

  • PurgeQueueOutput

PurgeQueueRequest

</> 
pub type PurgeQueueRequest {
  PurgeQueueRequest(queue_url: option.Option(String))
}

Constructors

QueueAttributeName

</> 
pub type QueueAttributeName {
  QueueAttributeNameAll
  QueueAttributeNameApproximatenumberofmessages
  QueueAttributeNameApproximatenumberofmessagesdelayed
  QueueAttributeNameApproximatenumberofmessagesnotvisible
  QueueAttributeNameContentbaseddeduplication
  QueueAttributeNameCreatedtimestamp
  QueueAttributeNameDeduplicationscope
  QueueAttributeNameDelayseconds
  QueueAttributeNameFifoqueue
  QueueAttributeNameFifothroughputlimit
  QueueAttributeNameKmsdatakeyreuseperiodseconds
  QueueAttributeNameKmsmasterkeyid
  QueueAttributeNameLastmodifiedtimestamp
  QueueAttributeNameMaximummessagesize
  QueueAttributeNameMessageretentionperiod
  QueueAttributeNamePolicy
  QueueAttributeNameQueuearn
  QueueAttributeNameReceivemessagewaittimeseconds
  QueueAttributeNameRedriveallowpolicy
  QueueAttributeNameRedrivepolicy
  QueueAttributeNameSqsmanagedsseenabled
  QueueAttributeNameVisibilitytimeout
}

Constructors 

  • QueueAttributeNameAll
  • QueueAttributeNameApproximatenumberofmessages
  • QueueAttributeNameApproximatenumberofmessagesdelayed
  • QueueAttributeNameApproximatenumberofmessagesnotvisible
  • QueueAttributeNameContentbaseddeduplication
  • QueueAttributeNameCreatedtimestamp
  • QueueAttributeNameDeduplicationscope
  • QueueAttributeNameDelayseconds
  • QueueAttributeNameFifoqueue
  • QueueAttributeNameFifothroughputlimit
  • QueueAttributeNameKmsdatakeyreuseperiodseconds
  • QueueAttributeNameKmsmasterkeyid
  • QueueAttributeNameLastmodifiedtimestamp
  • QueueAttributeNameMaximummessagesize
  • QueueAttributeNameMessageretentionperiod
  • QueueAttributeNamePolicy
  • QueueAttributeNameQueuearn
  • QueueAttributeNameReceivemessagewaittimeseconds
  • QueueAttributeNameRedriveallowpolicy
  • QueueAttributeNameRedrivepolicy
  • QueueAttributeNameSqsmanagedsseenabled
  • QueueAttributeNameVisibilitytimeout

QueueDeletedRecently

</> 
pub type QueueDeletedRecently {
  QueueDeletedRecently(message: option.Option(String))
}

Constructors

QueueDoesNotExist

</> 
pub type QueueDoesNotExist {
  QueueDoesNotExist(message: option.Option(String))
}

Constructors

QueueNameExists

</> 
pub type QueueNameExists {
  QueueNameExists(message: option.Option(String))
}

Constructors

ReceiptHandleIsInvalid

</> 
pub type ReceiptHandleIsInvalid {
  ReceiptHandleIsInvalid(message: option.Option(String))
}

Constructors

ReceiveMessageError

</> 
pub type ReceiveMessageError {
  ReceiveMessageErrorInvalidAddress(value: InvalidAddress)
  ReceiveMessageErrorInvalidSecurity(value: InvalidSecurity)
  ReceiveMessageErrorKmsAccessDenied(value: KmsAccessDenied)
  ReceiveMessageErrorKmsDisabled(value: KmsDisabled)
  ReceiveMessageErrorKmsInvalidKeyUsage(
    value: KmsInvalidKeyUsage,
  )
  ReceiveMessageErrorKmsInvalidState(value: KmsInvalidState)
  ReceiveMessageErrorKmsNotFound(value: KmsNotFound)
  ReceiveMessageErrorKmsOptInRequired(value: KmsOptInRequired)
  ReceiveMessageErrorKmsThrottled(value: KmsThrottled)
  ReceiveMessageErrorOverLimit(value: OverLimit)
  ReceiveMessageErrorQueueDoesNotExist(value: QueueDoesNotExist)
  ReceiveMessageErrorRequestThrottled(value: RequestThrottled)
  ReceiveMessageErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  ReceiveMessageErrorTransport(reason: String)
  ReceiveMessageErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

ReceiveMessageRequest

</> 
pub type ReceiveMessageRequest {
  ReceiveMessageRequest(
    attribute_names: option.Option(List(QueueAttributeName)),
    max_number_of_messages: option.Option(Int),
    message_attribute_names: option.Option(List(String)),
    message_system_attribute_names: option.Option(
      List(MessageSystemAttributeName),
    ),
    queue_url: option.Option(String),
    receive_request_attempt_id: option.Option(String),
    visibility_timeout: option.Option(Int),
    wait_time_seconds: option.Option(Int),
  )
}

Constructors

ReceiveMessageResult

</> 
pub type ReceiveMessageResult {
  ReceiveMessageResult(messages: option.Option(List(Message)))
}

Constructors

RemovePermissionError

</> 
pub type RemovePermissionError {
  RemovePermissionErrorInvalidAddress(value: InvalidAddress)
  RemovePermissionErrorInvalidSecurity(value: InvalidSecurity)
  RemovePermissionErrorQueueDoesNotExist(
    value: QueueDoesNotExist,
  )
  RemovePermissionErrorRequestThrottled(value: RequestThrottled)
  RemovePermissionErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  RemovePermissionErrorTransport(reason: String)
  RemovePermissionErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • RemovePermissionErrorInvalidAddress(value: InvalidAddress)
  • RemovePermissionErrorInvalidSecurity(value: InvalidSecurity)
  • RemovePermissionErrorQueueDoesNotExist(value: QueueDoesNotExist)
  • RemovePermissionErrorRequestThrottled(value: RequestThrottled)
  • RemovePermissionErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • RemovePermissionErrorTransport(reason: String)
  • RemovePermissionErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

RemovePermissionOutput

</> 
pub type RemovePermissionOutput {
  RemovePermissionOutput
}

Constructors 

  • RemovePermissionOutput

RemovePermissionRequest

</> 
pub type RemovePermissionRequest {
  RemovePermissionRequest(
    label: option.Option(String),
    queue_url: option.Option(String),
  )
}

Constructors

RequestThrottled

</> 
pub type RequestThrottled {
  RequestThrottled(message: option.Option(String))
}

Constructors

ResourceNotFoundException

</> 
pub type ResourceNotFoundException {
  ResourceNotFoundException(message: option.Option(String))
}

Constructors

SendMessageBatchError

</> 
pub type SendMessageBatchError {
  SendMessageBatchErrorBatchEntryIdsNotDistinct(
    value: BatchEntryIdsNotDistinct,
  )
  SendMessageBatchErrorBatchRequestTooLong(
    value: BatchRequestTooLong,
  )
  SendMessageBatchErrorEmptyBatchRequest(
    value: EmptyBatchRequest,
  )
  SendMessageBatchErrorInvalidAddress(value: InvalidAddress)
  SendMessageBatchErrorInvalidBatchEntryId(
    value: InvalidBatchEntryId,
  )
  SendMessageBatchErrorInvalidSecurity(value: InvalidSecurity)
  SendMessageBatchErrorKmsAccessDenied(value: KmsAccessDenied)
  SendMessageBatchErrorKmsDisabled(value: KmsDisabled)
  SendMessageBatchErrorKmsInvalidKeyUsage(
    value: KmsInvalidKeyUsage,
  )
  SendMessageBatchErrorKmsInvalidState(value: KmsInvalidState)
  SendMessageBatchErrorKmsNotFound(value: KmsNotFound)
  SendMessageBatchErrorKmsOptInRequired(value: KmsOptInRequired)
  SendMessageBatchErrorKmsThrottled(value: KmsThrottled)
  SendMessageBatchErrorQueueDoesNotExist(
    value: QueueDoesNotExist,
  )
  SendMessageBatchErrorRequestThrottled(value: RequestThrottled)
  SendMessageBatchErrorTooManyEntriesInBatchRequest(
    value: TooManyEntriesInBatchRequest,
  )
  SendMessageBatchErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  SendMessageBatchErrorTransport(reason: String)
  SendMessageBatchErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

SendMessageBatchRequest

</> 
pub type SendMessageBatchRequest {
  SendMessageBatchRequest(
    entries: option.Option(List(SendMessageBatchRequestEntry)),
    queue_url: option.Option(String),
  )
}

Constructors

SendMessageBatchRequestEntry

</> 
pub type SendMessageBatchRequestEntry {
  SendMessageBatchRequestEntry(
    delay_seconds: option.Option(Int),
    id: option.Option(String),
    message_attributes: option.Option(
      dict.Dict(String, MessageAttributeValue),
    ),
    message_body: option.Option(String),
    message_deduplication_id: option.Option(String),
    message_group_id: option.Option(String),
    message_system_attributes: option.Option(
      dict.Dict(String, MessageSystemAttributeValue),
    ),
  )
}

Constructors

SendMessageBatchResult

</> 
pub type SendMessageBatchResult {
  SendMessageBatchResult(
    failed: option.Option(List(BatchResultErrorEntry)),
    successful: option.Option(List(SendMessageBatchResultEntry)),
  )
}

Constructors

SendMessageBatchResultEntry

</> 
pub type SendMessageBatchResultEntry {
  SendMessageBatchResultEntry(
    id: option.Option(String),
    md5_of_message_attributes: option.Option(String),
    md5_of_message_body: option.Option(String),
    md5_of_message_system_attributes: option.Option(String),
    message_id: option.Option(String),
    sequence_number: option.Option(String),
  )
}

Constructors

SendMessageError

</> 
pub type SendMessageError {
  SendMessageErrorInvalidAddress(value: InvalidAddress)
  SendMessageErrorInvalidMessageContents(
    value: InvalidMessageContents,
  )
  SendMessageErrorInvalidSecurity(value: InvalidSecurity)
  SendMessageErrorKmsAccessDenied(value: KmsAccessDenied)
  SendMessageErrorKmsDisabled(value: KmsDisabled)
  SendMessageErrorKmsInvalidKeyUsage(value: KmsInvalidKeyUsage)
  SendMessageErrorKmsInvalidState(value: KmsInvalidState)
  SendMessageErrorKmsNotFound(value: KmsNotFound)
  SendMessageErrorKmsOptInRequired(value: KmsOptInRequired)
  SendMessageErrorKmsThrottled(value: KmsThrottled)
  SendMessageErrorQueueDoesNotExist(value: QueueDoesNotExist)
  SendMessageErrorRequestThrottled(value: RequestThrottled)
  SendMessageErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  SendMessageErrorTransport(reason: String)
  SendMessageErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

SendMessageRequest

</> 
pub type SendMessageRequest {
  SendMessageRequest(
    delay_seconds: option.Option(Int),
    message_attributes: option.Option(
      dict.Dict(String, MessageAttributeValue),
    ),
    message_body: option.Option(String),
    message_deduplication_id: option.Option(String),
    message_group_id: option.Option(String),
    message_system_attributes: option.Option(
      dict.Dict(String, MessageSystemAttributeValue),
    ),
    queue_url: option.Option(String),
  )
}

Constructors

SendMessageResult

</> 
pub type SendMessageResult {
  SendMessageResult(
    md5_of_message_attributes: option.Option(String),
    md5_of_message_body: option.Option(String),
    md5_of_message_system_attributes: option.Option(String),
    message_id: option.Option(String),
    sequence_number: option.Option(String),
  )
}

Constructors

SetQueueAttributesError

</> 
pub type SetQueueAttributesError {
  SetQueueAttributesErrorInvalidAddress(value: InvalidAddress)
  SetQueueAttributesErrorInvalidAttributeName(
    value: InvalidAttributeName,
  )
  SetQueueAttributesErrorInvalidAttributeValue(
    value: InvalidAttributeValue,
  )
  SetQueueAttributesErrorInvalidSecurity(value: InvalidSecurity)
  SetQueueAttributesErrorOverLimit(value: OverLimit)
  SetQueueAttributesErrorQueueDoesNotExist(
    value: QueueDoesNotExist,
  )
  SetQueueAttributesErrorRequestThrottled(
    value: RequestThrottled,
  )
  SetQueueAttributesErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  SetQueueAttributesErrorTransport(reason: String)
  SetQueueAttributesErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • SetQueueAttributesErrorInvalidAddress(value: InvalidAddress)
  • SetQueueAttributesErrorInvalidAttributeName(
  value: InvalidAttributeName,
)
  • SetQueueAttributesErrorInvalidAttributeValue(
  value: InvalidAttributeValue,
)
  • SetQueueAttributesErrorInvalidSecurity(value: InvalidSecurity)
  • SetQueueAttributesErrorOverLimit(value: OverLimit)
  • SetQueueAttributesErrorQueueDoesNotExist(
  value: QueueDoesNotExist,
)
  • SetQueueAttributesErrorRequestThrottled(value: RequestThrottled)
  • SetQueueAttributesErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • SetQueueAttributesErrorTransport(reason: String)
  • SetQueueAttributesErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

SetQueueAttributesOutput

</> 
pub type SetQueueAttributesOutput {
  SetQueueAttributesOutput
}

Constructors 

  • SetQueueAttributesOutput

SetQueueAttributesRequest

</> 
pub type SetQueueAttributesRequest {
  SetQueueAttributesRequest(
    attributes: option.Option(dict.Dict(String, String)),
    queue_url: option.Option(String),
  )
}

Constructors

StartMessageMoveTaskError

</> 
pub type StartMessageMoveTaskError {
  StartMessageMoveTaskErrorInvalidAddress(value: InvalidAddress)
  StartMessageMoveTaskErrorInvalidSecurity(
    value: InvalidSecurity,
  )
  StartMessageMoveTaskErrorRequestThrottled(
    value: RequestThrottled,
  )
  StartMessageMoveTaskErrorResourceNotFoundException(
    value: ResourceNotFoundException,
  )
  StartMessageMoveTaskErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  StartMessageMoveTaskErrorTransport(reason: String)
  StartMessageMoveTaskErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors 

  • StartMessageMoveTaskErrorInvalidAddress(value: InvalidAddress)
  • StartMessageMoveTaskErrorInvalidSecurity(value: InvalidSecurity)
  • StartMessageMoveTaskErrorRequestThrottled(
  value: RequestThrottled,
)
  • StartMessageMoveTaskErrorResourceNotFoundException(
  value: ResourceNotFoundException,
)
  • StartMessageMoveTaskErrorUnsupportedOperation(
  value: UnsupportedOperation,
)
  • StartMessageMoveTaskErrorTransport(reason: String)
  • StartMessageMoveTaskErrorUnknown(
  error_type: String,
  status: Int,
  body: String,
)

StartMessageMoveTaskRequest

</> 
pub type StartMessageMoveTaskRequest {
  StartMessageMoveTaskRequest(
    destination_arn: option.Option(String),
    max_number_of_messages_per_second: option.Option(Int),
    source_arn: option.Option(String),
  )
}

Constructors

StartMessageMoveTaskResult

</> 
pub type StartMessageMoveTaskResult {
  StartMessageMoveTaskResult(task_handle: option.Option(String))
}

Constructors

TagQueueError

</> 
pub type TagQueueError {
  TagQueueErrorInvalidAddress(value: InvalidAddress)
  TagQueueErrorInvalidSecurity(value: InvalidSecurity)
  TagQueueErrorQueueDoesNotExist(value: QueueDoesNotExist)
  TagQueueErrorRequestThrottled(value: RequestThrottled)
  TagQueueErrorUnsupportedOperation(value: UnsupportedOperation)
  TagQueueErrorTransport(reason: String)
  TagQueueErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

TagQueueOutput

</> 
pub type TagQueueOutput {
  TagQueueOutput
}

Constructors 

  • TagQueueOutput

TagQueueRequest

</> 
pub type TagQueueRequest {
  TagQueueRequest(
    queue_url: option.Option(String),
    tags: option.Option(dict.Dict(String, String)),
  )
}

Constructors

TooManyEntriesInBatchRequest

</> 
pub type TooManyEntriesInBatchRequest {
  TooManyEntriesInBatchRequest(message: option.Option(String))
}

Constructors

UnsupportedOperation

</> 
pub type UnsupportedOperation {
  UnsupportedOperation(message: option.Option(String))
}

Constructors

UntagQueueError

</> 
pub type UntagQueueError {
  UntagQueueErrorInvalidAddress(value: InvalidAddress)
  UntagQueueErrorInvalidSecurity(value: InvalidSecurity)
  UntagQueueErrorQueueDoesNotExist(value: QueueDoesNotExist)
  UntagQueueErrorRequestThrottled(value: RequestThrottled)
  UntagQueueErrorUnsupportedOperation(
    value: UnsupportedOperation,
  )
  UntagQueueErrorTransport(reason: String)
  UntagQueueErrorUnknown(
    error_type: String,
    status: Int,
    body: String,
  )
}

Constructors

UntagQueueOutput

</> 
pub type UntagQueueOutput {
  UntagQueueOutput
}

Constructors 

  • UntagQueueOutput

UntagQueueRequest

</> 
pub type UntagQueueRequest {
  UntagQueueRequest(
    queue_url: option.Option(String),
    tag_keys: option.Option(List(String)),
  )
}

Constructors

Values

add_permission

</> 
pub fn add_permission(
  client: Client,
  input: AddPermissionRequest,
) -> Result(AddPermissionOutput, AddPermissionError)

Invoke AddPermission. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed AddPermissionError variants; transport, decode, and credentials failures all collapse into the generic AddPermissionErrorTransport variant.

build_add_permission_request

</> 
pub fn build_add_permission_request(
  input: AddPermissionRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_cancel_message_move_task_request

</> 
pub fn build_cancel_message_move_task_request(
  input: CancelMessageMoveTaskRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_change_message_visibility_batch_request

</> 
pub fn build_change_message_visibility_batch_request(
  input: ChangeMessageVisibilityBatchRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_change_message_visibility_request

</> 
pub fn build_change_message_visibility_request(
  input: ChangeMessageVisibilityRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_create_queue_request

</> 
pub fn build_create_queue_request(
  input: CreateQueueRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_delete_message_batch_request

</> 
pub fn build_delete_message_batch_request(
  input: DeleteMessageBatchRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_delete_message_request

</> 
pub fn build_delete_message_request(
  input: DeleteMessageRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_delete_queue_request

</> 
pub fn build_delete_queue_request(
  input: DeleteQueueRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_get_queue_attributes_request

</> 
pub fn build_get_queue_attributes_request(
  input: GetQueueAttributesRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_get_queue_url_request

</> 
pub fn build_get_queue_url_request(
  input: GetQueueUrlRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_list_dead_letter_source_queues_request

</> 
pub fn build_list_dead_letter_source_queues_request(
  input: ListDeadLetterSourceQueuesRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_list_message_move_tasks_request

</> 
pub fn build_list_message_move_tasks_request(
  input: ListMessageMoveTasksRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_list_queue_tags_request

</> 
pub fn build_list_queue_tags_request(
  input: ListQueueTagsRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_list_queues_request

</> 
pub fn build_list_queues_request(
  input: ListQueuesRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_purge_queue_request

</> 
pub fn build_purge_queue_request(
  input: PurgeQueueRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_receive_message_request

</> 
pub fn build_receive_message_request(
  input: ReceiveMessageRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_remove_permission_request

</> 
pub fn build_remove_permission_request(
  input: RemovePermissionRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_send_message_batch_request

</> 
pub fn build_send_message_batch_request(
  input: SendMessageBatchRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_send_message_request

</> 
pub fn build_send_message_request(
  input: SendMessageRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_set_queue_attributes_request

</> 
pub fn build_set_queue_attributes_request(
  input: SetQueueAttributesRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_start_message_move_task_request

</> 
pub fn build_start_message_move_task_request(
  input: StartMessageMoveTaskRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_tag_queue_request

</> 
pub fn build_tag_queue_request(
  input: TagQueueRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

build_untag_queue_request

</> 
pub fn build_untag_queue_request(
  input: UntagQueueRequest,
) -> #(String, String, dict.Dict(String, String), BitArray)

cancel_message_move_task

</> 
pub fn cancel_message_move_task(
  client: Client,
  input: CancelMessageMoveTaskRequest,
) -> Result(
  CancelMessageMoveTaskResult,
  CancelMessageMoveTaskError,
)

Invoke CancelMessageMoveTask. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed CancelMessageMoveTaskError variants; transport, decode, and credentials failures all collapse into the generic CancelMessageMoveTaskErrorTransport variant.

change_message_visibility

</> 
pub fn change_message_visibility(
  client: Client,
  input: ChangeMessageVisibilityRequest,
) -> Result(
  ChangeMessageVisibilityOutput,
  ChangeMessageVisibilityError,
)

Invoke ChangeMessageVisibility. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed ChangeMessageVisibilityError variants; transport, decode, and credentials failures all collapse into the generic ChangeMessageVisibilityErrorTransport variant.

change_message_visibility_batch

</> 
pub fn change_message_visibility_batch(
  client: Client,
  input: ChangeMessageVisibilityBatchRequest,
) -> Result(
  ChangeMessageVisibilityBatchResult,
  ChangeMessageVisibilityBatchError,
)

Invoke ChangeMessageVisibilityBatch. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed ChangeMessageVisibilityBatchError variants; transport, decode, and credentials failures all collapse into the generic ChangeMessageVisibilityBatchErrorTransport variant.

config

</> 
pub fn config(client: Client) -> runtime.ClientConfig

Read the underlying runtime.ClientConfig out of an existing Client. Use this when you want to dispatch a request through runtime.invoke / runtime.invoke_streaming directly — e.g. to build a service-specific streaming wrapper around a @streaming output operation that the per-op codegen hasn’t surfaced yet. The returned config is a value (Gleam records are immutable); callers cannot mutate the Client through it.

create_queue

</> 
pub fn create_queue(
  client: Client,
  input: CreateQueueRequest,
) -> Result(CreateQueueResult, CreateQueueError)

Invoke CreateQueue. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed CreateQueueError variants; transport, decode, and credentials failures all collapse into the generic CreateQueueErrorTransport variant.

decode_add_permission_output

</> 
pub fn decode_add_permission_output(
  body: String,
) -> Result(AddPermissionOutput, String)

decode_add_permission_output_struct

</> 
pub fn decode_add_permission_output_struct() -> decode.Decoder(
  AddPermissionOutput,
)

decode_add_permission_request_struct

</> 
pub fn decode_add_permission_request_struct() -> decode.Decoder(
  AddPermissionRequest,
)

decode_batch_entry_ids_not_distinct_struct

</> 
pub fn decode_batch_entry_ids_not_distinct_struct() -> decode.Decoder(
  BatchEntryIdsNotDistinct,
)

decode_batch_request_too_long_struct

</> 
pub fn decode_batch_request_too_long_struct() -> decode.Decoder(
  BatchRequestTooLong,
)

decode_batch_result_error_entry_struct

</> 
pub fn decode_batch_result_error_entry_struct() -> decode.Decoder(
  BatchResultErrorEntry,
)

decode_cancel_message_move_task_output

</> 
pub fn decode_cancel_message_move_task_output(
  body: String,
) -> Result(CancelMessageMoveTaskResult, String)

decode_cancel_message_move_task_request_struct

</> 
pub fn decode_cancel_message_move_task_request_struct() -> decode.Decoder(
  CancelMessageMoveTaskRequest,
)

decode_cancel_message_move_task_result_struct

</> 
pub fn decode_cancel_message_move_task_result_struct() -> decode.Decoder(
  CancelMessageMoveTaskResult,
)

decode_change_message_visibility_batch_output

</> 
pub fn decode_change_message_visibility_batch_output(
  body: String,
) -> Result(ChangeMessageVisibilityBatchResult, String)

decode_change_message_visibility_batch_request_entry_struct

</> 
pub fn decode_change_message_visibility_batch_request_entry_struct() -> decode.Decoder(
  ChangeMessageVisibilityBatchRequestEntry,
)

decode_change_message_visibility_batch_request_struct

</> 
pub fn decode_change_message_visibility_batch_request_struct() -> decode.Decoder(
  ChangeMessageVisibilityBatchRequest,
)

decode_change_message_visibility_batch_result_entry_struct

</> 
pub fn decode_change_message_visibility_batch_result_entry_struct() -> decode.Decoder(
  ChangeMessageVisibilityBatchResultEntry,
)

decode_change_message_visibility_batch_result_struct

</> 
pub fn decode_change_message_visibility_batch_result_struct() -> decode.Decoder(
  ChangeMessageVisibilityBatchResult,
)

decode_change_message_visibility_output

</> 
pub fn decode_change_message_visibility_output(
  body: String,
) -> Result(ChangeMessageVisibilityOutput, String)

decode_change_message_visibility_output_struct

</> 
pub fn decode_change_message_visibility_output_struct() -> decode.Decoder(
  ChangeMessageVisibilityOutput,
)

decode_change_message_visibility_request_struct

</> 
pub fn decode_change_message_visibility_request_struct() -> decode.Decoder(
  ChangeMessageVisibilityRequest,
)

decode_create_queue_output

</> 
pub fn decode_create_queue_output(
  body: String,
) -> Result(CreateQueueResult, String)

decode_create_queue_request_struct

</> 
pub fn decode_create_queue_request_struct() -> decode.Decoder(
  CreateQueueRequest,
)

decode_create_queue_result_struct

</> 
pub fn decode_create_queue_result_struct() -> decode.Decoder(
  CreateQueueResult,
)

decode_delete_message_batch_output

</> 
pub fn decode_delete_message_batch_output(
  body: String,
) -> Result(DeleteMessageBatchResult, String)

decode_delete_message_batch_request_entry_struct

</> 
pub fn decode_delete_message_batch_request_entry_struct() -> decode.Decoder(
  DeleteMessageBatchRequestEntry,
)

decode_delete_message_batch_request_struct

</> 
pub fn decode_delete_message_batch_request_struct() -> decode.Decoder(
  DeleteMessageBatchRequest,
)

decode_delete_message_batch_result_entry_struct

</> 
pub fn decode_delete_message_batch_result_entry_struct() -> decode.Decoder(
  DeleteMessageBatchResultEntry,
)

decode_delete_message_batch_result_struct

</> 
pub fn decode_delete_message_batch_result_struct() -> decode.Decoder(
  DeleteMessageBatchResult,
)

decode_delete_message_output

</> 
pub fn decode_delete_message_output(
  body: String,
) -> Result(DeleteMessageOutput, String)

decode_delete_message_output_struct

</> 
pub fn decode_delete_message_output_struct() -> decode.Decoder(
  DeleteMessageOutput,
)

decode_delete_message_request_struct

</> 
pub fn decode_delete_message_request_struct() -> decode.Decoder(
  DeleteMessageRequest,
)

decode_delete_queue_output

</> 
pub fn decode_delete_queue_output(
  body: String,
) -> Result(DeleteQueueOutput, String)

decode_delete_queue_output_struct

</> 
pub fn decode_delete_queue_output_struct() -> decode.Decoder(
  DeleteQueueOutput,
)

decode_delete_queue_request_struct

</> 
pub fn decode_delete_queue_request_struct() -> decode.Decoder(
  DeleteQueueRequest,
)

decode_empty_batch_request_struct

</> 
pub fn decode_empty_batch_request_struct() -> decode.Decoder(
  EmptyBatchRequest,
)

decode_get_queue_attributes_output

</> 
pub fn decode_get_queue_attributes_output(
  body: String,
) -> Result(GetQueueAttributesResult, String)

decode_get_queue_attributes_request_struct

</> 
pub fn decode_get_queue_attributes_request_struct() -> decode.Decoder(
  GetQueueAttributesRequest,
)

decode_get_queue_attributes_result_struct

</> 
pub fn decode_get_queue_attributes_result_struct() -> decode.Decoder(
  GetQueueAttributesResult,
)

decode_get_queue_url_output

</> 
pub fn decode_get_queue_url_output(
  body: String,
) -> Result(GetQueueUrlResult, String)

decode_get_queue_url_request_struct

</> 
pub fn decode_get_queue_url_request_struct() -> decode.Decoder(
  GetQueueUrlRequest,
)

decode_get_queue_url_result_struct

</> 
pub fn decode_get_queue_url_result_struct() -> decode.Decoder(
  GetQueueUrlResult,
)

decode_invalid_address_struct

</> 
pub fn decode_invalid_address_struct() -> decode.Decoder(
  InvalidAddress,
)

decode_invalid_attribute_name_struct

</> 
pub fn decode_invalid_attribute_name_struct() -> decode.Decoder(
  InvalidAttributeName,
)

decode_invalid_attribute_value_struct

</> 
pub fn decode_invalid_attribute_value_struct() -> decode.Decoder(
  InvalidAttributeValue,
)

decode_invalid_batch_entry_id_struct

</> 
pub fn decode_invalid_batch_entry_id_struct() -> decode.Decoder(
  InvalidBatchEntryId,
)

decode_invalid_id_format_struct

</> 
pub fn decode_invalid_id_format_struct() -> decode.Decoder(
  InvalidIdFormat,
)

decode_invalid_message_contents_struct

</> 
pub fn decode_invalid_message_contents_struct() -> decode.Decoder(
  InvalidMessageContents,
)

decode_invalid_security_struct

</> 
pub fn decode_invalid_security_struct() -> decode.Decoder(
  InvalidSecurity,
)

decode_kms_access_denied_struct

</> 
pub fn decode_kms_access_denied_struct() -> decode.Decoder(
  KmsAccessDenied,
)

decode_kms_disabled_struct

</> 
pub fn decode_kms_disabled_struct() -> decode.Decoder(KmsDisabled)

decode_kms_invalid_key_usage_struct

</> 
pub fn decode_kms_invalid_key_usage_struct() -> decode.Decoder(
  KmsInvalidKeyUsage,
)

decode_kms_invalid_state_struct

</> 
pub fn decode_kms_invalid_state_struct() -> decode.Decoder(
  KmsInvalidState,
)

decode_kms_not_found_struct

</> 
pub fn decode_kms_not_found_struct() -> decode.Decoder(
  KmsNotFound,
)

decode_kms_opt_in_required_struct

</> 
pub fn decode_kms_opt_in_required_struct() -> decode.Decoder(
  KmsOptInRequired,
)

decode_kms_throttled_struct

</> 
pub fn decode_kms_throttled_struct() -> decode.Decoder(
  KmsThrottled,
)

decode_list_dead_letter_source_queues_output

</> 
pub fn decode_list_dead_letter_source_queues_output(
  body: String,
) -> Result(ListDeadLetterSourceQueuesResult, String)

decode_list_dead_letter_source_queues_request_struct

</> 
pub fn decode_list_dead_letter_source_queues_request_struct() -> decode.Decoder(
  ListDeadLetterSourceQueuesRequest,
)

decode_list_dead_letter_source_queues_result_struct

</> 
pub fn decode_list_dead_letter_source_queues_result_struct() -> decode.Decoder(
  ListDeadLetterSourceQueuesResult,
)

decode_list_message_move_tasks_output

</> 
pub fn decode_list_message_move_tasks_output(
  body: String,
) -> Result(ListMessageMoveTasksResult, String)

decode_list_message_move_tasks_request_struct

</> 
pub fn decode_list_message_move_tasks_request_struct() -> decode.Decoder(
  ListMessageMoveTasksRequest,
)

decode_list_message_move_tasks_result_entry_struct

</> 
pub fn decode_list_message_move_tasks_result_entry_struct() -> decode.Decoder(
  ListMessageMoveTasksResultEntry,
)

decode_list_message_move_tasks_result_struct

</> 
pub fn decode_list_message_move_tasks_result_struct() -> decode.Decoder(
  ListMessageMoveTasksResult,
)

decode_list_queue_tags_output

</> 
pub fn decode_list_queue_tags_output(
  body: String,
) -> Result(ListQueueTagsResult, String)

decode_list_queue_tags_request_struct

</> 
pub fn decode_list_queue_tags_request_struct() -> decode.Decoder(
  ListQueueTagsRequest,
)

decode_list_queue_tags_result_struct

</> 
pub fn decode_list_queue_tags_result_struct() -> decode.Decoder(
  ListQueueTagsResult,
)

decode_list_queues_output

</> 
pub fn decode_list_queues_output(
  body: String,
) -> Result(ListQueuesResult, String)

decode_list_queues_request_struct

</> 
pub fn decode_list_queues_request_struct() -> decode.Decoder(
  ListQueuesRequest,
)

decode_list_queues_result_struct

</> 
pub fn decode_list_queues_result_struct() -> decode.Decoder(
  ListQueuesResult,
)

decode_message_attribute_value_struct

</> 
pub fn decode_message_attribute_value_struct() -> decode.Decoder(
  MessageAttributeValue,
)

decode_message_not_inflight_struct

</> 
pub fn decode_message_not_inflight_struct() -> decode.Decoder(
  MessageNotInflight,
)

decode_message_struct

</> 
pub fn decode_message_struct() -> decode.Decoder(Message)

decode_message_system_attribute_name_enum

</> 
pub fn decode_message_system_attribute_name_enum() -> decode.Decoder(
  MessageSystemAttributeName,
)

decode_message_system_attribute_name_for_sends_enum

</> 
pub fn decode_message_system_attribute_name_for_sends_enum() -> decode.Decoder(
  MessageSystemAttributeNameForSends,
)

decode_message_system_attribute_value_struct

</> 
pub fn decode_message_system_attribute_value_struct() -> decode.Decoder(
  MessageSystemAttributeValue,
)

decode_over_limit_struct

</> 
pub fn decode_over_limit_struct() -> decode.Decoder(OverLimit)

decode_purge_queue_in_progress_struct

</> 
pub fn decode_purge_queue_in_progress_struct() -> decode.Decoder(
  PurgeQueueInProgress,
)

decode_purge_queue_output

</> 
pub fn decode_purge_queue_output(
  body: String,
) -> Result(PurgeQueueOutput, String)

decode_purge_queue_output_struct

</> 
pub fn decode_purge_queue_output_struct() -> decode.Decoder(
  PurgeQueueOutput,
)

decode_purge_queue_request_struct

</> 
pub fn decode_purge_queue_request_struct() -> decode.Decoder(
  PurgeQueueRequest,
)

decode_queue_attribute_name_enum

</> 
pub fn decode_queue_attribute_name_enum() -> decode.Decoder(
  QueueAttributeName,
)

decode_queue_deleted_recently_struct

</> 
pub fn decode_queue_deleted_recently_struct() -> decode.Decoder(
  QueueDeletedRecently,
)

decode_queue_does_not_exist_struct

</> 
pub fn decode_queue_does_not_exist_struct() -> decode.Decoder(
  QueueDoesNotExist,
)

decode_queue_name_exists_struct

</> 
pub fn decode_queue_name_exists_struct() -> decode.Decoder(
  QueueNameExists,
)

decode_receipt_handle_is_invalid_struct

</> 
pub fn decode_receipt_handle_is_invalid_struct() -> decode.Decoder(
  ReceiptHandleIsInvalid,
)

decode_receive_message_output

</> 
pub fn decode_receive_message_output(
  body: String,
) -> Result(ReceiveMessageResult, String)

decode_receive_message_request_struct

</> 
pub fn decode_receive_message_request_struct() -> decode.Decoder(
  ReceiveMessageRequest,
)

decode_receive_message_result_struct

</> 
pub fn decode_receive_message_result_struct() -> decode.Decoder(
  ReceiveMessageResult,
)

decode_remove_permission_output

</> 
pub fn decode_remove_permission_output(
  body: String,
) -> Result(RemovePermissionOutput, String)

decode_remove_permission_output_struct

</> 
pub fn decode_remove_permission_output_struct() -> decode.Decoder(
  RemovePermissionOutput,
)

decode_remove_permission_request_struct

</> 
pub fn decode_remove_permission_request_struct() -> decode.Decoder(
  RemovePermissionRequest,
)

decode_request_throttled_struct

</> 
pub fn decode_request_throttled_struct() -> decode.Decoder(
  RequestThrottled,
)

decode_resource_not_found_exception_struct

</> 
pub fn decode_resource_not_found_exception_struct() -> decode.Decoder(
  ResourceNotFoundException,
)

decode_send_message_batch_output

</> 
pub fn decode_send_message_batch_output(
  body: String,
) -> Result(SendMessageBatchResult, String)

decode_send_message_batch_request_entry_struct

</> 
pub fn decode_send_message_batch_request_entry_struct() -> decode.Decoder(
  SendMessageBatchRequestEntry,
)

decode_send_message_batch_request_struct

</> 
pub fn decode_send_message_batch_request_struct() -> decode.Decoder(
  SendMessageBatchRequest,
)

decode_send_message_batch_result_entry_struct

</> 
pub fn decode_send_message_batch_result_entry_struct() -> decode.Decoder(
  SendMessageBatchResultEntry,
)

decode_send_message_batch_result_struct

</> 
pub fn decode_send_message_batch_result_struct() -> decode.Decoder(
  SendMessageBatchResult,
)

decode_send_message_output

</> 
pub fn decode_send_message_output(
  body: String,
) -> Result(SendMessageResult, String)

decode_send_message_request_struct

</> 
pub fn decode_send_message_request_struct() -> decode.Decoder(
  SendMessageRequest,
)

decode_send_message_result_struct

</> 
pub fn decode_send_message_result_struct() -> decode.Decoder(
  SendMessageResult,
)

decode_set_queue_attributes_output

</> 
pub fn decode_set_queue_attributes_output(
  body: String,
) -> Result(SetQueueAttributesOutput, String)

decode_set_queue_attributes_output_struct

</> 
pub fn decode_set_queue_attributes_output_struct() -> decode.Decoder(
  SetQueueAttributesOutput,
)

decode_set_queue_attributes_request_struct

</> 
pub fn decode_set_queue_attributes_request_struct() -> decode.Decoder(
  SetQueueAttributesRequest,
)

decode_start_message_move_task_output

</> 
pub fn decode_start_message_move_task_output(
  body: String,
) -> Result(StartMessageMoveTaskResult, String)

decode_start_message_move_task_request_struct

</> 
pub fn decode_start_message_move_task_request_struct() -> decode.Decoder(
  StartMessageMoveTaskRequest,
)

decode_start_message_move_task_result_struct

</> 
pub fn decode_start_message_move_task_result_struct() -> decode.Decoder(
  StartMessageMoveTaskResult,
)

decode_tag_queue_output

</> 
pub fn decode_tag_queue_output(
  body: String,
) -> Result(TagQueueOutput, String)

decode_tag_queue_output_struct

</> 
pub fn decode_tag_queue_output_struct() -> decode.Decoder(
  TagQueueOutput,
)

decode_tag_queue_request_struct

</> 
pub fn decode_tag_queue_request_struct() -> decode.Decoder(
  TagQueueRequest,
)

decode_too_many_entries_in_batch_request_struct

</> 
pub fn decode_too_many_entries_in_batch_request_struct() -> decode.Decoder(
  TooManyEntriesInBatchRequest,
)

decode_unsupported_operation_struct

</> 
pub fn decode_unsupported_operation_struct() -> decode.Decoder(
  UnsupportedOperation,
)

decode_untag_queue_output

</> 
pub fn decode_untag_queue_output(
  body: String,
) -> Result(UntagQueueOutput, String)

decode_untag_queue_output_struct

</> 
pub fn decode_untag_queue_output_struct() -> decode.Decoder(
  UntagQueueOutput,
)

decode_untag_queue_request_struct

</> 
pub fn decode_untag_queue_request_struct() -> decode.Decoder(
  UntagQueueRequest,
)

delete_message

</> 
pub fn delete_message(
  client: Client,
  input: DeleteMessageRequest,
) -> Result(DeleteMessageOutput, DeleteMessageError)

Invoke DeleteMessage. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed DeleteMessageError variants; transport, decode, and credentials failures all collapse into the generic DeleteMessageErrorTransport variant.

delete_message_batch

</> 
pub fn delete_message_batch(
  client: Client,
  input: DeleteMessageBatchRequest,
) -> Result(DeleteMessageBatchResult, DeleteMessageBatchError)

Invoke DeleteMessageBatch. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed DeleteMessageBatchError variants; transport, decode, and credentials failures all collapse into the generic DeleteMessageBatchErrorTransport variant.

delete_queue

</> 
pub fn delete_queue(
  client: Client,
  input: DeleteQueueRequest,
) -> Result(DeleteQueueOutput, DeleteQueueError)

Invoke DeleteQueue. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed DeleteQueueError variants; transport, decode, and credentials failures all collapse into the generic DeleteQueueErrorTransport variant.

encode_add_permission_input

</> 
pub fn encode_add_permission_input(
  input: AddPermissionRequest,
) -> String

encode_add_permission_request_struct

</> 
pub fn encode_add_permission_request_struct(
  input: AddPermissionRequest,
) -> json.Json

encode_add_permission_request_struct_top

</> 
pub fn encode_add_permission_request_struct_top(
  input: AddPermissionRequest,
) -> json.Json

encode_batch_entry_ids_not_distinct_struct

</> 
pub fn encode_batch_entry_ids_not_distinct_struct(
  input: BatchEntryIdsNotDistinct,
) -> json.Json

encode_batch_entry_ids_not_distinct_struct_top

</> 
pub fn encode_batch_entry_ids_not_distinct_struct_top(
  input: BatchEntryIdsNotDistinct,
) -> json.Json

encode_batch_request_too_long_struct

</> 
pub fn encode_batch_request_too_long_struct(
  input: BatchRequestTooLong,
) -> json.Json

encode_batch_request_too_long_struct_top

</> 
pub fn encode_batch_request_too_long_struct_top(
  input: BatchRequestTooLong,
) -> json.Json

encode_batch_result_error_entry_struct

</> 
pub fn encode_batch_result_error_entry_struct(
  input: BatchResultErrorEntry,
) -> json.Json

encode_batch_result_error_entry_struct_top

</> 
pub fn encode_batch_result_error_entry_struct_top(
  input: BatchResultErrorEntry,
) -> json.Json

encode_cancel_message_move_task_input

</> 
pub fn encode_cancel_message_move_task_input(
  input: CancelMessageMoveTaskRequest,
) -> String

encode_cancel_message_move_task_request_struct

</> 
pub fn encode_cancel_message_move_task_request_struct(
  input: CancelMessageMoveTaskRequest,
) -> json.Json

encode_cancel_message_move_task_request_struct_top

</> 
pub fn encode_cancel_message_move_task_request_struct_top(
  input: CancelMessageMoveTaskRequest,
) -> json.Json

encode_cancel_message_move_task_result_struct

</> 
pub fn encode_cancel_message_move_task_result_struct(
  input: CancelMessageMoveTaskResult,
) -> json.Json

encode_cancel_message_move_task_result_struct_top

</> 
pub fn encode_cancel_message_move_task_result_struct_top(
  input: CancelMessageMoveTaskResult,
) -> json.Json

encode_change_message_visibility_batch_input

</> 
pub fn encode_change_message_visibility_batch_input(
  input: ChangeMessageVisibilityBatchRequest,
) -> String

encode_change_message_visibility_batch_request_entry_struct

</> 
pub fn encode_change_message_visibility_batch_request_entry_struct(
  input: ChangeMessageVisibilityBatchRequestEntry,
) -> json.Json

encode_change_message_visibility_batch_request_entry_struct_top

</> 
pub fn encode_change_message_visibility_batch_request_entry_struct_top(
  input: ChangeMessageVisibilityBatchRequestEntry,
) -> json.Json

encode_change_message_visibility_batch_request_struct

</> 
pub fn encode_change_message_visibility_batch_request_struct(
  input: ChangeMessageVisibilityBatchRequest,
) -> json.Json

encode_change_message_visibility_batch_request_struct_top

</> 
pub fn encode_change_message_visibility_batch_request_struct_top(
  input: ChangeMessageVisibilityBatchRequest,
) -> json.Json

encode_change_message_visibility_batch_result_entry_struct

</> 
pub fn encode_change_message_visibility_batch_result_entry_struct(
  input: ChangeMessageVisibilityBatchResultEntry,
) -> json.Json

encode_change_message_visibility_batch_result_entry_struct_top

</> 
pub fn encode_change_message_visibility_batch_result_entry_struct_top(
  input: ChangeMessageVisibilityBatchResultEntry,
) -> json.Json

encode_change_message_visibility_batch_result_struct

</> 
pub fn encode_change_message_visibility_batch_result_struct(
  input: ChangeMessageVisibilityBatchResult,
) -> json.Json

encode_change_message_visibility_batch_result_struct_top

</> 
pub fn encode_change_message_visibility_batch_result_struct_top(
  input: ChangeMessageVisibilityBatchResult,
) -> json.Json

encode_change_message_visibility_input

</> 
pub fn encode_change_message_visibility_input(
  input: ChangeMessageVisibilityRequest,
) -> String

encode_change_message_visibility_request_struct

</> 
pub fn encode_change_message_visibility_request_struct(
  input: ChangeMessageVisibilityRequest,
) -> json.Json

encode_change_message_visibility_request_struct_top

</> 
pub fn encode_change_message_visibility_request_struct_top(
  input: ChangeMessageVisibilityRequest,
) -> json.Json

encode_create_queue_input

</> 
pub fn encode_create_queue_input(
  input: CreateQueueRequest,
) -> String

encode_create_queue_request_struct

</> 
pub fn encode_create_queue_request_struct(
  input: CreateQueueRequest,
) -> json.Json

encode_create_queue_request_struct_top

</> 
pub fn encode_create_queue_request_struct_top(
  input: CreateQueueRequest,
) -> json.Json

encode_create_queue_result_struct

</> 
pub fn encode_create_queue_result_struct(
  input: CreateQueueResult,
) -> json.Json

encode_create_queue_result_struct_top

</> 
pub fn encode_create_queue_result_struct_top(
  input: CreateQueueResult,
) -> json.Json

encode_delete_message_batch_input

</> 
pub fn encode_delete_message_batch_input(
  input: DeleteMessageBatchRequest,
) -> String

encode_delete_message_batch_request_entry_struct

</> 
pub fn encode_delete_message_batch_request_entry_struct(
  input: DeleteMessageBatchRequestEntry,
) -> json.Json

encode_delete_message_batch_request_entry_struct_top

</> 
pub fn encode_delete_message_batch_request_entry_struct_top(
  input: DeleteMessageBatchRequestEntry,
) -> json.Json

encode_delete_message_batch_request_struct

</> 
pub fn encode_delete_message_batch_request_struct(
  input: DeleteMessageBatchRequest,
) -> json.Json

encode_delete_message_batch_request_struct_top

</> 
pub fn encode_delete_message_batch_request_struct_top(
  input: DeleteMessageBatchRequest,
) -> json.Json

encode_delete_message_batch_result_entry_struct

</> 
pub fn encode_delete_message_batch_result_entry_struct(
  input: DeleteMessageBatchResultEntry,
) -> json.Json

encode_delete_message_batch_result_entry_struct_top

</> 
pub fn encode_delete_message_batch_result_entry_struct_top(
  input: DeleteMessageBatchResultEntry,
) -> json.Json

encode_delete_message_batch_result_struct

</> 
pub fn encode_delete_message_batch_result_struct(
  input: DeleteMessageBatchResult,
) -> json.Json

encode_delete_message_batch_result_struct_top

</> 
pub fn encode_delete_message_batch_result_struct_top(
  input: DeleteMessageBatchResult,
) -> json.Json

encode_delete_message_input

</> 
pub fn encode_delete_message_input(
  input: DeleteMessageRequest,
) -> String

encode_delete_message_request_struct

</> 
pub fn encode_delete_message_request_struct(
  input: DeleteMessageRequest,
) -> json.Json

encode_delete_message_request_struct_top

</> 
pub fn encode_delete_message_request_struct_top(
  input: DeleteMessageRequest,
) -> json.Json

encode_delete_queue_input

</> 
pub fn encode_delete_queue_input(
  input: DeleteQueueRequest,
) -> String

encode_delete_queue_request_struct

</> 
pub fn encode_delete_queue_request_struct(
  input: DeleteQueueRequest,
) -> json.Json

encode_delete_queue_request_struct_top

</> 
pub fn encode_delete_queue_request_struct_top(
  input: DeleteQueueRequest,
) -> json.Json

encode_empty_batch_request_struct

</> 
pub fn encode_empty_batch_request_struct(
  input: EmptyBatchRequest,
) -> json.Json

encode_empty_batch_request_struct_top

</> 
pub fn encode_empty_batch_request_struct_top(
  input: EmptyBatchRequest,
) -> json.Json

encode_get_queue_attributes_input

</> 
pub fn encode_get_queue_attributes_input(
  input: GetQueueAttributesRequest,
) -> String

encode_get_queue_attributes_request_struct

</> 
pub fn encode_get_queue_attributes_request_struct(
  input: GetQueueAttributesRequest,
) -> json.Json

encode_get_queue_attributes_request_struct_top

</> 
pub fn encode_get_queue_attributes_request_struct_top(
  input: GetQueueAttributesRequest,
) -> json.Json

encode_get_queue_attributes_result_struct

</> 
pub fn encode_get_queue_attributes_result_struct(
  input: GetQueueAttributesResult,
) -> json.Json

encode_get_queue_attributes_result_struct_top

</> 
pub fn encode_get_queue_attributes_result_struct_top(
  input: GetQueueAttributesResult,
) -> json.Json

encode_get_queue_url_input

</> 
pub fn encode_get_queue_url_input(
  input: GetQueueUrlRequest,
) -> String

encode_get_queue_url_request_struct

</> 
pub fn encode_get_queue_url_request_struct(
  input: GetQueueUrlRequest,
) -> json.Json

encode_get_queue_url_request_struct_top

</> 
pub fn encode_get_queue_url_request_struct_top(
  input: GetQueueUrlRequest,
) -> json.Json

encode_get_queue_url_result_struct

</> 
pub fn encode_get_queue_url_result_struct(
  input: GetQueueUrlResult,
) -> json.Json

encode_get_queue_url_result_struct_top

</> 
pub fn encode_get_queue_url_result_struct_top(
  input: GetQueueUrlResult,
) -> json.Json

encode_invalid_address_struct

</> 
pub fn encode_invalid_address_struct(
  input: InvalidAddress,
) -> json.Json

encode_invalid_address_struct_top

</> 
pub fn encode_invalid_address_struct_top(
  input: InvalidAddress,
) -> json.Json

encode_invalid_attribute_name_struct

</> 
pub fn encode_invalid_attribute_name_struct(
  input: InvalidAttributeName,
) -> json.Json

encode_invalid_attribute_name_struct_top

</> 
pub fn encode_invalid_attribute_name_struct_top(
  input: InvalidAttributeName,
) -> json.Json

encode_invalid_attribute_value_struct

</> 
pub fn encode_invalid_attribute_value_struct(
  input: InvalidAttributeValue,
) -> json.Json

encode_invalid_attribute_value_struct_top

</> 
pub fn encode_invalid_attribute_value_struct_top(
  input: InvalidAttributeValue,
) -> json.Json

encode_invalid_batch_entry_id_struct

</> 
pub fn encode_invalid_batch_entry_id_struct(
  input: InvalidBatchEntryId,
) -> json.Json

encode_invalid_batch_entry_id_struct_top

</> 
pub fn encode_invalid_batch_entry_id_struct_top(
  input: InvalidBatchEntryId,
) -> json.Json

encode_invalid_id_format_struct

</> 
pub fn encode_invalid_id_format_struct(
  v: InvalidIdFormat,
) -> json.Json

encode_invalid_id_format_struct_top

</> 
pub fn encode_invalid_id_format_struct_top(
  v: InvalidIdFormat,
) -> json.Json

encode_invalid_message_contents_struct

</> 
pub fn encode_invalid_message_contents_struct(
  input: InvalidMessageContents,
) -> json.Json

encode_invalid_message_contents_struct_top

</> 
pub fn encode_invalid_message_contents_struct_top(
  input: InvalidMessageContents,
) -> json.Json

encode_invalid_security_struct

</> 
pub fn encode_invalid_security_struct(
  input: InvalidSecurity,
) -> json.Json

encode_invalid_security_struct_top

</> 
pub fn encode_invalid_security_struct_top(
  input: InvalidSecurity,
) -> json.Json

encode_kms_access_denied_struct

</> 
pub fn encode_kms_access_denied_struct(
  input: KmsAccessDenied,
) -> json.Json

encode_kms_access_denied_struct_top

</> 
pub fn encode_kms_access_denied_struct_top(
  input: KmsAccessDenied,
) -> json.Json

encode_kms_disabled_struct

</> 
pub fn encode_kms_disabled_struct(
  input: KmsDisabled,
) -> json.Json

encode_kms_disabled_struct_top

</> 
pub fn encode_kms_disabled_struct_top(
  input: KmsDisabled,
) -> json.Json

encode_kms_invalid_key_usage_struct

</> 
pub fn encode_kms_invalid_key_usage_struct(
  input: KmsInvalidKeyUsage,
) -> json.Json

encode_kms_invalid_key_usage_struct_top

</> 
pub fn encode_kms_invalid_key_usage_struct_top(
  input: KmsInvalidKeyUsage,
) -> json.Json

encode_kms_invalid_state_struct

</> 
pub fn encode_kms_invalid_state_struct(
  input: KmsInvalidState,
) -> json.Json

encode_kms_invalid_state_struct_top

</> 
pub fn encode_kms_invalid_state_struct_top(
  input: KmsInvalidState,
) -> json.Json

encode_kms_not_found_struct

</> 
pub fn encode_kms_not_found_struct(
  input: KmsNotFound,
) -> json.Json

encode_kms_not_found_struct_top

</> 
pub fn encode_kms_not_found_struct_top(
  input: KmsNotFound,
) -> json.Json

encode_kms_opt_in_required_struct

</> 
pub fn encode_kms_opt_in_required_struct(
  input: KmsOptInRequired,
) -> json.Json

encode_kms_opt_in_required_struct_top

</> 
pub fn encode_kms_opt_in_required_struct_top(
  input: KmsOptInRequired,
) -> json.Json

encode_kms_throttled_struct

</> 
pub fn encode_kms_throttled_struct(
  input: KmsThrottled,
) -> json.Json

encode_kms_throttled_struct_top

</> 
pub fn encode_kms_throttled_struct_top(
  input: KmsThrottled,
) -> json.Json

encode_list_dead_letter_source_queues_input

</> 
pub fn encode_list_dead_letter_source_queues_input(
  input: ListDeadLetterSourceQueuesRequest,
) -> String

encode_list_dead_letter_source_queues_request_struct

</> 
pub fn encode_list_dead_letter_source_queues_request_struct(
  input: ListDeadLetterSourceQueuesRequest,
) -> json.Json

encode_list_dead_letter_source_queues_request_struct_top

</> 
pub fn encode_list_dead_letter_source_queues_request_struct_top(
  input: ListDeadLetterSourceQueuesRequest,
) -> json.Json

encode_list_dead_letter_source_queues_result_struct

</> 
pub fn encode_list_dead_letter_source_queues_result_struct(
  input: ListDeadLetterSourceQueuesResult,
) -> json.Json

encode_list_dead_letter_source_queues_result_struct_top

</> 
pub fn encode_list_dead_letter_source_queues_result_struct_top(
  input: ListDeadLetterSourceQueuesResult,
) -> json.Json

encode_list_message_move_tasks_input

</> 
pub fn encode_list_message_move_tasks_input(
  input: ListMessageMoveTasksRequest,
) -> String

encode_list_message_move_tasks_request_struct

</> 
pub fn encode_list_message_move_tasks_request_struct(
  input: ListMessageMoveTasksRequest,
) -> json.Json

encode_list_message_move_tasks_request_struct_top

</> 
pub fn encode_list_message_move_tasks_request_struct_top(
  input: ListMessageMoveTasksRequest,
) -> json.Json

encode_list_message_move_tasks_result_entry_struct

</> 
pub fn encode_list_message_move_tasks_result_entry_struct(
  input: ListMessageMoveTasksResultEntry,
) -> json.Json

encode_list_message_move_tasks_result_entry_struct_top

</> 
pub fn encode_list_message_move_tasks_result_entry_struct_top(
  input: ListMessageMoveTasksResultEntry,
) -> json.Json

encode_list_message_move_tasks_result_struct

</> 
pub fn encode_list_message_move_tasks_result_struct(
  input: ListMessageMoveTasksResult,
) -> json.Json

encode_list_message_move_tasks_result_struct_top

</> 
pub fn encode_list_message_move_tasks_result_struct_top(
  input: ListMessageMoveTasksResult,
) -> json.Json

encode_list_queue_tags_input

</> 
pub fn encode_list_queue_tags_input(
  input: ListQueueTagsRequest,
) -> String

encode_list_queue_tags_request_struct

</> 
pub fn encode_list_queue_tags_request_struct(
  input: ListQueueTagsRequest,
) -> json.Json

encode_list_queue_tags_request_struct_top

</> 
pub fn encode_list_queue_tags_request_struct_top(
  input: ListQueueTagsRequest,
) -> json.Json

encode_list_queue_tags_result_struct

</> 
pub fn encode_list_queue_tags_result_struct(
  input: ListQueueTagsResult,
) -> json.Json

encode_list_queue_tags_result_struct_top

</> 
pub fn encode_list_queue_tags_result_struct_top(
  input: ListQueueTagsResult,
) -> json.Json

encode_list_queues_input

</> 
pub fn encode_list_queues_input(
  input: ListQueuesRequest,
) -> String

encode_list_queues_request_struct

</> 
pub fn encode_list_queues_request_struct(
  input: ListQueuesRequest,
) -> json.Json

encode_list_queues_request_struct_top

</> 
pub fn encode_list_queues_request_struct_top(
  input: ListQueuesRequest,
) -> json.Json

encode_list_queues_result_struct

</> 
pub fn encode_list_queues_result_struct(
  input: ListQueuesResult,
) -> json.Json

encode_list_queues_result_struct_top

</> 
pub fn encode_list_queues_result_struct_top(
  input: ListQueuesResult,
) -> json.Json

encode_message_attribute_value_struct

</> 
pub fn encode_message_attribute_value_struct(
  input: MessageAttributeValue,
) -> json.Json

encode_message_attribute_value_struct_top

</> 
pub fn encode_message_attribute_value_struct_top(
  input: MessageAttributeValue,
) -> json.Json

encode_message_not_inflight_struct

</> 
pub fn encode_message_not_inflight_struct(
  v: MessageNotInflight,
) -> json.Json

encode_message_not_inflight_struct_top

</> 
pub fn encode_message_not_inflight_struct_top(
  v: MessageNotInflight,
) -> json.Json

encode_message_struct

</> 
pub fn encode_message_struct(input: Message) -> json.Json

encode_message_struct_top

</> 
pub fn encode_message_struct_top(input: Message) -> json.Json

encode_message_system_attribute_name_enum

</> 
pub fn encode_message_system_attribute_name_enum(
  v: MessageSystemAttributeName,
) -> json.Json

encode_message_system_attribute_name_for_sends_enum

</> 
pub fn encode_message_system_attribute_name_for_sends_enum(
  v: MessageSystemAttributeNameForSends,
) -> json.Json

encode_message_system_attribute_value_struct

</> 
pub fn encode_message_system_attribute_value_struct(
  input: MessageSystemAttributeValue,
) -> json.Json

encode_message_system_attribute_value_struct_top

</> 
pub fn encode_message_system_attribute_value_struct_top(
  input: MessageSystemAttributeValue,
) -> json.Json

encode_over_limit_struct

</> 
pub fn encode_over_limit_struct(input: OverLimit) -> json.Json

encode_over_limit_struct_top

</> 
pub fn encode_over_limit_struct_top(
  input: OverLimit,
) -> json.Json

encode_purge_queue_in_progress_struct

</> 
pub fn encode_purge_queue_in_progress_struct(
  input: PurgeQueueInProgress,
) -> json.Json

encode_purge_queue_in_progress_struct_top

</> 
pub fn encode_purge_queue_in_progress_struct_top(
  input: PurgeQueueInProgress,
) -> json.Json

encode_purge_queue_input

</> 
pub fn encode_purge_queue_input(
  input: PurgeQueueRequest,
) -> String

encode_purge_queue_request_struct

</> 
pub fn encode_purge_queue_request_struct(
  input: PurgeQueueRequest,
) -> json.Json

encode_purge_queue_request_struct_top

</> 
pub fn encode_purge_queue_request_struct_top(
  input: PurgeQueueRequest,
) -> json.Json

encode_queue_attribute_name_enum

</> 
pub fn encode_queue_attribute_name_enum(
  v: QueueAttributeName,
) -> json.Json

encode_queue_deleted_recently_struct

</> 
pub fn encode_queue_deleted_recently_struct(
  input: QueueDeletedRecently,
) -> json.Json

encode_queue_deleted_recently_struct_top

</> 
pub fn encode_queue_deleted_recently_struct_top(
  input: QueueDeletedRecently,
) -> json.Json

encode_queue_does_not_exist_struct

</> 
pub fn encode_queue_does_not_exist_struct(
  input: QueueDoesNotExist,
) -> json.Json

encode_queue_does_not_exist_struct_top

</> 
pub fn encode_queue_does_not_exist_struct_top(
  input: QueueDoesNotExist,
) -> json.Json

encode_queue_name_exists_struct

</> 
pub fn encode_queue_name_exists_struct(
  input: QueueNameExists,
) -> json.Json

encode_queue_name_exists_struct_top

</> 
pub fn encode_queue_name_exists_struct_top(
  input: QueueNameExists,
) -> json.Json

encode_receipt_handle_is_invalid_struct

</> 
pub fn encode_receipt_handle_is_invalid_struct(
  input: ReceiptHandleIsInvalid,
) -> json.Json

encode_receipt_handle_is_invalid_struct_top

</> 
pub fn encode_receipt_handle_is_invalid_struct_top(
  input: ReceiptHandleIsInvalid,
) -> json.Json

encode_receive_message_input

</> 
pub fn encode_receive_message_input(
  input: ReceiveMessageRequest,
) -> String

encode_receive_message_request_struct

</> 
pub fn encode_receive_message_request_struct(
  input: ReceiveMessageRequest,
) -> json.Json

encode_receive_message_request_struct_top

</> 
pub fn encode_receive_message_request_struct_top(
  input: ReceiveMessageRequest,
) -> json.Json

encode_receive_message_result_struct

</> 
pub fn encode_receive_message_result_struct(
  input: ReceiveMessageResult,
) -> json.Json

encode_receive_message_result_struct_top

</> 
pub fn encode_receive_message_result_struct_top(
  input: ReceiveMessageResult,
) -> json.Json

encode_remove_permission_input

</> 
pub fn encode_remove_permission_input(
  input: RemovePermissionRequest,
) -> String

encode_remove_permission_request_struct

</> 
pub fn encode_remove_permission_request_struct(
  input: RemovePermissionRequest,
) -> json.Json

encode_remove_permission_request_struct_top

</> 
pub fn encode_remove_permission_request_struct_top(
  input: RemovePermissionRequest,
) -> json.Json

encode_request_throttled_struct

</> 
pub fn encode_request_throttled_struct(
  input: RequestThrottled,
) -> json.Json

encode_request_throttled_struct_top

</> 
pub fn encode_request_throttled_struct_top(
  input: RequestThrottled,
) -> json.Json

encode_resource_not_found_exception_struct

</> 
pub fn encode_resource_not_found_exception_struct(
  input: ResourceNotFoundException,
) -> json.Json

encode_resource_not_found_exception_struct_top

</> 
pub fn encode_resource_not_found_exception_struct_top(
  input: ResourceNotFoundException,
) -> json.Json

encode_send_message_batch_input

</> 
pub fn encode_send_message_batch_input(
  input: SendMessageBatchRequest,
) -> String

encode_send_message_batch_request_entry_struct

</> 
pub fn encode_send_message_batch_request_entry_struct(
  input: SendMessageBatchRequestEntry,
) -> json.Json

encode_send_message_batch_request_entry_struct_top

</> 
pub fn encode_send_message_batch_request_entry_struct_top(
  input: SendMessageBatchRequestEntry,
) -> json.Json

encode_send_message_batch_request_struct

</> 
pub fn encode_send_message_batch_request_struct(
  input: SendMessageBatchRequest,
) -> json.Json

encode_send_message_batch_request_struct_top

</> 
pub fn encode_send_message_batch_request_struct_top(
  input: SendMessageBatchRequest,
) -> json.Json

encode_send_message_batch_result_entry_struct

</> 
pub fn encode_send_message_batch_result_entry_struct(
  input: SendMessageBatchResultEntry,
) -> json.Json

encode_send_message_batch_result_entry_struct_top

</> 
pub fn encode_send_message_batch_result_entry_struct_top(
  input: SendMessageBatchResultEntry,
) -> json.Json

encode_send_message_batch_result_struct

</> 
pub fn encode_send_message_batch_result_struct(
  input: SendMessageBatchResult,
) -> json.Json

encode_send_message_batch_result_struct_top

</> 
pub fn encode_send_message_batch_result_struct_top(
  input: SendMessageBatchResult,
) -> json.Json

encode_send_message_input

</> 
pub fn encode_send_message_input(
  input: SendMessageRequest,
) -> String

encode_send_message_request_struct

</> 
pub fn encode_send_message_request_struct(
  input: SendMessageRequest,
) -> json.Json

encode_send_message_request_struct_top

</> 
pub fn encode_send_message_request_struct_top(
  input: SendMessageRequest,
) -> json.Json

encode_send_message_result_struct

</> 
pub fn encode_send_message_result_struct(
  input: SendMessageResult,
) -> json.Json

encode_send_message_result_struct_top

</> 
pub fn encode_send_message_result_struct_top(
  input: SendMessageResult,
) -> json.Json

encode_set_queue_attributes_input

</> 
pub fn encode_set_queue_attributes_input(
  input: SetQueueAttributesRequest,
) -> String

encode_set_queue_attributes_request_struct

</> 
pub fn encode_set_queue_attributes_request_struct(
  input: SetQueueAttributesRequest,
) -> json.Json

encode_set_queue_attributes_request_struct_top

</> 
pub fn encode_set_queue_attributes_request_struct_top(
  input: SetQueueAttributesRequest,
) -> json.Json

encode_start_message_move_task_input

</> 
pub fn encode_start_message_move_task_input(
  input: StartMessageMoveTaskRequest,
) -> String

encode_start_message_move_task_request_struct

</> 
pub fn encode_start_message_move_task_request_struct(
  input: StartMessageMoveTaskRequest,
) -> json.Json

encode_start_message_move_task_request_struct_top

</> 
pub fn encode_start_message_move_task_request_struct_top(
  input: StartMessageMoveTaskRequest,
) -> json.Json

encode_start_message_move_task_result_struct

</> 
pub fn encode_start_message_move_task_result_struct(
  input: StartMessageMoveTaskResult,
) -> json.Json

encode_start_message_move_task_result_struct_top

</> 
pub fn encode_start_message_move_task_result_struct_top(
  input: StartMessageMoveTaskResult,
) -> json.Json

encode_tag_queue_input

</> 
pub fn encode_tag_queue_input(input: TagQueueRequest) -> String

encode_tag_queue_request_struct

</> 
pub fn encode_tag_queue_request_struct(
  input: TagQueueRequest,
) -> json.Json

encode_tag_queue_request_struct_top

</> 
pub fn encode_tag_queue_request_struct_top(
  input: TagQueueRequest,
) -> json.Json

encode_too_many_entries_in_batch_request_struct

</> 
pub fn encode_too_many_entries_in_batch_request_struct(
  input: TooManyEntriesInBatchRequest,
) -> json.Json

encode_too_many_entries_in_batch_request_struct_top

</> 
pub fn encode_too_many_entries_in_batch_request_struct_top(
  input: TooManyEntriesInBatchRequest,
) -> json.Json

encode_unsupported_operation_struct

</> 
pub fn encode_unsupported_operation_struct(
  input: UnsupportedOperation,
) -> json.Json

encode_unsupported_operation_struct_top

</> 
pub fn encode_unsupported_operation_struct_top(
  input: UnsupportedOperation,
) -> json.Json

encode_untag_queue_input

</> 
pub fn encode_untag_queue_input(
  input: UntagQueueRequest,
) -> String

encode_untag_queue_request_struct

</> 
pub fn encode_untag_queue_request_struct(
  input: UntagQueueRequest,
) -> json.Json

encode_untag_queue_request_struct_top

</> 
pub fn encode_untag_queue_request_struct_top(
  input: UntagQueueRequest,
) -> json.Json

get_queue_attributes

</> 
pub fn get_queue_attributes(
  client: Client,
  input: GetQueueAttributesRequest,
) -> Result(GetQueueAttributesResult, GetQueueAttributesError)

Invoke GetQueueAttributes. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed GetQueueAttributesError variants; transport, decode, and credentials failures all collapse into the generic GetQueueAttributesErrorTransport variant.

get_queue_url

</> 
pub fn get_queue_url(
  client: Client,
  input: GetQueueUrlRequest,
) -> Result(GetQueueUrlResult, GetQueueUrlError)

Invoke GetQueueUrl. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed GetQueueUrlError variants; transport, decode, and credentials failures all collapse into the generic GetQueueUrlErrorTransport variant.

list_dead_letter_source_queues

</> 
pub fn list_dead_letter_source_queues(
  client: Client,
  input: ListDeadLetterSourceQueuesRequest,
) -> Result(
  ListDeadLetterSourceQueuesResult,
  ListDeadLetterSourceQueuesError,
)

Invoke ListDeadLetterSourceQueues. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed ListDeadLetterSourceQueuesError variants; transport, decode, and credentials failures all collapse into the generic ListDeadLetterSourceQueuesErrorTransport variant.

list_message_move_tasks

</> 
pub fn list_message_move_tasks(
  client: Client,
  input: ListMessageMoveTasksRequest,
) -> Result(ListMessageMoveTasksResult, ListMessageMoveTasksError)

Invoke ListMessageMoveTasks. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed ListMessageMoveTasksError variants; transport, decode, and credentials failures all collapse into the generic ListMessageMoveTasksErrorTransport variant.

list_queue_tags

</> 
pub fn list_queue_tags(
  client: Client,
  input: ListQueueTagsRequest,
) -> Result(ListQueueTagsResult, ListQueueTagsError)

Invoke ListQueueTags. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed ListQueueTagsError variants; transport, decode, and credentials failures all collapse into the generic ListQueueTagsErrorTransport variant.

list_queues

</> 
pub fn list_queues(
  client: Client,
  input: ListQueuesRequest,
) -> Result(ListQueuesResult, ListQueuesError)

Invoke ListQueues. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed ListQueuesError variants; transport, decode, and credentials failures all collapse into the generic ListQueuesErrorTransport variant.

new

</> 
pub fn new(region region: String) -> Client

Build a Client for an AWS region. Credentials resolve through the default chain (env → web-identity → SSO → profile → process → ECS → IMDS); use with_credentials_provider to override.

new_with_auto_region

</> 
pub fn new_with_auto_region() -> Result(
  Client,
  region.ResolveError,
)

Build a Client by resolving the region from the standard AWS sources (AWS_REGION, AWS_DEFAULT_REGION, ~/.aws/config). Returns Error(_) when no source supplies a region — typical in Lambda/ECS/EC2 where exactly one of these is always set.

paginate_list_dead_letter_source_queues

</> 
pub fn paginate_list_dead_letter_source_queues(
  client: Client,
  input: ListDeadLetterSourceQueuesRequest,
  acc: acc,
  reducer: fn(acc, List(String)) -> acc,
) -> Result(acc, ListDeadLetterSourceQueuesError)

paginate_list_queues

</> 
pub fn paginate_list_queues(
  client: Client,
  input: ListQueuesRequest,
  acc: acc,
  reducer: fn(acc, List(String)) -> acc,
) -> Result(acc, ListQueuesError)

parse_add_permission_response

</> 
pub fn parse_add_permission_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(AddPermissionOutput, String)

parse_batch_entry_ids_not_distinct_response

</> 
pub fn parse_batch_entry_ids_not_distinct_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_batch_request_too_long_response

</> 
pub fn parse_batch_request_too_long_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_cancel_message_move_task_response

</> 
pub fn parse_cancel_message_move_task_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(CancelMessageMoveTaskResult, String)

parse_change_message_visibility_batch_response

</> 
pub fn parse_change_message_visibility_batch_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(ChangeMessageVisibilityBatchResult, String)

parse_change_message_visibility_response

</> 
pub fn parse_change_message_visibility_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(ChangeMessageVisibilityOutput, String)

parse_create_queue_response

</> 
pub fn parse_create_queue_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(CreateQueueResult, String)

parse_delete_message_batch_response

</> 
pub fn parse_delete_message_batch_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(DeleteMessageBatchResult, String)

parse_delete_message_response

</> 
pub fn parse_delete_message_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(DeleteMessageOutput, String)

parse_delete_queue_response

</> 
pub fn parse_delete_queue_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(DeleteQueueOutput, String)

parse_empty_batch_request_response

</> 
pub fn parse_empty_batch_request_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_get_queue_attributes_response

</> 
pub fn parse_get_queue_attributes_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(GetQueueAttributesResult, String)

parse_get_queue_url_response

</> 
pub fn parse_get_queue_url_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(GetQueueUrlResult, String)

parse_invalid_address_response

</> 
pub fn parse_invalid_address_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_invalid_attribute_name_response

</> 
pub fn parse_invalid_attribute_name_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_invalid_attribute_value_response

</> 
pub fn parse_invalid_attribute_value_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_invalid_batch_entry_id_response

</> 
pub fn parse_invalid_batch_entry_id_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_invalid_id_format_response

</> 
pub fn parse_invalid_id_format_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_invalid_message_contents_response

</> 
pub fn parse_invalid_message_contents_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_invalid_security_response

</> 
pub fn parse_invalid_security_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_kms_access_denied_response

</> 
pub fn parse_kms_access_denied_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_kms_disabled_response

</> 
pub fn parse_kms_disabled_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_kms_invalid_key_usage_response

</> 
pub fn parse_kms_invalid_key_usage_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_kms_invalid_state_response

</> 
pub fn parse_kms_invalid_state_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_kms_not_found_response

</> 
pub fn parse_kms_not_found_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_kms_opt_in_required_response

</> 
pub fn parse_kms_opt_in_required_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_kms_throttled_response

</> 
pub fn parse_kms_throttled_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_list_dead_letter_source_queues_response

</> 
pub fn parse_list_dead_letter_source_queues_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(ListDeadLetterSourceQueuesResult, String)

parse_list_message_move_tasks_response

</> 
pub fn parse_list_message_move_tasks_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(ListMessageMoveTasksResult, String)

parse_list_queue_tags_response

</> 
pub fn parse_list_queue_tags_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(ListQueueTagsResult, String)

parse_list_queues_response

</> 
pub fn parse_list_queues_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(ListQueuesResult, String)

parse_message_not_inflight_response

</> 
pub fn parse_message_not_inflight_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_over_limit_response

</> 
pub fn parse_over_limit_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_purge_queue_in_progress_response

</> 
pub fn parse_purge_queue_in_progress_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_purge_queue_response

</> 
pub fn parse_purge_queue_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(PurgeQueueOutput, String)

parse_queue_deleted_recently_response

</> 
pub fn parse_queue_deleted_recently_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_queue_does_not_exist_response

</> 
pub fn parse_queue_does_not_exist_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_queue_name_exists_response

</> 
pub fn parse_queue_name_exists_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_receipt_handle_is_invalid_response

</> 
pub fn parse_receipt_handle_is_invalid_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_receive_message_response

</> 
pub fn parse_receive_message_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(ReceiveMessageResult, String)

parse_remove_permission_response

</> 
pub fn parse_remove_permission_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(RemovePermissionOutput, String)

parse_request_throttled_response

</> 
pub fn parse_request_throttled_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_resource_not_found_exception_response

</> 
pub fn parse_resource_not_found_exception_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_send_message_batch_response

</> 
pub fn parse_send_message_batch_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(SendMessageBatchResult, String)

parse_send_message_response

</> 
pub fn parse_send_message_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(SendMessageResult, String)

parse_set_queue_attributes_response

</> 
pub fn parse_set_queue_attributes_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(SetQueueAttributesOutput, String)

parse_start_message_move_task_response

</> 
pub fn parse_start_message_move_task_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(StartMessageMoveTaskResult, String)

parse_tag_queue_response

</> 
pub fn parse_tag_queue_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(TagQueueOutput, String)

parse_too_many_entries_in_batch_request_response

</> 
pub fn parse_too_many_entries_in_batch_request_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_unsupported_operation_response

</> 
pub fn parse_unsupported_operation_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(Nil, String)

parse_untag_queue_response

</> 
pub fn parse_untag_queue_response(
  code: Int,
  headers: dict.Dict(String, String),
  body: BitArray,
) -> Result(UntagQueueOutput, String)

purge_queue

</> 
pub fn purge_queue(
  client: Client,
  input: PurgeQueueRequest,
) -> Result(PurgeQueueOutput, PurgeQueueError)

Invoke PurgeQueue. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed PurgeQueueError variants; transport, decode, and credentials failures all collapse into the generic PurgeQueueErrorTransport variant.

receive_message

</> 
pub fn receive_message(
  client: Client,
  input: ReceiveMessageRequest,
) -> Result(ReceiveMessageResult, ReceiveMessageError)

Invoke ReceiveMessage. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed ReceiveMessageError variants; transport, decode, and credentials failures all collapse into the generic ReceiveMessageErrorTransport variant.

remove_permission

</> 
pub fn remove_permission(
  client: Client,
  input: RemovePermissionRequest,
) -> Result(RemovePermissionOutput, RemovePermissionError)

Invoke RemovePermission. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed RemovePermissionError variants; transport, decode, and credentials failures all collapse into the generic RemovePermissionErrorTransport variant.

send_message

</> 
pub fn send_message(
  client: Client,
  input: SendMessageRequest,
) -> Result(SendMessageResult, SendMessageError)

Invoke SendMessage. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed SendMessageError variants; transport, decode, and credentials failures all collapse into the generic SendMessageErrorTransport variant.

send_message_batch

</> 
pub fn send_message_batch(
  client: Client,
  input: SendMessageBatchRequest,
) -> Result(SendMessageBatchResult, SendMessageBatchError)

Invoke SendMessageBatch. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed SendMessageBatchError variants; transport, decode, and credentials failures all collapse into the generic SendMessageBatchErrorTransport variant.

set_queue_attributes

</> 
pub fn set_queue_attributes(
  client: Client,
  input: SetQueueAttributesRequest,
) -> Result(SetQueueAttributesOutput, SetQueueAttributesError)

Invoke SetQueueAttributes. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed SetQueueAttributesError variants; transport, decode, and credentials failures all collapse into the generic SetQueueAttributesErrorTransport variant.

shutdown

</> 
pub fn shutdown(client: Client) -> Nil

Release the per-Client credentials cache actor. Call this when a Client value is no longer needed — long-running processes that build many Clients (tests, scripts, multi-tenant servers) will otherwise accumulate one BEAM process per new call. Fire-and- forget; safe to call multiple times. For tests or graceful shutdown that must observe the actor’s exit, use shutdown_sync.

shutdown_sync

</> 
pub fn shutdown_sync(
  client: Client,
  timeout_ms timeout_ms: Int,
) -> Result(Nil, Nil)

Like shutdown but blocks until the credentials cache actor has actually exited (or timeout_ms elapses). Ok(Nil) indicates a clean exit; Error(Nil) indicates the timeout fired and the actor was still alive when the caller gave up.

start_message_move_task

</> 
pub fn start_message_move_task(
  client: Client,
  input: StartMessageMoveTaskRequest,
) -> Result(StartMessageMoveTaskResult, StartMessageMoveTaskError)

Invoke StartMessageMoveTask. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed StartMessageMoveTaskError variants; transport, decode, and credentials failures all collapse into the generic StartMessageMoveTaskErrorTransport variant.

tag_queue

</> 
pub fn tag_queue(
  client: Client,
  input: TagQueueRequest,
) -> Result(TagQueueOutput, TagQueueError)

Invoke TagQueue. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed TagQueueError variants; transport, decode, and credentials failures all collapse into the generic TagQueueErrorTransport variant.

untag_queue

</> 
pub fn untag_queue(
  client: Client,
  input: UntagQueueRequest,
) -> Result(UntagQueueOutput, UntagQueueError)

Invoke UntagQueue. Signs the request with SigV4 and dispatches via the configured HTTP transport. Service errors come back as typed UntagQueueError variants; transport, decode, and credentials failures all collapse into the generic UntagQueueErrorTransport variant.

with_credentials_provider

</> 
pub fn with_credentials_provider(
  client: Client,
  provider: credentials.Provider,
) -> Client

Override the credentials provider — use for non-default profiles, in-process static credentials, or a custom chain. The supplied provider is wrapped in a fresh per-Client credentials cache so callers don’t lose refresh/coalesce behaviour by overriding the default chain. The previously running cache actor is stopped — call this on a Client value you intend to keep, not on one that’s about to be discarded.

with_endpoint_url

</> 
pub fn with_endpoint_url(client: Client, url: String) -> Client

Override the endpoint URL (LocalStack, FIPS endpoints, custom DNS).

with_http2

</> 
pub fn with_http2(client: Client) -> Client

Switch the streaming sender to the HTTP/2 variant. httpc adds {http_version, "HTTP/2"} to its option list; servers that don’t speak HTTP/2 negotiate down to HTTP/1.1 via ALPN, so calls keep working even when the peer doesn’t support it. Buffered requests (with_http_send) are unaffected — HTTP/2 is for high-throughput streaming endpoints (S3 multipart, Bedrock streaming, Transcribe).

with_http_send

</> 
pub fn with_http_send(
  client: Client,
  send: fn(request.Request(BitArray)) -> Result(
    response.Response(BitArray),
    http_send.HttpError,
  ),
) -> Client

Swap the HTTP transport — useful for canned-response test doubles.

with_max_attempts

</> 
pub fn with_max_attempts(client: Client, n: Int) -> Client

Override the retry attempt budget on the underlying ClientConfig. The common case for retry tuning — pass 1 to disable retries entirely (single attempt per request), 5 for long-running batch workloads. Preserves the other retry knobs (delays, sleep, rng, rate-limiter); use runtime.with_retry_strategy for full control.

with_sigv4a_path_normalization

</> 
pub fn with_sigv4a_path_normalization(
  client: Client,
  normalize: Bool,
) -> Client

Override SigV4a’s normalize_path (RFC 3986 dot-segment removal). No-op when with_sigv4a_region_set has not been called yet — the knob lives on the per-Client SigV4a state, not on the underlying transport. S3 callers need False so object keys with . / .. survive the canonical-request step.

with_sigv4a_region_set

</> 
pub fn with_sigv4a_region_set(
  client: Client,
  region_set: List(String),
) -> Client

Opt the Client into SigV4a (asymmetric ECDSA P-256) signing for every request. region_set becomes the X-Amz-Region-Set header — single-region callers pass ["us-east-1"], multi-region callers pass the full list. Required for S3 Multi-Region Access Points and any other endpoint that demands AWS4-ECDSA-P256-SHA256 signatures.

with_streaming_http_send

</> 
pub fn with_streaming_http_send(
  client: Client,
  send: fn(request.Request(BitArray)) -> Result(
    response.Response(streaming.StreamingBody),
    http_send.HttpError,
  ),
) -> Client

Swap the streaming HTTP transport. Same role as with_http_send but targets the @streaming output path (runtime.invoke_streaming). Use for canned-response test doubles on streaming ops, or to plug in a custom chunked transport (proxy, gRPC tunnel, instrumented sender) without disturbing the buffered path.

with_use_dual_stack

</> 
pub fn with_use_dual_stack(client: Client, value: Bool) -> Client

When true, use the dual-stack endpoint. If the configured endpoint does not support dual-stack, dispatching the request MAY return an error. Wire form: runtime.with_endpoint_param(config, "UseDualStack", ...).

with_use_fips

</> 
pub fn with_use_fips(client: Client, value: Bool) -> Client

When true, send this request to the FIPS-compliant regional endpoint. If the configured endpoint does not have a FIPS compliant endpoint, dispatching the request will return an error. Wire form: runtime.with_endpoint_param(config, "UseFIPS", ...).

✨ Search Document