pub fn serialize_operation_crate_operation_create_connector_profile(
input: &crate::input::CreateConnectorProfileInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_create_connector_profile_input(
&mut object,
input,
);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_create_flow(
input: &crate::input::CreateFlowInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_create_flow_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_delete_connector_profile(
input: &crate::input::DeleteConnectorProfileInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_delete_connector_profile_input(
&mut object,
input,
);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_delete_flow(
input: &crate::input::DeleteFlowInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_delete_flow_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_describe_connector_entity(
input: &crate::input::DescribeConnectorEntityInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_describe_connector_entity_input(
&mut object,
input,
);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_describe_connector_profiles(
input: &crate::input::DescribeConnectorProfilesInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_describe_connector_profiles_input(
&mut object,
input,
);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_describe_connectors(
input: &crate::input::DescribeConnectorsInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_describe_connectors_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_describe_flow(
input: &crate::input::DescribeFlowInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_describe_flow_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_describe_flow_execution_records(
input: &crate::input::DescribeFlowExecutionRecordsInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_describe_flow_execution_records_input(
&mut object,
input,
);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_list_connector_entities(
input: &crate::input::ListConnectorEntitiesInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_list_connector_entities_input(
&mut object,
input,
);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_list_flows(
input: &crate::input::ListFlowsInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_list_flows_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_start_flow(
input: &crate::input::StartFlowInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_start_flow_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_stop_flow(
input: &crate::input::StopFlowInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_stop_flow_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_tag_resource(
input: &crate::input::TagResourceInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_tag_resource_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_update_connector_profile(
input: &crate::input::UpdateConnectorProfileInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_update_connector_profile_input(
&mut object,
input,
);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}
pub fn serialize_operation_crate_operation_update_flow(
input: &crate::input::UpdateFlowInput,
) -> Result<aws_smithy_http::body::SdkBody, aws_smithy_types::Error> {
let mut out = String::new();
let mut object = aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
crate::json_ser::serialize_structure_crate_input_update_flow_input(&mut object, input);
object.finish();
Ok(aws_smithy_http::body::SdkBody::from(out))
}