#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct AddPermission {
_private: (),
}
impl AddPermission {
pub fn builder() -> crate::input::add_permission_input::Builder {
crate::input::add_permission_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for AddPermission {
type Output =
std::result::Result<crate::output::AddPermissionOutput, crate::error::AddPermissionError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_add_permission_error(response)
} else {
crate::operation_deser::parse_add_permission_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ChangeMessageVisibility {
_private: (),
}
impl ChangeMessageVisibility {
pub fn builder() -> crate::input::change_message_visibility_input::Builder {
crate::input::change_message_visibility_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ChangeMessageVisibility {
type Output = std::result::Result<
crate::output::ChangeMessageVisibilityOutput,
crate::error::ChangeMessageVisibilityError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_change_message_visibility_error(response)
} else {
crate::operation_deser::parse_change_message_visibility_response(response)
}
}
}
#[cfg(test)]
#[allow(unreachable_code, unused_variables)]
mod change_message_visibility_request_test {
#[tokio::test]
async fn sqs_set_visibility_zero_request() {
let builder = crate::config::Config::builder()
.with_test_defaults()
.endpoint_resolver("https://example.com");
let config = builder.build();
let input = crate::input::ChangeMessageVisibilityInput::builder()
.set_queue_url(Some("http://somequeue.amazon.com".to_owned()))
.set_receipt_handle(Some("handlehandle".to_owned()))
.set_visibility_timeout(Some(0))
.build()
.unwrap()
.make_operation(&config)
.await
.expect("operation failed to build");
let (http_request, parts) = input.into_request_response().0.into_parts();
pretty_assertions::assert_eq!(http_request.method(), "POST");
pretty_assertions::assert_eq!(http_request.uri().path(), "/");
let body = http_request.body().bytes().expect("body should be strict");
aws_smithy_protocol_test::assert_ok(
aws_smithy_protocol_test::validate_body(&body, "Action=ChangeMessageVisibility&Version=2012-11-05&QueueUrl=http%3A%2F%2Fsomequeue.amazon.com&ReceiptHandle=handlehandle&VisibilityTimeout=0", aws_smithy_protocol_test::MediaType::from("application/x-www-formurl-encoded"))
);
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ChangeMessageVisibilityBatch {
_private: (),
}
impl ChangeMessageVisibilityBatch {
pub fn builder() -> crate::input::change_message_visibility_batch_input::Builder {
crate::input::change_message_visibility_batch_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ChangeMessageVisibilityBatch {
type Output = std::result::Result<
crate::output::ChangeMessageVisibilityBatchOutput,
crate::error::ChangeMessageVisibilityBatchError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_change_message_visibility_batch_error(response)
} else {
crate::operation_deser::parse_change_message_visibility_batch_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct CreateQueue {
_private: (),
}
impl CreateQueue {
pub fn builder() -> crate::input::create_queue_input::Builder {
crate::input::create_queue_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for CreateQueue {
type Output =
std::result::Result<crate::output::CreateQueueOutput, crate::error::CreateQueueError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_create_queue_error(response)
} else {
crate::operation_deser::parse_create_queue_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct DeleteMessage {
_private: (),
}
impl DeleteMessage {
pub fn builder() -> crate::input::delete_message_input::Builder {
crate::input::delete_message_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for DeleteMessage {
type Output =
std::result::Result<crate::output::DeleteMessageOutput, crate::error::DeleteMessageError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_delete_message_error(response)
} else {
crate::operation_deser::parse_delete_message_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct DeleteMessageBatch {
_private: (),
}
impl DeleteMessageBatch {
pub fn builder() -> crate::input::delete_message_batch_input::Builder {
crate::input::delete_message_batch_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for DeleteMessageBatch {
type Output = std::result::Result<
crate::output::DeleteMessageBatchOutput,
crate::error::DeleteMessageBatchError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_delete_message_batch_error(response)
} else {
crate::operation_deser::parse_delete_message_batch_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct DeleteQueue {
_private: (),
}
impl DeleteQueue {
pub fn builder() -> crate::input::delete_queue_input::Builder {
crate::input::delete_queue_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for DeleteQueue {
type Output =
std::result::Result<crate::output::DeleteQueueOutput, crate::error::DeleteQueueError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_delete_queue_error(response)
} else {
crate::operation_deser::parse_delete_queue_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct GetQueueAttributes {
_private: (),
}
impl GetQueueAttributes {
pub fn builder() -> crate::input::get_queue_attributes_input::Builder {
crate::input::get_queue_attributes_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for GetQueueAttributes {
type Output = std::result::Result<
crate::output::GetQueueAttributesOutput,
crate::error::GetQueueAttributesError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_get_queue_attributes_error(response)
} else {
crate::operation_deser::parse_get_queue_attributes_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct GetQueueUrl {
_private: (),
}
impl GetQueueUrl {
pub fn builder() -> crate::input::get_queue_url_input::Builder {
crate::input::get_queue_url_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for GetQueueUrl {
type Output =
std::result::Result<crate::output::GetQueueUrlOutput, crate::error::GetQueueUrlError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_get_queue_url_error(response)
} else {
crate::operation_deser::parse_get_queue_url_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ListDeadLetterSourceQueues {
_private: (),
}
impl ListDeadLetterSourceQueues {
pub fn builder() -> crate::input::list_dead_letter_source_queues_input::Builder {
crate::input::list_dead_letter_source_queues_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ListDeadLetterSourceQueues {
type Output = std::result::Result<
crate::output::ListDeadLetterSourceQueuesOutput,
crate::error::ListDeadLetterSourceQueuesError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_list_dead_letter_source_queues_error(response)
} else {
crate::operation_deser::parse_list_dead_letter_source_queues_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ListQueues {
_private: (),
}
impl ListQueues {
pub fn builder() -> crate::input::list_queues_input::Builder {
crate::input::list_queues_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ListQueues {
type Output =
std::result::Result<crate::output::ListQueuesOutput, crate::error::ListQueuesError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_list_queues_error(response)
} else {
crate::operation_deser::parse_list_queues_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ListQueueTags {
_private: (),
}
impl ListQueueTags {
pub fn builder() -> crate::input::list_queue_tags_input::Builder {
crate::input::list_queue_tags_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ListQueueTags {
type Output =
std::result::Result<crate::output::ListQueueTagsOutput, crate::error::ListQueueTagsError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_list_queue_tags_error(response)
} else {
crate::operation_deser::parse_list_queue_tags_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct PurgeQueue {
_private: (),
}
impl PurgeQueue {
pub fn builder() -> crate::input::purge_queue_input::Builder {
crate::input::purge_queue_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for PurgeQueue {
type Output =
std::result::Result<crate::output::PurgeQueueOutput, crate::error::PurgeQueueError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_purge_queue_error(response)
} else {
crate::operation_deser::parse_purge_queue_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ReceiveMessage {
_private: (),
}
impl ReceiveMessage {
pub fn builder() -> crate::input::receive_message_input::Builder {
crate::input::receive_message_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ReceiveMessage {
type Output =
std::result::Result<crate::output::ReceiveMessageOutput, crate::error::ReceiveMessageError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_receive_message_error(response)
} else {
crate::operation_deser::parse_receive_message_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct RemovePermission {
_private: (),
}
impl RemovePermission {
pub fn builder() -> crate::input::remove_permission_input::Builder {
crate::input::remove_permission_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for RemovePermission {
type Output = std::result::Result<
crate::output::RemovePermissionOutput,
crate::error::RemovePermissionError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_remove_permission_error(response)
} else {
crate::operation_deser::parse_remove_permission_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct SendMessage {
_private: (),
}
impl SendMessage {
pub fn builder() -> crate::input::send_message_input::Builder {
crate::input::send_message_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for SendMessage {
type Output =
std::result::Result<crate::output::SendMessageOutput, crate::error::SendMessageError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_send_message_error(response)
} else {
crate::operation_deser::parse_send_message_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct SendMessageBatch {
_private: (),
}
impl SendMessageBatch {
pub fn builder() -> crate::input::send_message_batch_input::Builder {
crate::input::send_message_batch_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for SendMessageBatch {
type Output = std::result::Result<
crate::output::SendMessageBatchOutput,
crate::error::SendMessageBatchError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_send_message_batch_error(response)
} else {
crate::operation_deser::parse_send_message_batch_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct SetQueueAttributes {
_private: (),
}
impl SetQueueAttributes {
pub fn builder() -> crate::input::set_queue_attributes_input::Builder {
crate::input::set_queue_attributes_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for SetQueueAttributes {
type Output = std::result::Result<
crate::output::SetQueueAttributesOutput,
crate::error::SetQueueAttributesError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_set_queue_attributes_error(response)
} else {
crate::operation_deser::parse_set_queue_attributes_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct TagQueue {
_private: (),
}
impl TagQueue {
pub fn builder() -> crate::input::tag_queue_input::Builder {
crate::input::tag_queue_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for TagQueue {
type Output = std::result::Result<crate::output::TagQueueOutput, crate::error::TagQueueError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_tag_queue_error(response)
} else {
crate::operation_deser::parse_tag_queue_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct UntagQueue {
_private: (),
}
impl UntagQueue {
pub fn builder() -> crate::input::untag_queue_input::Builder {
crate::input::untag_queue_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for UntagQueue {
type Output =
std::result::Result<crate::output::UntagQueueOutput, crate::error::UntagQueueError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_untag_queue_error(response)
} else {
crate::operation_deser::parse_untag_queue_response(response)
}
}
}
pub mod customize;