use std::fmt::Write;
pub mod create_extended_source_server_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default)]
pub struct Builder {
pub(crate) source_server_arn: std::option::Option<std::string::String>,
pub(crate) tags: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
}
impl Builder {
pub fn source_server_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_arn = Some(input.into());
self
}
pub fn set_source_server_arn(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_arn = input;
self
}
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
let mut hash_map = self.tags.unwrap_or_default();
hash_map.insert(k.into(), v.into());
self.tags = Some(hash_map);
self
}
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.tags = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::CreateExtendedSourceServerInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::CreateExtendedSourceServerInput {
source_server_arn: self.source_server_arn,
tags: self.tags,
})
}
}
impl std::fmt::Debug for Builder {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("Builder");
formatter.field("source_server_arn", &self.source_server_arn);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
}
impl CreateExtendedSourceServerInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::CreateExtendedSourceServer,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::CreateExtendedSourceServerInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/CreateExtendedSourceServer").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::CreateExtendedSourceServerInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_create_extended_source_server(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::CreateExtendedSourceServer::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"CreateExtendedSourceServer",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::create_extended_source_server_input::Builder {
crate::input::create_extended_source_server_input::Builder::default()
}
}
pub mod create_replication_configuration_template_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default)]
pub struct Builder {
pub(crate) staging_area_subnet_id: std::option::Option<std::string::String>,
pub(crate) associate_default_security_group: std::option::Option<bool>,
pub(crate) replication_servers_security_groups_i_ds:
std::option::Option<std::vec::Vec<std::string::String>>,
pub(crate) replication_server_instance_type: std::option::Option<std::string::String>,
pub(crate) use_dedicated_replication_server: std::option::Option<bool>,
pub(crate) default_large_staging_disk_type:
std::option::Option<crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>,
pub(crate) ebs_encryption:
std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
pub(crate) ebs_encryption_key_arn: std::option::Option<std::string::String>,
pub(crate) bandwidth_throttling: std::option::Option<i64>,
pub(crate) data_plane_routing:
std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
pub(crate) create_public_ip: std::option::Option<bool>,
pub(crate) staging_area_tags: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
pub(crate) pit_policy: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
pub(crate) tags: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
}
impl Builder {
pub fn staging_area_subnet_id(mut self, input: impl Into<std::string::String>) -> Self {
self.staging_area_subnet_id = Some(input.into());
self
}
pub fn set_staging_area_subnet_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.staging_area_subnet_id = input;
self
}
pub fn associate_default_security_group(mut self, input: bool) -> Self {
self.associate_default_security_group = Some(input);
self
}
pub fn set_associate_default_security_group(
mut self,
input: std::option::Option<bool>,
) -> Self {
self.associate_default_security_group = input;
self
}
pub fn replication_servers_security_groups_i_ds(
mut self,
input: impl Into<std::string::String>,
) -> Self {
let mut v = self
.replication_servers_security_groups_i_ds
.unwrap_or_default();
v.push(input.into());
self.replication_servers_security_groups_i_ds = Some(v);
self
}
pub fn set_replication_servers_security_groups_i_ds(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.replication_servers_security_groups_i_ds = input;
self
}
pub fn replication_server_instance_type(
mut self,
input: impl Into<std::string::String>,
) -> Self {
self.replication_server_instance_type = Some(input.into());
self
}
pub fn set_replication_server_instance_type(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.replication_server_instance_type = input;
self
}
pub fn use_dedicated_replication_server(mut self, input: bool) -> Self {
self.use_dedicated_replication_server = Some(input);
self
}
pub fn set_use_dedicated_replication_server(
mut self,
input: std::option::Option<bool>,
) -> Self {
self.use_dedicated_replication_server = input;
self
}
pub fn default_large_staging_disk_type(
mut self,
input: crate::model::ReplicationConfigurationDefaultLargeStagingDiskType,
) -> Self {
self.default_large_staging_disk_type = Some(input);
self
}
pub fn set_default_large_staging_disk_type(
mut self,
input: std::option::Option<
crate::model::ReplicationConfigurationDefaultLargeStagingDiskType,
>,
) -> Self {
self.default_large_staging_disk_type = input;
self
}
pub fn ebs_encryption(
mut self,
input: crate::model::ReplicationConfigurationEbsEncryption,
) -> Self {
self.ebs_encryption = Some(input);
self
}
pub fn set_ebs_encryption(
mut self,
input: std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
) -> Self {
self.ebs_encryption = input;
self
}
pub fn ebs_encryption_key_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.ebs_encryption_key_arn = Some(input.into());
self
}
pub fn set_ebs_encryption_key_arn(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.ebs_encryption_key_arn = input;
self
}
pub fn bandwidth_throttling(mut self, input: i64) -> Self {
self.bandwidth_throttling = Some(input);
self
}
pub fn set_bandwidth_throttling(mut self, input: std::option::Option<i64>) -> Self {
self.bandwidth_throttling = input;
self
}
pub fn data_plane_routing(
mut self,
input: crate::model::ReplicationConfigurationDataPlaneRouting,
) -> Self {
self.data_plane_routing = Some(input);
self
}
pub fn set_data_plane_routing(
mut self,
input: std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
) -> Self {
self.data_plane_routing = input;
self
}
pub fn create_public_ip(mut self, input: bool) -> Self {
self.create_public_ip = Some(input);
self
}
pub fn set_create_public_ip(mut self, input: std::option::Option<bool>) -> Self {
self.create_public_ip = input;
self
}
pub fn staging_area_tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
let mut hash_map = self.staging_area_tags.unwrap_or_default();
hash_map.insert(k.into(), v.into());
self.staging_area_tags = Some(hash_map);
self
}
pub fn set_staging_area_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.staging_area_tags = input;
self
}
pub fn pit_policy(mut self, input: crate::model::PitPolicyRule) -> Self {
let mut v = self.pit_policy.unwrap_or_default();
v.push(input);
self.pit_policy = Some(v);
self
}
pub fn set_pit_policy(
mut self,
input: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
) -> Self {
self.pit_policy = input;
self
}
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
let mut hash_map = self.tags.unwrap_or_default();
hash_map.insert(k.into(), v.into());
self.tags = Some(hash_map);
self
}
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.tags = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::CreateReplicationConfigurationTemplateInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::CreateReplicationConfigurationTemplateInput {
staging_area_subnet_id: self.staging_area_subnet_id,
associate_default_security_group: self.associate_default_security_group,
replication_servers_security_groups_i_ds: self
.replication_servers_security_groups_i_ds,
replication_server_instance_type: self.replication_server_instance_type,
use_dedicated_replication_server: self.use_dedicated_replication_server,
default_large_staging_disk_type: self.default_large_staging_disk_type,
ebs_encryption: self.ebs_encryption,
ebs_encryption_key_arn: self.ebs_encryption_key_arn,
bandwidth_throttling: self.bandwidth_throttling.unwrap_or_default(),
data_plane_routing: self.data_plane_routing,
create_public_ip: self.create_public_ip,
staging_area_tags: self.staging_area_tags,
pit_policy: self.pit_policy,
tags: self.tags,
})
}
}
impl std::fmt::Debug for Builder {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("Builder");
formatter.field("staging_area_subnet_id", &self.staging_area_subnet_id);
formatter.field(
"associate_default_security_group",
&self.associate_default_security_group,
);
formatter.field(
"replication_servers_security_groups_i_ds",
&self.replication_servers_security_groups_i_ds,
);
formatter.field(
"replication_server_instance_type",
&self.replication_server_instance_type,
);
formatter.field(
"use_dedicated_replication_server",
&self.use_dedicated_replication_server,
);
formatter.field(
"default_large_staging_disk_type",
&self.default_large_staging_disk_type,
);
formatter.field("ebs_encryption", &self.ebs_encryption);
formatter.field("ebs_encryption_key_arn", &self.ebs_encryption_key_arn);
formatter.field("bandwidth_throttling", &self.bandwidth_throttling);
formatter.field("data_plane_routing", &self.data_plane_routing);
formatter.field("create_public_ip", &self.create_public_ip);
formatter.field("staging_area_tags", &"*** Sensitive Data Redacted ***");
formatter.field("pit_policy", &self.pit_policy);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
}
impl CreateReplicationConfigurationTemplateInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::CreateReplicationConfigurationTemplate,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::CreateReplicationConfigurationTemplateInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/CreateReplicationConfigurationTemplate")
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::CreateReplicationConfigurationTemplateInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_create_replication_configuration_template(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::CreateReplicationConfigurationTemplate::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"CreateReplicationConfigurationTemplate",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::create_replication_configuration_template_input::Builder {
crate::input::create_replication_configuration_template_input::Builder::default()
}
}
pub mod delete_job_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) job_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn job_id(mut self, input: impl Into<std::string::String>) -> Self {
self.job_id = Some(input.into());
self
}
pub fn set_job_id(mut self, input: std::option::Option<std::string::String>) -> Self {
self.job_id = input;
self
}
pub fn build(
self,
) -> Result<crate::input::DeleteJobInput, aws_smithy_http::operation::error::BuildError>
{
Ok(crate::input::DeleteJobInput {
job_id: self.job_id,
})
}
}
}
impl DeleteJobInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DeleteJob,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DeleteJobInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DeleteJob").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DeleteJobInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_delete_job(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op =
aws_smithy_http::operation::Operation::new(request, crate::operation::DeleteJob::new())
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DeleteJob",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::delete_job_input::Builder {
crate::input::delete_job_input::Builder::default()
}
}
pub mod delete_recovery_instance_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) recovery_instance_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn recovery_instance_id(mut self, input: impl Into<std::string::String>) -> Self {
self.recovery_instance_id = Some(input.into());
self
}
pub fn set_recovery_instance_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.recovery_instance_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DeleteRecoveryInstanceInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DeleteRecoveryInstanceInput {
recovery_instance_id: self.recovery_instance_id,
})
}
}
}
impl DeleteRecoveryInstanceInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DeleteRecoveryInstance,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DeleteRecoveryInstanceInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DeleteRecoveryInstance").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DeleteRecoveryInstanceInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_delete_recovery_instance(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DeleteRecoveryInstance::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DeleteRecoveryInstance",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::delete_recovery_instance_input::Builder {
crate::input::delete_recovery_instance_input::Builder::default()
}
}
pub mod delete_replication_configuration_template_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) replication_configuration_template_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn replication_configuration_template_id(
mut self,
input: impl Into<std::string::String>,
) -> Self {
self.replication_configuration_template_id = Some(input.into());
self
}
pub fn set_replication_configuration_template_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.replication_configuration_template_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DeleteReplicationConfigurationTemplateInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DeleteReplicationConfigurationTemplateInput {
replication_configuration_template_id: self.replication_configuration_template_id,
})
}
}
}
impl DeleteReplicationConfigurationTemplateInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DeleteReplicationConfigurationTemplate,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DeleteReplicationConfigurationTemplateInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DeleteReplicationConfigurationTemplate")
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DeleteReplicationConfigurationTemplateInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_delete_replication_configuration_template(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DeleteReplicationConfigurationTemplate::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DeleteReplicationConfigurationTemplate",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::delete_replication_configuration_template_input::Builder {
crate::input::delete_replication_configuration_template_input::Builder::default()
}
}
pub mod delete_source_server_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DeleteSourceServerInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DeleteSourceServerInput {
source_server_id: self.source_server_id,
})
}
}
}
impl DeleteSourceServerInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DeleteSourceServer,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DeleteSourceServerInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DeleteSourceServer").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DeleteSourceServerInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_delete_source_server(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DeleteSourceServer::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DeleteSourceServer",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::delete_source_server_input::Builder {
crate::input::delete_source_server_input::Builder::default()
}
}
pub mod describe_job_log_items_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) job_id: std::option::Option<std::string::String>,
pub(crate) max_results: std::option::Option<i32>,
pub(crate) next_token: std::option::Option<std::string::String>,
}
impl Builder {
pub fn job_id(mut self, input: impl Into<std::string::String>) -> Self {
self.job_id = Some(input.into());
self
}
pub fn set_job_id(mut self, input: std::option::Option<std::string::String>) -> Self {
self.job_id = input;
self
}
pub fn max_results(mut self, input: i32) -> Self {
self.max_results = Some(input);
self
}
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.max_results = input;
self
}
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.next_token = Some(input.into());
self
}
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.next_token = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DescribeJobLogItemsInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DescribeJobLogItemsInput {
job_id: self.job_id,
max_results: self.max_results.unwrap_or_default(),
next_token: self.next_token,
})
}
}
}
impl DescribeJobLogItemsInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DescribeJobLogItems,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DescribeJobLogItemsInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DescribeJobLogItems").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DescribeJobLogItemsInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_describe_job_log_items(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DescribeJobLogItems::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DescribeJobLogItems",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::describe_job_log_items_input::Builder {
crate::input::describe_job_log_items_input::Builder::default()
}
}
pub mod describe_jobs_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) filters: std::option::Option<crate::model::DescribeJobsRequestFilters>,
pub(crate) max_results: std::option::Option<i32>,
pub(crate) next_token: std::option::Option<std::string::String>,
}
impl Builder {
pub fn filters(mut self, input: crate::model::DescribeJobsRequestFilters) -> Self {
self.filters = Some(input);
self
}
pub fn set_filters(
mut self,
input: std::option::Option<crate::model::DescribeJobsRequestFilters>,
) -> Self {
self.filters = input;
self
}
pub fn max_results(mut self, input: i32) -> Self {
self.max_results = Some(input);
self
}
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.max_results = input;
self
}
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.next_token = Some(input.into());
self
}
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.next_token = input;
self
}
pub fn build(
self,
) -> Result<crate::input::DescribeJobsInput, aws_smithy_http::operation::error::BuildError>
{
Ok(crate::input::DescribeJobsInput {
filters: self.filters,
max_results: self.max_results.unwrap_or_default(),
next_token: self.next_token,
})
}
}
}
impl DescribeJobsInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DescribeJobs,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DescribeJobsInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DescribeJobs").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DescribeJobsInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_describe_jobs(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DescribeJobs::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DescribeJobs",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::describe_jobs_input::Builder {
crate::input::describe_jobs_input::Builder::default()
}
}
pub mod describe_recovery_instances_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) filters:
std::option::Option<crate::model::DescribeRecoveryInstancesRequestFilters>,
pub(crate) max_results: std::option::Option<i32>,
pub(crate) next_token: std::option::Option<std::string::String>,
}
impl Builder {
pub fn filters(
mut self,
input: crate::model::DescribeRecoveryInstancesRequestFilters,
) -> Self {
self.filters = Some(input);
self
}
pub fn set_filters(
mut self,
input: std::option::Option<crate::model::DescribeRecoveryInstancesRequestFilters>,
) -> Self {
self.filters = input;
self
}
pub fn max_results(mut self, input: i32) -> Self {
self.max_results = Some(input);
self
}
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.max_results = input;
self
}
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.next_token = Some(input.into());
self
}
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.next_token = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DescribeRecoveryInstancesInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DescribeRecoveryInstancesInput {
filters: self.filters,
max_results: self.max_results.unwrap_or_default(),
next_token: self.next_token,
})
}
}
}
impl DescribeRecoveryInstancesInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DescribeRecoveryInstances,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DescribeRecoveryInstancesInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DescribeRecoveryInstances").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DescribeRecoveryInstancesInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_describe_recovery_instances(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DescribeRecoveryInstances::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DescribeRecoveryInstances",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::describe_recovery_instances_input::Builder {
crate::input::describe_recovery_instances_input::Builder::default()
}
}
pub mod describe_recovery_snapshots_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
pub(crate) filters:
std::option::Option<crate::model::DescribeRecoverySnapshotsRequestFilters>,
pub(crate) order: std::option::Option<crate::model::RecoverySnapshotsOrder>,
pub(crate) max_results: std::option::Option<i32>,
pub(crate) next_token: std::option::Option<std::string::String>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn filters(
mut self,
input: crate::model::DescribeRecoverySnapshotsRequestFilters,
) -> Self {
self.filters = Some(input);
self
}
pub fn set_filters(
mut self,
input: std::option::Option<crate::model::DescribeRecoverySnapshotsRequestFilters>,
) -> Self {
self.filters = input;
self
}
pub fn order(mut self, input: crate::model::RecoverySnapshotsOrder) -> Self {
self.order = Some(input);
self
}
pub fn set_order(
mut self,
input: std::option::Option<crate::model::RecoverySnapshotsOrder>,
) -> Self {
self.order = input;
self
}
pub fn max_results(mut self, input: i32) -> Self {
self.max_results = Some(input);
self
}
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.max_results = input;
self
}
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.next_token = Some(input.into());
self
}
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.next_token = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DescribeRecoverySnapshotsInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DescribeRecoverySnapshotsInput {
source_server_id: self.source_server_id,
filters: self.filters,
order: self.order,
max_results: self.max_results.unwrap_or_default(),
next_token: self.next_token,
})
}
}
}
impl DescribeRecoverySnapshotsInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DescribeRecoverySnapshots,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DescribeRecoverySnapshotsInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DescribeRecoverySnapshots").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DescribeRecoverySnapshotsInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_describe_recovery_snapshots(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DescribeRecoverySnapshots::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DescribeRecoverySnapshots",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::describe_recovery_snapshots_input::Builder {
crate::input::describe_recovery_snapshots_input::Builder::default()
}
}
pub mod describe_replication_configuration_templates_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) replication_configuration_template_i_ds:
std::option::Option<std::vec::Vec<std::string::String>>,
pub(crate) max_results: std::option::Option<i32>,
pub(crate) next_token: std::option::Option<std::string::String>,
}
impl Builder {
pub fn replication_configuration_template_i_ds(
mut self,
input: impl Into<std::string::String>,
) -> Self {
let mut v = self
.replication_configuration_template_i_ds
.unwrap_or_default();
v.push(input.into());
self.replication_configuration_template_i_ds = Some(v);
self
}
pub fn set_replication_configuration_template_i_ds(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.replication_configuration_template_i_ds = input;
self
}
pub fn max_results(mut self, input: i32) -> Self {
self.max_results = Some(input);
self
}
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.max_results = input;
self
}
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.next_token = Some(input.into());
self
}
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.next_token = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DescribeReplicationConfigurationTemplatesInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(
crate::input::DescribeReplicationConfigurationTemplatesInput {
replication_configuration_template_i_ds: self
.replication_configuration_template_i_ds,
max_results: self.max_results.unwrap_or_default(),
next_token: self.next_token,
},
)
}
}
}
impl DescribeReplicationConfigurationTemplatesInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DescribeReplicationConfigurationTemplates,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DescribeReplicationConfigurationTemplatesInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DescribeReplicationConfigurationTemplates")
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DescribeReplicationConfigurationTemplatesInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_describe_replication_configuration_templates(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DescribeReplicationConfigurationTemplates::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DescribeReplicationConfigurationTemplates",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::describe_replication_configuration_templates_input::Builder {
crate::input::describe_replication_configuration_templates_input::Builder::default()
}
}
pub mod describe_source_servers_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) filters: std::option::Option<crate::model::DescribeSourceServersRequestFilters>,
pub(crate) max_results: std::option::Option<i32>,
pub(crate) next_token: std::option::Option<std::string::String>,
}
impl Builder {
pub fn filters(mut self, input: crate::model::DescribeSourceServersRequestFilters) -> Self {
self.filters = Some(input);
self
}
pub fn set_filters(
mut self,
input: std::option::Option<crate::model::DescribeSourceServersRequestFilters>,
) -> Self {
self.filters = input;
self
}
pub fn max_results(mut self, input: i32) -> Self {
self.max_results = Some(input);
self
}
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.max_results = input;
self
}
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.next_token = Some(input.into());
self
}
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.next_token = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DescribeSourceServersInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DescribeSourceServersInput {
filters: self.filters,
max_results: self.max_results.unwrap_or_default(),
next_token: self.next_token,
})
}
}
}
impl DescribeSourceServersInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DescribeSourceServers,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DescribeSourceServersInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DescribeSourceServers").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DescribeSourceServersInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_describe_source_servers(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DescribeSourceServers::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DescribeSourceServers",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::describe_source_servers_input::Builder {
crate::input::describe_source_servers_input::Builder::default()
}
}
pub mod disconnect_recovery_instance_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) recovery_instance_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn recovery_instance_id(mut self, input: impl Into<std::string::String>) -> Self {
self.recovery_instance_id = Some(input.into());
self
}
pub fn set_recovery_instance_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.recovery_instance_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DisconnectRecoveryInstanceInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DisconnectRecoveryInstanceInput {
recovery_instance_id: self.recovery_instance_id,
})
}
}
}
impl DisconnectRecoveryInstanceInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DisconnectRecoveryInstance,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DisconnectRecoveryInstanceInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DisconnectRecoveryInstance").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DisconnectRecoveryInstanceInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_disconnect_recovery_instance(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DisconnectRecoveryInstance::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DisconnectRecoveryInstance",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::disconnect_recovery_instance_input::Builder {
crate::input::disconnect_recovery_instance_input::Builder::default()
}
}
pub mod disconnect_source_server_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::DisconnectSourceServerInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::DisconnectSourceServerInput {
source_server_id: self.source_server_id,
})
}
}
}
impl DisconnectSourceServerInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::DisconnectSourceServer,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::DisconnectSourceServerInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/DisconnectSourceServer").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::DisconnectSourceServerInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_disconnect_source_server(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::DisconnectSourceServer::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"DisconnectSourceServer",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::disconnect_source_server_input::Builder {
crate::input::disconnect_source_server_input::Builder::default()
}
}
pub mod get_failback_replication_configuration_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) recovery_instance_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn recovery_instance_id(mut self, input: impl Into<std::string::String>) -> Self {
self.recovery_instance_id = Some(input.into());
self
}
pub fn set_recovery_instance_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.recovery_instance_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::GetFailbackReplicationConfigurationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::GetFailbackReplicationConfigurationInput {
recovery_instance_id: self.recovery_instance_id,
})
}
}
}
impl GetFailbackReplicationConfigurationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::GetFailbackReplicationConfiguration,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::GetFailbackReplicationConfigurationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/GetFailbackReplicationConfiguration")
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::GetFailbackReplicationConfigurationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_get_failback_replication_configuration(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::GetFailbackReplicationConfiguration::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"GetFailbackReplicationConfiguration",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::get_failback_replication_configuration_input::Builder {
crate::input::get_failback_replication_configuration_input::Builder::default()
}
}
pub mod get_launch_configuration_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::GetLaunchConfigurationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::GetLaunchConfigurationInput {
source_server_id: self.source_server_id,
})
}
}
}
impl GetLaunchConfigurationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::GetLaunchConfiguration,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::GetLaunchConfigurationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/GetLaunchConfiguration").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::GetLaunchConfigurationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_get_launch_configuration(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::GetLaunchConfiguration::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"GetLaunchConfiguration",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::get_launch_configuration_input::Builder {
crate::input::get_launch_configuration_input::Builder::default()
}
}
pub mod get_replication_configuration_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::GetReplicationConfigurationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::GetReplicationConfigurationInput {
source_server_id: self.source_server_id,
})
}
}
}
impl GetReplicationConfigurationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::GetReplicationConfiguration,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::GetReplicationConfigurationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/GetReplicationConfiguration").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::GetReplicationConfigurationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_get_replication_configuration(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::GetReplicationConfiguration::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"GetReplicationConfiguration",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::get_replication_configuration_input::Builder {
crate::input::get_replication_configuration_input::Builder::default()
}
}
pub mod initialize_service_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {}
impl Builder {
pub fn build(
self,
) -> Result<
crate::input::InitializeServiceInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::InitializeServiceInput {})
}
}
}
impl InitializeServiceInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::InitializeService,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::InitializeServiceInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/InitializeService").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::InitializeServiceInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from("");
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::InitializeService::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"InitializeService",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::initialize_service_input::Builder {
crate::input::initialize_service_input::Builder::default()
}
}
pub mod list_extensible_source_servers_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) staging_account_id: std::option::Option<std::string::String>,
pub(crate) max_results: std::option::Option<i32>,
pub(crate) next_token: std::option::Option<std::string::String>,
}
impl Builder {
pub fn staging_account_id(mut self, input: impl Into<std::string::String>) -> Self {
self.staging_account_id = Some(input.into());
self
}
pub fn set_staging_account_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.staging_account_id = input;
self
}
pub fn max_results(mut self, input: i32) -> Self {
self.max_results = Some(input);
self
}
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.max_results = input;
self
}
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.next_token = Some(input.into());
self
}
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.next_token = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::ListExtensibleSourceServersInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::ListExtensibleSourceServersInput {
staging_account_id: self.staging_account_id,
max_results: self.max_results.unwrap_or_default(),
next_token: self.next_token,
})
}
}
}
impl ListExtensibleSourceServersInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::ListExtensibleSourceServers,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::ListExtensibleSourceServersInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/ListExtensibleSourceServers").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::ListExtensibleSourceServersInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_list_extensible_source_servers(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::ListExtensibleSourceServers::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"ListExtensibleSourceServers",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::list_extensible_source_servers_input::Builder {
crate::input::list_extensible_source_servers_input::Builder::default()
}
}
pub mod list_staging_accounts_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) max_results: std::option::Option<i32>,
pub(crate) next_token: std::option::Option<std::string::String>,
}
impl Builder {
pub fn max_results(mut self, input: i32) -> Self {
self.max_results = Some(input);
self
}
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.max_results = input;
self
}
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.next_token = Some(input.into());
self
}
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.next_token = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::ListStagingAccountsInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::ListStagingAccountsInput {
max_results: self.max_results,
next_token: self.next_token,
})
}
}
}
impl ListStagingAccountsInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::ListStagingAccounts,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::ListStagingAccountsInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/ListStagingAccounts").expect("formatting should succeed");
Ok(())
}
fn uri_query(
_input: &crate::input::ListStagingAccountsInput,
mut output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
let mut query = aws_smithy_http::query::Writer::new(&mut output);
if let Some(inner_1) = &_input.max_results {
if *inner_1 != 0 {
query.push_kv(
"maxResults",
aws_smithy_types::primitive::Encoder::from(*inner_1).encode(),
);
}
}
if let Some(inner_2) = &_input.next_token {
{
query.push_kv("nextToken", &aws_smithy_http::query::fmt_string(&inner_2));
}
}
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::ListStagingAccountsInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
uri_query(input, &mut uri)?;
Ok(builder.method("GET").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from("");
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::ListStagingAccounts::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"ListStagingAccounts",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::list_staging_accounts_input::Builder {
crate::input::list_staging_accounts_input::Builder::default()
}
}
pub mod list_tags_for_resource_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) resource_arn: std::option::Option<std::string::String>,
}
impl Builder {
pub fn resource_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.resource_arn = Some(input.into());
self
}
pub fn set_resource_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.resource_arn = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::ListTagsForResourceInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::ListTagsForResourceInput {
resource_arn: self.resource_arn,
})
}
}
}
impl ListTagsForResourceInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::ListTagsForResource,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::ListTagsForResourceInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
let input_3 = &_input.resource_arn;
let input_3 = input_3.as_ref().ok_or_else(|| {
aws_smithy_http::operation::error::BuildError::missing_field(
"resource_arn",
"cannot be empty or unset",
)
})?;
let resource_arn = aws_smithy_http::label::fmt_string(
input_3,
aws_smithy_http::label::EncodingStrategy::Default,
);
if resource_arn.is_empty() {
return Err(
aws_smithy_http::operation::error::BuildError::missing_field(
"resource_arn",
"cannot be empty or unset",
),
);
}
write!(output, "/tags/{resourceArn}", resourceArn = resource_arn)
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::ListTagsForResourceInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("GET").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from("");
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::ListTagsForResource::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"ListTagsForResource",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::list_tags_for_resource_input::Builder {
crate::input::list_tags_for_resource_input::Builder::default()
}
}
pub mod retry_data_replication_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::RetryDataReplicationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::RetryDataReplicationInput {
source_server_id: self.source_server_id,
})
}
}
}
impl RetryDataReplicationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::RetryDataReplication,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::RetryDataReplicationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/RetryDataReplication").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::RetryDataReplicationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_retry_data_replication(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::RetryDataReplication::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"RetryDataReplication",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::retry_data_replication_input::Builder {
crate::input::retry_data_replication_input::Builder::default()
}
}
pub mod reverse_replication_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) recovery_instance_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn recovery_instance_id(mut self, input: impl Into<std::string::String>) -> Self {
self.recovery_instance_id = Some(input.into());
self
}
pub fn set_recovery_instance_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.recovery_instance_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::ReverseReplicationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::ReverseReplicationInput {
recovery_instance_id: self.recovery_instance_id,
})
}
}
}
impl ReverseReplicationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::ReverseReplication,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::ReverseReplicationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/ReverseReplication").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::ReverseReplicationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_reverse_replication(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::ReverseReplication::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"ReverseReplication",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::reverse_replication_input::Builder {
crate::input::reverse_replication_input::Builder::default()
}
}
pub mod start_failback_launch_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default)]
pub struct Builder {
pub(crate) recovery_instance_i_ds: std::option::Option<std::vec::Vec<std::string::String>>,
pub(crate) tags: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
}
impl Builder {
pub fn recovery_instance_i_ds(mut self, input: impl Into<std::string::String>) -> Self {
let mut v = self.recovery_instance_i_ds.unwrap_or_default();
v.push(input.into());
self.recovery_instance_i_ds = Some(v);
self
}
pub fn set_recovery_instance_i_ds(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.recovery_instance_i_ds = input;
self
}
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
let mut hash_map = self.tags.unwrap_or_default();
hash_map.insert(k.into(), v.into());
self.tags = Some(hash_map);
self
}
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.tags = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::StartFailbackLaunchInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::StartFailbackLaunchInput {
recovery_instance_i_ds: self.recovery_instance_i_ds,
tags: self.tags,
})
}
}
impl std::fmt::Debug for Builder {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("Builder");
formatter.field("recovery_instance_i_ds", &self.recovery_instance_i_ds);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
}
impl StartFailbackLaunchInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::StartFailbackLaunch,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::StartFailbackLaunchInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/StartFailbackLaunch").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::StartFailbackLaunchInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_start_failback_launch(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::StartFailbackLaunch::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"StartFailbackLaunch",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::start_failback_launch_input::Builder {
crate::input::start_failback_launch_input::Builder::default()
}
}
pub mod start_recovery_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default)]
pub struct Builder {
pub(crate) source_servers:
std::option::Option<std::vec::Vec<crate::model::StartRecoveryRequestSourceServer>>,
pub(crate) is_drill: std::option::Option<bool>,
pub(crate) tags: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
}
impl Builder {
pub fn source_servers(
mut self,
input: crate::model::StartRecoveryRequestSourceServer,
) -> Self {
let mut v = self.source_servers.unwrap_or_default();
v.push(input);
self.source_servers = Some(v);
self
}
pub fn set_source_servers(
mut self,
input: std::option::Option<
std::vec::Vec<crate::model::StartRecoveryRequestSourceServer>,
>,
) -> Self {
self.source_servers = input;
self
}
pub fn is_drill(mut self, input: bool) -> Self {
self.is_drill = Some(input);
self
}
pub fn set_is_drill(mut self, input: std::option::Option<bool>) -> Self {
self.is_drill = input;
self
}
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
let mut hash_map = self.tags.unwrap_or_default();
hash_map.insert(k.into(), v.into());
self.tags = Some(hash_map);
self
}
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.tags = input;
self
}
pub fn build(
self,
) -> Result<crate::input::StartRecoveryInput, aws_smithy_http::operation::error::BuildError>
{
Ok(crate::input::StartRecoveryInput {
source_servers: self.source_servers,
is_drill: self.is_drill,
tags: self.tags,
})
}
}
impl std::fmt::Debug for Builder {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("Builder");
formatter.field("source_servers", &self.source_servers);
formatter.field("is_drill", &self.is_drill);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
}
impl StartRecoveryInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::StartRecovery,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::StartRecoveryInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/StartRecovery").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::StartRecoveryInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_start_recovery(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::StartRecovery::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"StartRecovery",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::start_recovery_input::Builder {
crate::input::start_recovery_input::Builder::default()
}
}
pub mod start_replication_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::StartReplicationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::StartReplicationInput {
source_server_id: self.source_server_id,
})
}
}
}
impl StartReplicationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::StartReplication,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::StartReplicationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/StartReplication").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::StartReplicationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_start_replication(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::StartReplication::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"StartReplication",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::start_replication_input::Builder {
crate::input::start_replication_input::Builder::default()
}
}
pub mod stop_failback_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) recovery_instance_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn recovery_instance_id(mut self, input: impl Into<std::string::String>) -> Self {
self.recovery_instance_id = Some(input.into());
self
}
pub fn set_recovery_instance_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.recovery_instance_id = input;
self
}
pub fn build(
self,
) -> Result<crate::input::StopFailbackInput, aws_smithy_http::operation::error::BuildError>
{
Ok(crate::input::StopFailbackInput {
recovery_instance_id: self.recovery_instance_id,
})
}
}
}
impl StopFailbackInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::StopFailback,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::StopFailbackInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/StopFailback").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::StopFailbackInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_stop_failback(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::StopFailback::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"StopFailback",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::stop_failback_input::Builder {
crate::input::stop_failback_input::Builder::default()
}
}
pub mod stop_replication_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn build(
self,
) -> Result<crate::input::StopReplicationInput, aws_smithy_http::operation::error::BuildError>
{
Ok(crate::input::StopReplicationInput {
source_server_id: self.source_server_id,
})
}
}
}
impl StopReplicationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::StopReplication,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::StopReplicationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/StopReplication").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::StopReplicationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_stop_replication(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::StopReplication::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"StopReplication",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::stop_replication_input::Builder {
crate::input::stop_replication_input::Builder::default()
}
}
pub mod tag_resource_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default)]
pub struct Builder {
pub(crate) resource_arn: std::option::Option<std::string::String>,
pub(crate) tags: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
}
impl Builder {
pub fn resource_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.resource_arn = Some(input.into());
self
}
pub fn set_resource_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.resource_arn = input;
self
}
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
let mut hash_map = self.tags.unwrap_or_default();
hash_map.insert(k.into(), v.into());
self.tags = Some(hash_map);
self
}
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.tags = input;
self
}
pub fn build(
self,
) -> Result<crate::input::TagResourceInput, aws_smithy_http::operation::error::BuildError>
{
Ok(crate::input::TagResourceInput {
resource_arn: self.resource_arn,
tags: self.tags,
})
}
}
impl std::fmt::Debug for Builder {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("Builder");
formatter.field("resource_arn", &self.resource_arn);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
}
impl TagResourceInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::TagResource,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::TagResourceInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
let input_4 = &_input.resource_arn;
let input_4 = input_4.as_ref().ok_or_else(|| {
aws_smithy_http::operation::error::BuildError::missing_field(
"resource_arn",
"cannot be empty or unset",
)
})?;
let resource_arn = aws_smithy_http::label::fmt_string(
input_4,
aws_smithy_http::label::EncodingStrategy::Default,
);
if resource_arn.is_empty() {
return Err(
aws_smithy_http::operation::error::BuildError::missing_field(
"resource_arn",
"cannot be empty or unset",
),
);
}
write!(output, "/tags/{resourceArn}", resourceArn = resource_arn)
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::TagResourceInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_tag_resource(&self)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::TagResource::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"TagResource",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::tag_resource_input::Builder {
crate::input::tag_resource_input::Builder::default()
}
}
pub mod terminate_recovery_instances_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) recovery_instance_i_ds: std::option::Option<std::vec::Vec<std::string::String>>,
}
impl Builder {
pub fn recovery_instance_i_ds(mut self, input: impl Into<std::string::String>) -> Self {
let mut v = self.recovery_instance_i_ds.unwrap_or_default();
v.push(input.into());
self.recovery_instance_i_ds = Some(v);
self
}
pub fn set_recovery_instance_i_ds(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.recovery_instance_i_ds = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::TerminateRecoveryInstancesInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::TerminateRecoveryInstancesInput {
recovery_instance_i_ds: self.recovery_instance_i_ds,
})
}
}
}
impl TerminateRecoveryInstancesInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::TerminateRecoveryInstances,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::TerminateRecoveryInstancesInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/TerminateRecoveryInstances").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::TerminateRecoveryInstancesInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_terminate_recovery_instances(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::TerminateRecoveryInstances::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"TerminateRecoveryInstances",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::terminate_recovery_instances_input::Builder {
crate::input::terminate_recovery_instances_input::Builder::default()
}
}
pub mod untag_resource_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default)]
pub struct Builder {
pub(crate) resource_arn: std::option::Option<std::string::String>,
pub(crate) tag_keys: std::option::Option<std::vec::Vec<std::string::String>>,
}
impl Builder {
pub fn resource_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.resource_arn = Some(input.into());
self
}
pub fn set_resource_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.resource_arn = input;
self
}
pub fn tag_keys(mut self, input: impl Into<std::string::String>) -> Self {
let mut v = self.tag_keys.unwrap_or_default();
v.push(input.into());
self.tag_keys = Some(v);
self
}
pub fn set_tag_keys(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.tag_keys = input;
self
}
pub fn build(
self,
) -> Result<crate::input::UntagResourceInput, aws_smithy_http::operation::error::BuildError>
{
Ok(crate::input::UntagResourceInput {
resource_arn: self.resource_arn,
tag_keys: self.tag_keys,
})
}
}
impl std::fmt::Debug for Builder {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("Builder");
formatter.field("resource_arn", &self.resource_arn);
formatter.field("tag_keys", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
}
impl UntagResourceInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::UntagResource,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::UntagResourceInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
let input_5 = &_input.resource_arn;
let input_5 = input_5.as_ref().ok_or_else(|| {
aws_smithy_http::operation::error::BuildError::missing_field(
"resource_arn",
"cannot be empty or unset",
)
})?;
let resource_arn = aws_smithy_http::label::fmt_string(
input_5,
aws_smithy_http::label::EncodingStrategy::Default,
);
if resource_arn.is_empty() {
return Err(
aws_smithy_http::operation::error::BuildError::missing_field(
"resource_arn",
"cannot be empty or unset",
),
);
}
write!(output, "/tags/{resourceArn}", resourceArn = resource_arn)
.expect("formatting should succeed");
Ok(())
}
fn uri_query(
_input: &crate::input::UntagResourceInput,
mut output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
let mut query = aws_smithy_http::query::Writer::new(&mut output);
let inner_6 = &_input.tag_keys;
let inner_6 = inner_6.as_ref().ok_or_else(|| {
aws_smithy_http::operation::error::BuildError::missing_field(
"tag_keys",
"cannot be empty or unset",
)
})?;
for inner_7 in inner_6 {
query.push_kv("tagKeys", &aws_smithy_http::query::fmt_string(&inner_7));
}
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::UntagResourceInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
uri_query(input, &mut uri)?;
Ok(builder.method("DELETE").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from("");
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::UntagResource::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"UntagResource",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::untag_resource_input::Builder {
crate::input::untag_resource_input::Builder::default()
}
}
pub mod update_failback_replication_configuration_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) recovery_instance_id: std::option::Option<std::string::String>,
pub(crate) name: std::option::Option<std::string::String>,
pub(crate) bandwidth_throttling: std::option::Option<i64>,
pub(crate) use_private_ip: std::option::Option<bool>,
}
impl Builder {
pub fn recovery_instance_id(mut self, input: impl Into<std::string::String>) -> Self {
self.recovery_instance_id = Some(input.into());
self
}
pub fn set_recovery_instance_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.recovery_instance_id = input;
self
}
pub fn name(mut self, input: impl Into<std::string::String>) -> Self {
self.name = Some(input.into());
self
}
pub fn set_name(mut self, input: std::option::Option<std::string::String>) -> Self {
self.name = input;
self
}
pub fn bandwidth_throttling(mut self, input: i64) -> Self {
self.bandwidth_throttling = Some(input);
self
}
pub fn set_bandwidth_throttling(mut self, input: std::option::Option<i64>) -> Self {
self.bandwidth_throttling = input;
self
}
pub fn use_private_ip(mut self, input: bool) -> Self {
self.use_private_ip = Some(input);
self
}
pub fn set_use_private_ip(mut self, input: std::option::Option<bool>) -> Self {
self.use_private_ip = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::UpdateFailbackReplicationConfigurationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::UpdateFailbackReplicationConfigurationInput {
recovery_instance_id: self.recovery_instance_id,
name: self.name,
bandwidth_throttling: self.bandwidth_throttling.unwrap_or_default(),
use_private_ip: self.use_private_ip,
})
}
}
}
impl UpdateFailbackReplicationConfigurationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::UpdateFailbackReplicationConfiguration,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::UpdateFailbackReplicationConfigurationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/UpdateFailbackReplicationConfiguration")
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::UpdateFailbackReplicationConfigurationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_update_failback_replication_configuration(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::UpdateFailbackReplicationConfiguration::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"UpdateFailbackReplicationConfiguration",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::update_failback_replication_configuration_input::Builder {
crate::input::update_failback_replication_configuration_input::Builder::default()
}
}
pub mod update_launch_configuration_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default, std::fmt::Debug)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
pub(crate) name: std::option::Option<std::string::String>,
pub(crate) launch_disposition: std::option::Option<crate::model::LaunchDisposition>,
pub(crate) target_instance_type_right_sizing_method:
std::option::Option<crate::model::TargetInstanceTypeRightSizingMethod>,
pub(crate) copy_private_ip: std::option::Option<bool>,
pub(crate) copy_tags: std::option::Option<bool>,
pub(crate) licensing: std::option::Option<crate::model::Licensing>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn name(mut self, input: impl Into<std::string::String>) -> Self {
self.name = Some(input.into());
self
}
pub fn set_name(mut self, input: std::option::Option<std::string::String>) -> Self {
self.name = input;
self
}
pub fn launch_disposition(mut self, input: crate::model::LaunchDisposition) -> Self {
self.launch_disposition = Some(input);
self
}
pub fn set_launch_disposition(
mut self,
input: std::option::Option<crate::model::LaunchDisposition>,
) -> Self {
self.launch_disposition = input;
self
}
pub fn target_instance_type_right_sizing_method(
mut self,
input: crate::model::TargetInstanceTypeRightSizingMethod,
) -> Self {
self.target_instance_type_right_sizing_method = Some(input);
self
}
pub fn set_target_instance_type_right_sizing_method(
mut self,
input: std::option::Option<crate::model::TargetInstanceTypeRightSizingMethod>,
) -> Self {
self.target_instance_type_right_sizing_method = input;
self
}
pub fn copy_private_ip(mut self, input: bool) -> Self {
self.copy_private_ip = Some(input);
self
}
pub fn set_copy_private_ip(mut self, input: std::option::Option<bool>) -> Self {
self.copy_private_ip = input;
self
}
pub fn copy_tags(mut self, input: bool) -> Self {
self.copy_tags = Some(input);
self
}
pub fn set_copy_tags(mut self, input: std::option::Option<bool>) -> Self {
self.copy_tags = input;
self
}
pub fn licensing(mut self, input: crate::model::Licensing) -> Self {
self.licensing = Some(input);
self
}
pub fn set_licensing(
mut self,
input: std::option::Option<crate::model::Licensing>,
) -> Self {
self.licensing = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::UpdateLaunchConfigurationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::UpdateLaunchConfigurationInput {
source_server_id: self.source_server_id,
name: self.name,
launch_disposition: self.launch_disposition,
target_instance_type_right_sizing_method: self
.target_instance_type_right_sizing_method,
copy_private_ip: self.copy_private_ip,
copy_tags: self.copy_tags,
licensing: self.licensing,
})
}
}
}
impl UpdateLaunchConfigurationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::UpdateLaunchConfiguration,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::UpdateLaunchConfigurationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/UpdateLaunchConfiguration").expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::UpdateLaunchConfigurationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_update_launch_configuration(
&self,
)?,
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::UpdateLaunchConfiguration::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"UpdateLaunchConfiguration",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::update_launch_configuration_input::Builder {
crate::input::update_launch_configuration_input::Builder::default()
}
}
pub mod update_replication_configuration_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default)]
pub struct Builder {
pub(crate) source_server_id: std::option::Option<std::string::String>,
pub(crate) name: std::option::Option<std::string::String>,
pub(crate) staging_area_subnet_id: std::option::Option<std::string::String>,
pub(crate) associate_default_security_group: std::option::Option<bool>,
pub(crate) replication_servers_security_groups_i_ds:
std::option::Option<std::vec::Vec<std::string::String>>,
pub(crate) replication_server_instance_type: std::option::Option<std::string::String>,
pub(crate) use_dedicated_replication_server: std::option::Option<bool>,
pub(crate) default_large_staging_disk_type:
std::option::Option<crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>,
pub(crate) replicated_disks: std::option::Option<
std::vec::Vec<crate::model::ReplicationConfigurationReplicatedDisk>,
>,
pub(crate) ebs_encryption:
std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
pub(crate) ebs_encryption_key_arn: std::option::Option<std::string::String>,
pub(crate) bandwidth_throttling: std::option::Option<i64>,
pub(crate) data_plane_routing:
std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
pub(crate) create_public_ip: std::option::Option<bool>,
pub(crate) staging_area_tags: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
pub(crate) pit_policy: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
}
impl Builder {
pub fn source_server_id(mut self, input: impl Into<std::string::String>) -> Self {
self.source_server_id = Some(input.into());
self
}
pub fn set_source_server_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.source_server_id = input;
self
}
pub fn name(mut self, input: impl Into<std::string::String>) -> Self {
self.name = Some(input.into());
self
}
pub fn set_name(mut self, input: std::option::Option<std::string::String>) -> Self {
self.name = input;
self
}
pub fn staging_area_subnet_id(mut self, input: impl Into<std::string::String>) -> Self {
self.staging_area_subnet_id = Some(input.into());
self
}
pub fn set_staging_area_subnet_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.staging_area_subnet_id = input;
self
}
pub fn associate_default_security_group(mut self, input: bool) -> Self {
self.associate_default_security_group = Some(input);
self
}
pub fn set_associate_default_security_group(
mut self,
input: std::option::Option<bool>,
) -> Self {
self.associate_default_security_group = input;
self
}
pub fn replication_servers_security_groups_i_ds(
mut self,
input: impl Into<std::string::String>,
) -> Self {
let mut v = self
.replication_servers_security_groups_i_ds
.unwrap_or_default();
v.push(input.into());
self.replication_servers_security_groups_i_ds = Some(v);
self
}
pub fn set_replication_servers_security_groups_i_ds(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.replication_servers_security_groups_i_ds = input;
self
}
pub fn replication_server_instance_type(
mut self,
input: impl Into<std::string::String>,
) -> Self {
self.replication_server_instance_type = Some(input.into());
self
}
pub fn set_replication_server_instance_type(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.replication_server_instance_type = input;
self
}
pub fn use_dedicated_replication_server(mut self, input: bool) -> Self {
self.use_dedicated_replication_server = Some(input);
self
}
pub fn set_use_dedicated_replication_server(
mut self,
input: std::option::Option<bool>,
) -> Self {
self.use_dedicated_replication_server = input;
self
}
pub fn default_large_staging_disk_type(
mut self,
input: crate::model::ReplicationConfigurationDefaultLargeStagingDiskType,
) -> Self {
self.default_large_staging_disk_type = Some(input);
self
}
pub fn set_default_large_staging_disk_type(
mut self,
input: std::option::Option<
crate::model::ReplicationConfigurationDefaultLargeStagingDiskType,
>,
) -> Self {
self.default_large_staging_disk_type = input;
self
}
pub fn replicated_disks(
mut self,
input: crate::model::ReplicationConfigurationReplicatedDisk,
) -> Self {
let mut v = self.replicated_disks.unwrap_or_default();
v.push(input);
self.replicated_disks = Some(v);
self
}
pub fn set_replicated_disks(
mut self,
input: std::option::Option<
std::vec::Vec<crate::model::ReplicationConfigurationReplicatedDisk>,
>,
) -> Self {
self.replicated_disks = input;
self
}
pub fn ebs_encryption(
mut self,
input: crate::model::ReplicationConfigurationEbsEncryption,
) -> Self {
self.ebs_encryption = Some(input);
self
}
pub fn set_ebs_encryption(
mut self,
input: std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
) -> Self {
self.ebs_encryption = input;
self
}
pub fn ebs_encryption_key_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.ebs_encryption_key_arn = Some(input.into());
self
}
pub fn set_ebs_encryption_key_arn(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.ebs_encryption_key_arn = input;
self
}
pub fn bandwidth_throttling(mut self, input: i64) -> Self {
self.bandwidth_throttling = Some(input);
self
}
pub fn set_bandwidth_throttling(mut self, input: std::option::Option<i64>) -> Self {
self.bandwidth_throttling = input;
self
}
pub fn data_plane_routing(
mut self,
input: crate::model::ReplicationConfigurationDataPlaneRouting,
) -> Self {
self.data_plane_routing = Some(input);
self
}
pub fn set_data_plane_routing(
mut self,
input: std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
) -> Self {
self.data_plane_routing = input;
self
}
pub fn create_public_ip(mut self, input: bool) -> Self {
self.create_public_ip = Some(input);
self
}
pub fn set_create_public_ip(mut self, input: std::option::Option<bool>) -> Self {
self.create_public_ip = input;
self
}
pub fn staging_area_tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
let mut hash_map = self.staging_area_tags.unwrap_or_default();
hash_map.insert(k.into(), v.into());
self.staging_area_tags = Some(hash_map);
self
}
pub fn set_staging_area_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.staging_area_tags = input;
self
}
pub fn pit_policy(mut self, input: crate::model::PitPolicyRule) -> Self {
let mut v = self.pit_policy.unwrap_or_default();
v.push(input);
self.pit_policy = Some(v);
self
}
pub fn set_pit_policy(
mut self,
input: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
) -> Self {
self.pit_policy = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::UpdateReplicationConfigurationInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::UpdateReplicationConfigurationInput {
source_server_id: self.source_server_id,
name: self.name,
staging_area_subnet_id: self.staging_area_subnet_id,
associate_default_security_group: self.associate_default_security_group,
replication_servers_security_groups_i_ds: self
.replication_servers_security_groups_i_ds,
replication_server_instance_type: self.replication_server_instance_type,
use_dedicated_replication_server: self.use_dedicated_replication_server,
default_large_staging_disk_type: self.default_large_staging_disk_type,
replicated_disks: self.replicated_disks,
ebs_encryption: self.ebs_encryption,
ebs_encryption_key_arn: self.ebs_encryption_key_arn,
bandwidth_throttling: self.bandwidth_throttling.unwrap_or_default(),
data_plane_routing: self.data_plane_routing,
create_public_ip: self.create_public_ip,
staging_area_tags: self.staging_area_tags,
pit_policy: self.pit_policy,
})
}
}
impl std::fmt::Debug for Builder {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("Builder");
formatter.field("source_server_id", &self.source_server_id);
formatter.field("name", &self.name);
formatter.field("staging_area_subnet_id", &self.staging_area_subnet_id);
formatter.field(
"associate_default_security_group",
&self.associate_default_security_group,
);
formatter.field(
"replication_servers_security_groups_i_ds",
&self.replication_servers_security_groups_i_ds,
);
formatter.field(
"replication_server_instance_type",
&self.replication_server_instance_type,
);
formatter.field(
"use_dedicated_replication_server",
&self.use_dedicated_replication_server,
);
formatter.field(
"default_large_staging_disk_type",
&self.default_large_staging_disk_type,
);
formatter.field("replicated_disks", &self.replicated_disks);
formatter.field("ebs_encryption", &self.ebs_encryption);
formatter.field("ebs_encryption_key_arn", &self.ebs_encryption_key_arn);
formatter.field("bandwidth_throttling", &self.bandwidth_throttling);
formatter.field("data_plane_routing", &self.data_plane_routing);
formatter.field("create_public_ip", &self.create_public_ip);
formatter.field("staging_area_tags", &"*** Sensitive Data Redacted ***");
formatter.field("pit_policy", &self.pit_policy);
formatter.finish()
}
}
}
impl UpdateReplicationConfigurationInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::UpdateReplicationConfiguration,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::UpdateReplicationConfigurationInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/UpdateReplicationConfiguration")
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::UpdateReplicationConfigurationInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_update_replication_configuration(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::UpdateReplicationConfiguration::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"UpdateReplicationConfiguration",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::update_replication_configuration_input::Builder {
crate::input::update_replication_configuration_input::Builder::default()
}
}
pub mod update_replication_configuration_template_input {
#[derive(std::clone::Clone, std::cmp::PartialEq, std::default::Default)]
pub struct Builder {
pub(crate) replication_configuration_template_id: std::option::Option<std::string::String>,
pub(crate) arn: std::option::Option<std::string::String>,
pub(crate) staging_area_subnet_id: std::option::Option<std::string::String>,
pub(crate) associate_default_security_group: std::option::Option<bool>,
pub(crate) replication_servers_security_groups_i_ds:
std::option::Option<std::vec::Vec<std::string::String>>,
pub(crate) replication_server_instance_type: std::option::Option<std::string::String>,
pub(crate) use_dedicated_replication_server: std::option::Option<bool>,
pub(crate) default_large_staging_disk_type:
std::option::Option<crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>,
pub(crate) ebs_encryption:
std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
pub(crate) ebs_encryption_key_arn: std::option::Option<std::string::String>,
pub(crate) bandwidth_throttling: std::option::Option<i64>,
pub(crate) data_plane_routing:
std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
pub(crate) create_public_ip: std::option::Option<bool>,
pub(crate) staging_area_tags: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
pub(crate) pit_policy: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
}
impl Builder {
pub fn replication_configuration_template_id(
mut self,
input: impl Into<std::string::String>,
) -> Self {
self.replication_configuration_template_id = Some(input.into());
self
}
pub fn set_replication_configuration_template_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.replication_configuration_template_id = input;
self
}
pub fn arn(mut self, input: impl Into<std::string::String>) -> Self {
self.arn = Some(input.into());
self
}
pub fn set_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.arn = input;
self
}
pub fn staging_area_subnet_id(mut self, input: impl Into<std::string::String>) -> Self {
self.staging_area_subnet_id = Some(input.into());
self
}
pub fn set_staging_area_subnet_id(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.staging_area_subnet_id = input;
self
}
pub fn associate_default_security_group(mut self, input: bool) -> Self {
self.associate_default_security_group = Some(input);
self
}
pub fn set_associate_default_security_group(
mut self,
input: std::option::Option<bool>,
) -> Self {
self.associate_default_security_group = input;
self
}
pub fn replication_servers_security_groups_i_ds(
mut self,
input: impl Into<std::string::String>,
) -> Self {
let mut v = self
.replication_servers_security_groups_i_ds
.unwrap_or_default();
v.push(input.into());
self.replication_servers_security_groups_i_ds = Some(v);
self
}
pub fn set_replication_servers_security_groups_i_ds(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.replication_servers_security_groups_i_ds = input;
self
}
pub fn replication_server_instance_type(
mut self,
input: impl Into<std::string::String>,
) -> Self {
self.replication_server_instance_type = Some(input.into());
self
}
pub fn set_replication_server_instance_type(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.replication_server_instance_type = input;
self
}
pub fn use_dedicated_replication_server(mut self, input: bool) -> Self {
self.use_dedicated_replication_server = Some(input);
self
}
pub fn set_use_dedicated_replication_server(
mut self,
input: std::option::Option<bool>,
) -> Self {
self.use_dedicated_replication_server = input;
self
}
pub fn default_large_staging_disk_type(
mut self,
input: crate::model::ReplicationConfigurationDefaultLargeStagingDiskType,
) -> Self {
self.default_large_staging_disk_type = Some(input);
self
}
pub fn set_default_large_staging_disk_type(
mut self,
input: std::option::Option<
crate::model::ReplicationConfigurationDefaultLargeStagingDiskType,
>,
) -> Self {
self.default_large_staging_disk_type = input;
self
}
pub fn ebs_encryption(
mut self,
input: crate::model::ReplicationConfigurationEbsEncryption,
) -> Self {
self.ebs_encryption = Some(input);
self
}
pub fn set_ebs_encryption(
mut self,
input: std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
) -> Self {
self.ebs_encryption = input;
self
}
pub fn ebs_encryption_key_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.ebs_encryption_key_arn = Some(input.into());
self
}
pub fn set_ebs_encryption_key_arn(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.ebs_encryption_key_arn = input;
self
}
pub fn bandwidth_throttling(mut self, input: i64) -> Self {
self.bandwidth_throttling = Some(input);
self
}
pub fn set_bandwidth_throttling(mut self, input: std::option::Option<i64>) -> Self {
self.bandwidth_throttling = input;
self
}
pub fn data_plane_routing(
mut self,
input: crate::model::ReplicationConfigurationDataPlaneRouting,
) -> Self {
self.data_plane_routing = Some(input);
self
}
pub fn set_data_plane_routing(
mut self,
input: std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
) -> Self {
self.data_plane_routing = input;
self
}
pub fn create_public_ip(mut self, input: bool) -> Self {
self.create_public_ip = Some(input);
self
}
pub fn set_create_public_ip(mut self, input: std::option::Option<bool>) -> Self {
self.create_public_ip = input;
self
}
pub fn staging_area_tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
let mut hash_map = self.staging_area_tags.unwrap_or_default();
hash_map.insert(k.into(), v.into());
self.staging_area_tags = Some(hash_map);
self
}
pub fn set_staging_area_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.staging_area_tags = input;
self
}
pub fn pit_policy(mut self, input: crate::model::PitPolicyRule) -> Self {
let mut v = self.pit_policy.unwrap_or_default();
v.push(input);
self.pit_policy = Some(v);
self
}
pub fn set_pit_policy(
mut self,
input: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
) -> Self {
self.pit_policy = input;
self
}
pub fn build(
self,
) -> Result<
crate::input::UpdateReplicationConfigurationTemplateInput,
aws_smithy_http::operation::error::BuildError,
> {
Ok(crate::input::UpdateReplicationConfigurationTemplateInput {
replication_configuration_template_id: self.replication_configuration_template_id,
arn: self.arn,
staging_area_subnet_id: self.staging_area_subnet_id,
associate_default_security_group: self.associate_default_security_group,
replication_servers_security_groups_i_ds: self
.replication_servers_security_groups_i_ds,
replication_server_instance_type: self.replication_server_instance_type,
use_dedicated_replication_server: self.use_dedicated_replication_server,
default_large_staging_disk_type: self.default_large_staging_disk_type,
ebs_encryption: self.ebs_encryption,
ebs_encryption_key_arn: self.ebs_encryption_key_arn,
bandwidth_throttling: self.bandwidth_throttling.unwrap_or_default(),
data_plane_routing: self.data_plane_routing,
create_public_ip: self.create_public_ip,
staging_area_tags: self.staging_area_tags,
pit_policy: self.pit_policy,
})
}
}
impl std::fmt::Debug for Builder {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("Builder");
formatter.field(
"replication_configuration_template_id",
&self.replication_configuration_template_id,
);
formatter.field("arn", &self.arn);
formatter.field("staging_area_subnet_id", &self.staging_area_subnet_id);
formatter.field(
"associate_default_security_group",
&self.associate_default_security_group,
);
formatter.field(
"replication_servers_security_groups_i_ds",
&self.replication_servers_security_groups_i_ds,
);
formatter.field(
"replication_server_instance_type",
&self.replication_server_instance_type,
);
formatter.field(
"use_dedicated_replication_server",
&self.use_dedicated_replication_server,
);
formatter.field(
"default_large_staging_disk_type",
&self.default_large_staging_disk_type,
);
formatter.field("ebs_encryption", &self.ebs_encryption);
formatter.field("ebs_encryption_key_arn", &self.ebs_encryption_key_arn);
formatter.field("bandwidth_throttling", &self.bandwidth_throttling);
formatter.field("data_plane_routing", &self.data_plane_routing);
formatter.field("create_public_ip", &self.create_public_ip);
formatter.field("staging_area_tags", &"*** Sensitive Data Redacted ***");
formatter.field("pit_policy", &self.pit_policy);
formatter.finish()
}
}
}
impl UpdateReplicationConfigurationTemplateInput {
#[allow(unused_mut)]
#[allow(clippy::let_and_return)]
#[allow(clippy::needless_borrow)]
pub async fn make_operation(
&self,
_config: &crate::config::Config,
) -> std::result::Result<
aws_smithy_http::operation::Operation<
crate::operation::UpdateReplicationConfigurationTemplate,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::operation::error::BuildError,
> {
let params_result = crate::endpoint::Params::builder()
.set_region(_config.region.as_ref().map(|r| r.as_ref().to_owned()))
.set_use_dual_stack(_config.use_dual_stack)
.set_use_fips(_config.use_fips)
.set_endpoint(_config.endpoint_url.clone())
.build()
.map_err(|err| {
aws_smithy_http::endpoint::ResolveEndpointError::from_source(
"could not construct endpoint parameters",
err,
)
});
let (endpoint_result, params) = match params_result {
Ok(params) => (
_config.endpoint_resolver.resolve_endpoint(¶ms),
Some(params),
),
Err(e) => (Err(e), None),
};
let mut request = {
fn uri_base(
_input: &crate::input::UpdateReplicationConfigurationTemplateInput,
output: &mut String,
) -> Result<(), aws_smithy_http::operation::error::BuildError> {
write!(output, "/UpdateReplicationConfigurationTemplate")
.expect("formatting should succeed");
Ok(())
}
#[allow(clippy::unnecessary_wraps)]
fn update_http_builder(
input: &crate::input::UpdateReplicationConfigurationTemplateInput,
builder: http::request::Builder,
) -> std::result::Result<
http::request::Builder,
aws_smithy_http::operation::error::BuildError,
> {
let mut uri = String::new();
uri_base(input, &mut uri)?;
Ok(builder.method("POST").uri(uri))
}
let mut builder = update_http_builder(&self, http::request::Builder::new())?;
builder = aws_smithy_http::header::set_request_header_if_absent(
builder,
http::header::CONTENT_TYPE,
"application/json",
);
builder
};
let mut properties = aws_smithy_http::property_bag::SharedPropertyBag::new();
#[allow(clippy::useless_conversion)]
let body = aws_smithy_http::body::SdkBody::from(
crate::operation_ser::serialize_operation_crate_operation_update_replication_configuration_template(&self)?
);
if let Some(content_length) = body.content_length() {
request = aws_smithy_http::header::set_request_header_if_absent(
request,
http::header::CONTENT_LENGTH,
content_length,
);
}
let request = request.body(body).expect("should be valid request");
let mut request = aws_smithy_http::operation::Request::from_parts(request, properties);
request.properties_mut().insert(endpoint_result);
if let Some(params) = params {
request.properties_mut().insert(params);
}
request
.properties_mut()
.insert(aws_smithy_http::http_versions::DEFAULT_HTTP_VERSION_LIST.clone());
let mut user_agent = aws_http::user_agent::AwsUserAgent::new_from_environment(
aws_types::os_shim_internal::Env::real(),
crate::API_METADATA.clone(),
);
if let Some(app_name) = _config.app_name() {
user_agent = user_agent.with_app_name(app_name.clone());
}
request.properties_mut().insert(user_agent);
let mut signing_config = aws_sig_auth::signer::OperationSigningConfig::default_config();
request.properties_mut().insert(signing_config);
request
.properties_mut()
.insert(aws_types::SigningService::from_static(
_config.signing_service(),
));
if let Some(region) = &_config.region {
request
.properties_mut()
.insert(aws_types::region::SigningRegion::from(region.clone()));
}
if let Some(region) = &_config.region {
request.properties_mut().insert(region.clone());
}
aws_http::auth::set_credentials_cache(
&mut request.properties_mut(),
_config.credentials_cache.clone(),
);
let op = aws_smithy_http::operation::Operation::new(
request,
crate::operation::UpdateReplicationConfigurationTemplate::new(),
)
.with_metadata(aws_smithy_http::operation::Metadata::new(
"UpdateReplicationConfigurationTemplate",
"drs",
));
let op = op.with_retry_classifier(aws_http::retry::AwsResponseRetryClassifier::new());
Ok(op)
}
pub fn builder() -> crate::input::update_replication_configuration_template_input::Builder {
crate::input::update_replication_configuration_template_input::Builder::default()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq)]
pub struct UpdateReplicationConfigurationInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub name: std::option::Option<std::string::String>,
#[doc(hidden)]
pub staging_area_subnet_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub associate_default_security_group: std::option::Option<bool>,
#[doc(hidden)]
pub replication_servers_security_groups_i_ds:
std::option::Option<std::vec::Vec<std::string::String>>,
#[doc(hidden)]
pub replication_server_instance_type: std::option::Option<std::string::String>,
#[doc(hidden)]
pub use_dedicated_replication_server: std::option::Option<bool>,
#[doc(hidden)]
pub default_large_staging_disk_type:
std::option::Option<crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>,
#[doc(hidden)]
pub replicated_disks:
std::option::Option<std::vec::Vec<crate::model::ReplicationConfigurationReplicatedDisk>>,
#[doc(hidden)]
pub ebs_encryption: std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
#[doc(hidden)]
pub ebs_encryption_key_arn: std::option::Option<std::string::String>,
#[doc(hidden)]
pub bandwidth_throttling: i64,
#[doc(hidden)]
pub data_plane_routing:
std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
#[doc(hidden)]
pub create_public_ip: std::option::Option<bool>,
#[doc(hidden)]
pub staging_area_tags:
std::option::Option<std::collections::HashMap<std::string::String, std::string::String>>,
#[doc(hidden)]
pub pit_policy: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
}
impl UpdateReplicationConfigurationInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
pub fn name(&self) -> std::option::Option<&str> {
self.name.as_deref()
}
pub fn staging_area_subnet_id(&self) -> std::option::Option<&str> {
self.staging_area_subnet_id.as_deref()
}
pub fn associate_default_security_group(&self) -> std::option::Option<bool> {
self.associate_default_security_group
}
pub fn replication_servers_security_groups_i_ds(
&self,
) -> std::option::Option<&[std::string::String]> {
self.replication_servers_security_groups_i_ds.as_deref()
}
pub fn replication_server_instance_type(&self) -> std::option::Option<&str> {
self.replication_server_instance_type.as_deref()
}
pub fn use_dedicated_replication_server(&self) -> std::option::Option<bool> {
self.use_dedicated_replication_server
}
pub fn default_large_staging_disk_type(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>
{
self.default_large_staging_disk_type.as_ref()
}
pub fn replicated_disks(
&self,
) -> std::option::Option<&[crate::model::ReplicationConfigurationReplicatedDisk]> {
self.replicated_disks.as_deref()
}
pub fn ebs_encryption(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationEbsEncryption> {
self.ebs_encryption.as_ref()
}
pub fn ebs_encryption_key_arn(&self) -> std::option::Option<&str> {
self.ebs_encryption_key_arn.as_deref()
}
pub fn bandwidth_throttling(&self) -> i64 {
self.bandwidth_throttling
}
pub fn data_plane_routing(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationDataPlaneRouting> {
self.data_plane_routing.as_ref()
}
pub fn create_public_ip(&self) -> std::option::Option<bool> {
self.create_public_ip
}
pub fn staging_area_tags(
&self,
) -> std::option::Option<&std::collections::HashMap<std::string::String, std::string::String>>
{
self.staging_area_tags.as_ref()
}
pub fn pit_policy(&self) -> std::option::Option<&[crate::model::PitPolicyRule]> {
self.pit_policy.as_deref()
}
}
impl std::fmt::Debug for UpdateReplicationConfigurationInput {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("UpdateReplicationConfigurationInput");
formatter.field("source_server_id", &self.source_server_id);
formatter.field("name", &self.name);
formatter.field("staging_area_subnet_id", &self.staging_area_subnet_id);
formatter.field(
"associate_default_security_group",
&self.associate_default_security_group,
);
formatter.field(
"replication_servers_security_groups_i_ds",
&self.replication_servers_security_groups_i_ds,
);
formatter.field(
"replication_server_instance_type",
&self.replication_server_instance_type,
);
formatter.field(
"use_dedicated_replication_server",
&self.use_dedicated_replication_server,
);
formatter.field(
"default_large_staging_disk_type",
&self.default_large_staging_disk_type,
);
formatter.field("replicated_disks", &self.replicated_disks);
formatter.field("ebs_encryption", &self.ebs_encryption);
formatter.field("ebs_encryption_key_arn", &self.ebs_encryption_key_arn);
formatter.field("bandwidth_throttling", &self.bandwidth_throttling);
formatter.field("data_plane_routing", &self.data_plane_routing);
formatter.field("create_public_ip", &self.create_public_ip);
formatter.field("staging_area_tags", &"*** Sensitive Data Redacted ***");
formatter.field("pit_policy", &self.pit_policy);
formatter.finish()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct UpdateLaunchConfigurationInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub name: std::option::Option<std::string::String>,
#[doc(hidden)]
pub launch_disposition: std::option::Option<crate::model::LaunchDisposition>,
#[doc(hidden)]
pub target_instance_type_right_sizing_method:
std::option::Option<crate::model::TargetInstanceTypeRightSizingMethod>,
#[doc(hidden)]
pub copy_private_ip: std::option::Option<bool>,
#[doc(hidden)]
pub copy_tags: std::option::Option<bool>,
#[doc(hidden)]
pub licensing: std::option::Option<crate::model::Licensing>,
}
impl UpdateLaunchConfigurationInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
pub fn name(&self) -> std::option::Option<&str> {
self.name.as_deref()
}
pub fn launch_disposition(&self) -> std::option::Option<&crate::model::LaunchDisposition> {
self.launch_disposition.as_ref()
}
pub fn target_instance_type_right_sizing_method(
&self,
) -> std::option::Option<&crate::model::TargetInstanceTypeRightSizingMethod> {
self.target_instance_type_right_sizing_method.as_ref()
}
pub fn copy_private_ip(&self) -> std::option::Option<bool> {
self.copy_private_ip
}
pub fn copy_tags(&self) -> std::option::Option<bool> {
self.copy_tags
}
pub fn licensing(&self) -> std::option::Option<&crate::model::Licensing> {
self.licensing.as_ref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct StopReplicationInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
}
impl StopReplicationInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct StartReplicationInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
}
impl StartReplicationInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct RetryDataReplicationInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
}
impl RetryDataReplicationInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct GetReplicationConfigurationInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
}
impl GetReplicationConfigurationInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct GetLaunchConfigurationInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
}
impl GetLaunchConfigurationInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DisconnectSourceServerInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
}
impl DisconnectSourceServerInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DescribeRecoverySnapshotsInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub filters: std::option::Option<crate::model::DescribeRecoverySnapshotsRequestFilters>,
#[doc(hidden)]
pub order: std::option::Option<crate::model::RecoverySnapshotsOrder>,
#[doc(hidden)]
pub max_results: i32,
#[doc(hidden)]
pub next_token: std::option::Option<std::string::String>,
}
impl DescribeRecoverySnapshotsInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
pub fn filters(
&self,
) -> std::option::Option<&crate::model::DescribeRecoverySnapshotsRequestFilters> {
self.filters.as_ref()
}
pub fn order(&self) -> std::option::Option<&crate::model::RecoverySnapshotsOrder> {
self.order.as_ref()
}
pub fn max_results(&self) -> i32 {
self.max_results
}
pub fn next_token(&self) -> std::option::Option<&str> {
self.next_token.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq)]
pub struct StartRecoveryInput {
#[doc(hidden)]
pub source_servers:
std::option::Option<std::vec::Vec<crate::model::StartRecoveryRequestSourceServer>>,
#[doc(hidden)]
pub is_drill: std::option::Option<bool>,
#[doc(hidden)]
pub tags:
std::option::Option<std::collections::HashMap<std::string::String, std::string::String>>,
}
impl StartRecoveryInput {
pub fn source_servers(
&self,
) -> std::option::Option<&[crate::model::StartRecoveryRequestSourceServer]> {
self.source_servers.as_deref()
}
pub fn is_drill(&self) -> std::option::Option<bool> {
self.is_drill
}
pub fn tags(
&self,
) -> std::option::Option<&std::collections::HashMap<std::string::String, std::string::String>>
{
self.tags.as_ref()
}
}
impl std::fmt::Debug for StartRecoveryInput {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("StartRecoveryInput");
formatter.field("source_servers", &self.source_servers);
formatter.field("is_drill", &self.is_drill);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DescribeSourceServersInput {
#[doc(hidden)]
pub filters: std::option::Option<crate::model::DescribeSourceServersRequestFilters>,
#[doc(hidden)]
pub max_results: i32,
#[doc(hidden)]
pub next_token: std::option::Option<std::string::String>,
}
impl DescribeSourceServersInput {
pub fn filters(
&self,
) -> std::option::Option<&crate::model::DescribeSourceServersRequestFilters> {
self.filters.as_ref()
}
pub fn max_results(&self) -> i32 {
self.max_results
}
pub fn next_token(&self) -> std::option::Option<&str> {
self.next_token.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DeleteSourceServerInput {
#[doc(hidden)]
pub source_server_id: std::option::Option<std::string::String>,
}
impl DeleteSourceServerInput {
pub fn source_server_id(&self) -> std::option::Option<&str> {
self.source_server_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DescribeReplicationConfigurationTemplatesInput {
#[doc(hidden)]
pub replication_configuration_template_i_ds:
std::option::Option<std::vec::Vec<std::string::String>>,
#[doc(hidden)]
pub max_results: i32,
#[doc(hidden)]
pub next_token: std::option::Option<std::string::String>,
}
impl DescribeReplicationConfigurationTemplatesInput {
pub fn replication_configuration_template_i_ds(
&self,
) -> std::option::Option<&[std::string::String]> {
self.replication_configuration_template_i_ds.as_deref()
}
pub fn max_results(&self) -> i32 {
self.max_results
}
pub fn next_token(&self) -> std::option::Option<&str> {
self.next_token.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq)]
pub struct CreateReplicationConfigurationTemplateInput {
#[doc(hidden)]
pub staging_area_subnet_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub associate_default_security_group: std::option::Option<bool>,
#[doc(hidden)]
pub replication_servers_security_groups_i_ds:
std::option::Option<std::vec::Vec<std::string::String>>,
#[doc(hidden)]
pub replication_server_instance_type: std::option::Option<std::string::String>,
#[doc(hidden)]
pub use_dedicated_replication_server: std::option::Option<bool>,
#[doc(hidden)]
pub default_large_staging_disk_type:
std::option::Option<crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>,
#[doc(hidden)]
pub ebs_encryption: std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
#[doc(hidden)]
pub ebs_encryption_key_arn: std::option::Option<std::string::String>,
#[doc(hidden)]
pub bandwidth_throttling: i64,
#[doc(hidden)]
pub data_plane_routing:
std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
#[doc(hidden)]
pub create_public_ip: std::option::Option<bool>,
#[doc(hidden)]
pub staging_area_tags:
std::option::Option<std::collections::HashMap<std::string::String, std::string::String>>,
#[doc(hidden)]
pub pit_policy: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
#[doc(hidden)]
pub tags:
std::option::Option<std::collections::HashMap<std::string::String, std::string::String>>,
}
impl CreateReplicationConfigurationTemplateInput {
pub fn staging_area_subnet_id(&self) -> std::option::Option<&str> {
self.staging_area_subnet_id.as_deref()
}
pub fn associate_default_security_group(&self) -> std::option::Option<bool> {
self.associate_default_security_group
}
pub fn replication_servers_security_groups_i_ds(
&self,
) -> std::option::Option<&[std::string::String]> {
self.replication_servers_security_groups_i_ds.as_deref()
}
pub fn replication_server_instance_type(&self) -> std::option::Option<&str> {
self.replication_server_instance_type.as_deref()
}
pub fn use_dedicated_replication_server(&self) -> std::option::Option<bool> {
self.use_dedicated_replication_server
}
pub fn default_large_staging_disk_type(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>
{
self.default_large_staging_disk_type.as_ref()
}
pub fn ebs_encryption(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationEbsEncryption> {
self.ebs_encryption.as_ref()
}
pub fn ebs_encryption_key_arn(&self) -> std::option::Option<&str> {
self.ebs_encryption_key_arn.as_deref()
}
pub fn bandwidth_throttling(&self) -> i64 {
self.bandwidth_throttling
}
pub fn data_plane_routing(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationDataPlaneRouting> {
self.data_plane_routing.as_ref()
}
pub fn create_public_ip(&self) -> std::option::Option<bool> {
self.create_public_ip
}
pub fn staging_area_tags(
&self,
) -> std::option::Option<&std::collections::HashMap<std::string::String, std::string::String>>
{
self.staging_area_tags.as_ref()
}
pub fn pit_policy(&self) -> std::option::Option<&[crate::model::PitPolicyRule]> {
self.pit_policy.as_deref()
}
pub fn tags(
&self,
) -> std::option::Option<&std::collections::HashMap<std::string::String, std::string::String>>
{
self.tags.as_ref()
}
}
impl std::fmt::Debug for CreateReplicationConfigurationTemplateInput {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("CreateReplicationConfigurationTemplateInput");
formatter.field("staging_area_subnet_id", &self.staging_area_subnet_id);
formatter.field(
"associate_default_security_group",
&self.associate_default_security_group,
);
formatter.field(
"replication_servers_security_groups_i_ds",
&self.replication_servers_security_groups_i_ds,
);
formatter.field(
"replication_server_instance_type",
&self.replication_server_instance_type,
);
formatter.field(
"use_dedicated_replication_server",
&self.use_dedicated_replication_server,
);
formatter.field(
"default_large_staging_disk_type",
&self.default_large_staging_disk_type,
);
formatter.field("ebs_encryption", &self.ebs_encryption);
formatter.field("ebs_encryption_key_arn", &self.ebs_encryption_key_arn);
formatter.field("bandwidth_throttling", &self.bandwidth_throttling);
formatter.field("data_plane_routing", &self.data_plane_routing);
formatter.field("create_public_ip", &self.create_public_ip);
formatter.field("staging_area_tags", &"*** Sensitive Data Redacted ***");
formatter.field("pit_policy", &self.pit_policy);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DeleteReplicationConfigurationTemplateInput {
#[doc(hidden)]
pub replication_configuration_template_id: std::option::Option<std::string::String>,
}
impl DeleteReplicationConfigurationTemplateInput {
pub fn replication_configuration_template_id(&self) -> std::option::Option<&str> {
self.replication_configuration_template_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq)]
pub struct UpdateReplicationConfigurationTemplateInput {
#[doc(hidden)]
pub replication_configuration_template_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub arn: std::option::Option<std::string::String>,
#[doc(hidden)]
pub staging_area_subnet_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub associate_default_security_group: std::option::Option<bool>,
#[doc(hidden)]
pub replication_servers_security_groups_i_ds:
std::option::Option<std::vec::Vec<std::string::String>>,
#[doc(hidden)]
pub replication_server_instance_type: std::option::Option<std::string::String>,
#[doc(hidden)]
pub use_dedicated_replication_server: std::option::Option<bool>,
#[doc(hidden)]
pub default_large_staging_disk_type:
std::option::Option<crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>,
#[doc(hidden)]
pub ebs_encryption: std::option::Option<crate::model::ReplicationConfigurationEbsEncryption>,
#[doc(hidden)]
pub ebs_encryption_key_arn: std::option::Option<std::string::String>,
#[doc(hidden)]
pub bandwidth_throttling: i64,
#[doc(hidden)]
pub data_plane_routing:
std::option::Option<crate::model::ReplicationConfigurationDataPlaneRouting>,
#[doc(hidden)]
pub create_public_ip: std::option::Option<bool>,
#[doc(hidden)]
pub staging_area_tags:
std::option::Option<std::collections::HashMap<std::string::String, std::string::String>>,
#[doc(hidden)]
pub pit_policy: std::option::Option<std::vec::Vec<crate::model::PitPolicyRule>>,
}
impl UpdateReplicationConfigurationTemplateInput {
pub fn replication_configuration_template_id(&self) -> std::option::Option<&str> {
self.replication_configuration_template_id.as_deref()
}
pub fn arn(&self) -> std::option::Option<&str> {
self.arn.as_deref()
}
pub fn staging_area_subnet_id(&self) -> std::option::Option<&str> {
self.staging_area_subnet_id.as_deref()
}
pub fn associate_default_security_group(&self) -> std::option::Option<bool> {
self.associate_default_security_group
}
pub fn replication_servers_security_groups_i_ds(
&self,
) -> std::option::Option<&[std::string::String]> {
self.replication_servers_security_groups_i_ds.as_deref()
}
pub fn replication_server_instance_type(&self) -> std::option::Option<&str> {
self.replication_server_instance_type.as_deref()
}
pub fn use_dedicated_replication_server(&self) -> std::option::Option<bool> {
self.use_dedicated_replication_server
}
pub fn default_large_staging_disk_type(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationDefaultLargeStagingDiskType>
{
self.default_large_staging_disk_type.as_ref()
}
pub fn ebs_encryption(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationEbsEncryption> {
self.ebs_encryption.as_ref()
}
pub fn ebs_encryption_key_arn(&self) -> std::option::Option<&str> {
self.ebs_encryption_key_arn.as_deref()
}
pub fn bandwidth_throttling(&self) -> i64 {
self.bandwidth_throttling
}
pub fn data_plane_routing(
&self,
) -> std::option::Option<&crate::model::ReplicationConfigurationDataPlaneRouting> {
self.data_plane_routing.as_ref()
}
pub fn create_public_ip(&self) -> std::option::Option<bool> {
self.create_public_ip
}
pub fn staging_area_tags(
&self,
) -> std::option::Option<&std::collections::HashMap<std::string::String, std::string::String>>
{
self.staging_area_tags.as_ref()
}
pub fn pit_policy(&self) -> std::option::Option<&[crate::model::PitPolicyRule]> {
self.pit_policy.as_deref()
}
}
impl std::fmt::Debug for UpdateReplicationConfigurationTemplateInput {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("UpdateReplicationConfigurationTemplateInput");
formatter.field(
"replication_configuration_template_id",
&self.replication_configuration_template_id,
);
formatter.field("arn", &self.arn);
formatter.field("staging_area_subnet_id", &self.staging_area_subnet_id);
formatter.field(
"associate_default_security_group",
&self.associate_default_security_group,
);
formatter.field(
"replication_servers_security_groups_i_ds",
&self.replication_servers_security_groups_i_ds,
);
formatter.field(
"replication_server_instance_type",
&self.replication_server_instance_type,
);
formatter.field(
"use_dedicated_replication_server",
&self.use_dedicated_replication_server,
);
formatter.field(
"default_large_staging_disk_type",
&self.default_large_staging_disk_type,
);
formatter.field("ebs_encryption", &self.ebs_encryption);
formatter.field("ebs_encryption_key_arn", &self.ebs_encryption_key_arn);
formatter.field("bandwidth_throttling", &self.bandwidth_throttling);
formatter.field("data_plane_routing", &self.data_plane_routing);
formatter.field("create_public_ip", &self.create_public_ip);
formatter.field("staging_area_tags", &"*** Sensitive Data Redacted ***");
formatter.field("pit_policy", &self.pit_policy);
formatter.finish()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct UpdateFailbackReplicationConfigurationInput {
#[doc(hidden)]
pub recovery_instance_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub name: std::option::Option<std::string::String>,
#[doc(hidden)]
pub bandwidth_throttling: i64,
#[doc(hidden)]
pub use_private_ip: std::option::Option<bool>,
}
impl UpdateFailbackReplicationConfigurationInput {
pub fn recovery_instance_id(&self) -> std::option::Option<&str> {
self.recovery_instance_id.as_deref()
}
pub fn name(&self) -> std::option::Option<&str> {
self.name.as_deref()
}
pub fn bandwidth_throttling(&self) -> i64 {
self.bandwidth_throttling
}
pub fn use_private_ip(&self) -> std::option::Option<bool> {
self.use_private_ip
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct StopFailbackInput {
#[doc(hidden)]
pub recovery_instance_id: std::option::Option<std::string::String>,
}
impl StopFailbackInput {
pub fn recovery_instance_id(&self) -> std::option::Option<&str> {
self.recovery_instance_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct ReverseReplicationInput {
#[doc(hidden)]
pub recovery_instance_id: std::option::Option<std::string::String>,
}
impl ReverseReplicationInput {
pub fn recovery_instance_id(&self) -> std::option::Option<&str> {
self.recovery_instance_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct GetFailbackReplicationConfigurationInput {
#[doc(hidden)]
pub recovery_instance_id: std::option::Option<std::string::String>,
}
impl GetFailbackReplicationConfigurationInput {
pub fn recovery_instance_id(&self) -> std::option::Option<&str> {
self.recovery_instance_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DisconnectRecoveryInstanceInput {
#[doc(hidden)]
pub recovery_instance_id: std::option::Option<std::string::String>,
}
impl DisconnectRecoveryInstanceInput {
pub fn recovery_instance_id(&self) -> std::option::Option<&str> {
self.recovery_instance_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DeleteRecoveryInstanceInput {
#[doc(hidden)]
pub recovery_instance_id: std::option::Option<std::string::String>,
}
impl DeleteRecoveryInstanceInput {
pub fn recovery_instance_id(&self) -> std::option::Option<&str> {
self.recovery_instance_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct TerminateRecoveryInstancesInput {
#[doc(hidden)]
pub recovery_instance_i_ds: std::option::Option<std::vec::Vec<std::string::String>>,
}
impl TerminateRecoveryInstancesInput {
pub fn recovery_instance_i_ds(&self) -> std::option::Option<&[std::string::String]> {
self.recovery_instance_i_ds.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq)]
pub struct StartFailbackLaunchInput {
#[doc(hidden)]
pub recovery_instance_i_ds: std::option::Option<std::vec::Vec<std::string::String>>,
#[doc(hidden)]
pub tags:
std::option::Option<std::collections::HashMap<std::string::String, std::string::String>>,
}
impl StartFailbackLaunchInput {
pub fn recovery_instance_i_ds(&self) -> std::option::Option<&[std::string::String]> {
self.recovery_instance_i_ds.as_deref()
}
pub fn tags(
&self,
) -> std::option::Option<&std::collections::HashMap<std::string::String, std::string::String>>
{
self.tags.as_ref()
}
}
impl std::fmt::Debug for StartFailbackLaunchInput {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("StartFailbackLaunchInput");
formatter.field("recovery_instance_i_ds", &self.recovery_instance_i_ds);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DescribeRecoveryInstancesInput {
#[doc(hidden)]
pub filters: std::option::Option<crate::model::DescribeRecoveryInstancesRequestFilters>,
#[doc(hidden)]
pub max_results: i32,
#[doc(hidden)]
pub next_token: std::option::Option<std::string::String>,
}
impl DescribeRecoveryInstancesInput {
pub fn filters(
&self,
) -> std::option::Option<&crate::model::DescribeRecoveryInstancesRequestFilters> {
self.filters.as_ref()
}
pub fn max_results(&self) -> i32 {
self.max_results
}
pub fn next_token(&self) -> std::option::Option<&str> {
self.next_token.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DescribeJobLogItemsInput {
#[doc(hidden)]
pub job_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub max_results: i32,
#[doc(hidden)]
pub next_token: std::option::Option<std::string::String>,
}
impl DescribeJobLogItemsInput {
pub fn job_id(&self) -> std::option::Option<&str> {
self.job_id.as_deref()
}
pub fn max_results(&self) -> i32 {
self.max_results
}
pub fn next_token(&self) -> std::option::Option<&str> {
self.next_token.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DescribeJobsInput {
#[doc(hidden)]
pub filters: std::option::Option<crate::model::DescribeJobsRequestFilters>,
#[doc(hidden)]
pub max_results: i32,
#[doc(hidden)]
pub next_token: std::option::Option<std::string::String>,
}
impl DescribeJobsInput {
pub fn filters(&self) -> std::option::Option<&crate::model::DescribeJobsRequestFilters> {
self.filters.as_ref()
}
pub fn max_results(&self) -> i32 {
self.max_results
}
pub fn next_token(&self) -> std::option::Option<&str> {
self.next_token.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct DeleteJobInput {
#[doc(hidden)]
pub job_id: std::option::Option<std::string::String>,
}
impl DeleteJobInput {
pub fn job_id(&self) -> std::option::Option<&str> {
self.job_id.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq)]
pub struct UntagResourceInput {
#[doc(hidden)]
pub resource_arn: std::option::Option<std::string::String>,
#[doc(hidden)]
pub tag_keys: std::option::Option<std::vec::Vec<std::string::String>>,
}
impl UntagResourceInput {
pub fn resource_arn(&self) -> std::option::Option<&str> {
self.resource_arn.as_deref()
}
pub fn tag_keys(&self) -> std::option::Option<&[std::string::String]> {
self.tag_keys.as_deref()
}
}
impl std::fmt::Debug for UntagResourceInput {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("UntagResourceInput");
formatter.field("resource_arn", &self.resource_arn);
formatter.field("tag_keys", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq)]
pub struct TagResourceInput {
#[doc(hidden)]
pub resource_arn: std::option::Option<std::string::String>,
#[doc(hidden)]
pub tags:
std::option::Option<std::collections::HashMap<std::string::String, std::string::String>>,
}
impl TagResourceInput {
pub fn resource_arn(&self) -> std::option::Option<&str> {
self.resource_arn.as_deref()
}
pub fn tags(
&self,
) -> std::option::Option<&std::collections::HashMap<std::string::String, std::string::String>>
{
self.tags.as_ref()
}
}
impl std::fmt::Debug for TagResourceInput {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("TagResourceInput");
formatter.field("resource_arn", &self.resource_arn);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct ListTagsForResourceInput {
#[doc(hidden)]
pub resource_arn: std::option::Option<std::string::String>,
}
impl ListTagsForResourceInput {
pub fn resource_arn(&self) -> std::option::Option<&str> {
self.resource_arn.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct ListStagingAccountsInput {
#[doc(hidden)]
pub max_results: std::option::Option<i32>,
#[doc(hidden)]
pub next_token: std::option::Option<std::string::String>,
}
impl ListStagingAccountsInput {
pub fn max_results(&self) -> std::option::Option<i32> {
self.max_results
}
pub fn next_token(&self) -> std::option::Option<&str> {
self.next_token.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct ListExtensibleSourceServersInput {
#[doc(hidden)]
pub staging_account_id: std::option::Option<std::string::String>,
#[doc(hidden)]
pub max_results: i32,
#[doc(hidden)]
pub next_token: std::option::Option<std::string::String>,
}
impl ListExtensibleSourceServersInput {
pub fn staging_account_id(&self) -> std::option::Option<&str> {
self.staging_account_id.as_deref()
}
pub fn max_results(&self) -> i32 {
self.max_results
}
pub fn next_token(&self) -> std::option::Option<&str> {
self.next_token.as_deref()
}
}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq, std::fmt::Debug)]
pub struct InitializeServiceInput {}
#[allow(missing_docs)] #[non_exhaustive]
#[derive(std::clone::Clone, std::cmp::PartialEq)]
pub struct CreateExtendedSourceServerInput {
#[doc(hidden)]
pub source_server_arn: std::option::Option<std::string::String>,
#[doc(hidden)]
pub tags:
std::option::Option<std::collections::HashMap<std::string::String, std::string::String>>,
}
impl CreateExtendedSourceServerInput {
pub fn source_server_arn(&self) -> std::option::Option<&str> {
self.source_server_arn.as_deref()
}
pub fn tags(
&self,
) -> std::option::Option<&std::collections::HashMap<std::string::String, std::string::String>>
{
self.tags.as_ref()
}
}
impl std::fmt::Debug for CreateExtendedSourceServerInput {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut formatter = f.debug_struct("CreateExtendedSourceServerInput");
formatter.field("source_server_arn", &self.source_server_arn);
formatter.field("tags", &"*** Sensitive Data Redacted ***");
formatter.finish()
}
}