#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ActivatePipeline {
_private: (),
}
impl ActivatePipeline {
pub fn builder() -> crate::input::activate_pipeline_input::Builder {
crate::input::activate_pipeline_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ActivatePipeline {
type Output = std::result::Result<
crate::output::ActivatePipelineOutput,
crate::error::ActivatePipelineError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_activate_pipeline_error(response)
} else {
crate::operation_deser::parse_activate_pipeline_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct AddTags {
_private: (),
}
impl AddTags {
pub fn builder() -> crate::input::add_tags_input::Builder {
crate::input::add_tags_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for AddTags {
type Output = std::result::Result<crate::output::AddTagsOutput, crate::error::AddTagsError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_add_tags_error(response)
} else {
crate::operation_deser::parse_add_tags_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct CreatePipeline {
_private: (),
}
impl CreatePipeline {
pub fn builder() -> crate::input::create_pipeline_input::Builder {
crate::input::create_pipeline_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for CreatePipeline {
type Output =
std::result::Result<crate::output::CreatePipelineOutput, crate::error::CreatePipelineError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_create_pipeline_error(response)
} else {
crate::operation_deser::parse_create_pipeline_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct DeactivatePipeline {
_private: (),
}
impl DeactivatePipeline {
pub fn builder() -> crate::input::deactivate_pipeline_input::Builder {
crate::input::deactivate_pipeline_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for DeactivatePipeline {
type Output = std::result::Result<
crate::output::DeactivatePipelineOutput,
crate::error::DeactivatePipelineError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_deactivate_pipeline_error(response)
} else {
crate::operation_deser::parse_deactivate_pipeline_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct DeletePipeline {
_private: (),
}
impl DeletePipeline {
pub fn builder() -> crate::input::delete_pipeline_input::Builder {
crate::input::delete_pipeline_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for DeletePipeline {
type Output =
std::result::Result<crate::output::DeletePipelineOutput, crate::error::DeletePipelineError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_delete_pipeline_error(response)
} else {
crate::operation_deser::parse_delete_pipeline_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct DescribeObjects {
_private: (),
}
impl DescribeObjects {
pub fn builder() -> crate::input::describe_objects_input::Builder {
crate::input::describe_objects_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for DescribeObjects {
type Output = std::result::Result<
crate::output::DescribeObjectsOutput,
crate::error::DescribeObjectsError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_describe_objects_error(response)
} else {
crate::operation_deser::parse_describe_objects_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct DescribePipelines {
_private: (),
}
impl DescribePipelines {
pub fn builder() -> crate::input::describe_pipelines_input::Builder {
crate::input::describe_pipelines_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for DescribePipelines {
type Output = std::result::Result<
crate::output::DescribePipelinesOutput,
crate::error::DescribePipelinesError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_describe_pipelines_error(response)
} else {
crate::operation_deser::parse_describe_pipelines_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct EvaluateExpression {
_private: (),
}
impl EvaluateExpression {
pub fn builder() -> crate::input::evaluate_expression_input::Builder {
crate::input::evaluate_expression_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for EvaluateExpression {
type Output = std::result::Result<
crate::output::EvaluateExpressionOutput,
crate::error::EvaluateExpressionError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_evaluate_expression_error(response)
} else {
crate::operation_deser::parse_evaluate_expression_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct GetPipelineDefinition {
_private: (),
}
impl GetPipelineDefinition {
pub fn builder() -> crate::input::get_pipeline_definition_input::Builder {
crate::input::get_pipeline_definition_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for GetPipelineDefinition {
type Output = std::result::Result<
crate::output::GetPipelineDefinitionOutput,
crate::error::GetPipelineDefinitionError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_get_pipeline_definition_error(response)
} else {
crate::operation_deser::parse_get_pipeline_definition_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ListPipelines {
_private: (),
}
impl ListPipelines {
pub fn builder() -> crate::input::list_pipelines_input::Builder {
crate::input::list_pipelines_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ListPipelines {
type Output =
std::result::Result<crate::output::ListPipelinesOutput, crate::error::ListPipelinesError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_list_pipelines_error(response)
} else {
crate::operation_deser::parse_list_pipelines_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct PollForTask {
_private: (),
}
impl PollForTask {
pub fn builder() -> crate::input::poll_for_task_input::Builder {
crate::input::poll_for_task_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for PollForTask {
type Output =
std::result::Result<crate::output::PollForTaskOutput, crate::error::PollForTaskError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_poll_for_task_error(response)
} else {
crate::operation_deser::parse_poll_for_task_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct PutPipelineDefinition {
_private: (),
}
impl PutPipelineDefinition {
pub fn builder() -> crate::input::put_pipeline_definition_input::Builder {
crate::input::put_pipeline_definition_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for PutPipelineDefinition {
type Output = std::result::Result<
crate::output::PutPipelineDefinitionOutput,
crate::error::PutPipelineDefinitionError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_put_pipeline_definition_error(response)
} else {
crate::operation_deser::parse_put_pipeline_definition_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct QueryObjects {
_private: (),
}
impl QueryObjects {
pub fn builder() -> crate::input::query_objects_input::Builder {
crate::input::query_objects_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for QueryObjects {
type Output =
std::result::Result<crate::output::QueryObjectsOutput, crate::error::QueryObjectsError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_query_objects_error(response)
} else {
crate::operation_deser::parse_query_objects_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct RemoveTags {
_private: (),
}
impl RemoveTags {
pub fn builder() -> crate::input::remove_tags_input::Builder {
crate::input::remove_tags_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for RemoveTags {
type Output =
std::result::Result<crate::output::RemoveTagsOutput, crate::error::RemoveTagsError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_remove_tags_error(response)
} else {
crate::operation_deser::parse_remove_tags_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ReportTaskProgress {
_private: (),
}
impl ReportTaskProgress {
pub fn builder() -> crate::input::report_task_progress_input::Builder {
crate::input::report_task_progress_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ReportTaskProgress {
type Output = std::result::Result<
crate::output::ReportTaskProgressOutput,
crate::error::ReportTaskProgressError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_report_task_progress_error(response)
} else {
crate::operation_deser::parse_report_task_progress_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ReportTaskRunnerHeartbeat {
_private: (),
}
impl ReportTaskRunnerHeartbeat {
pub fn builder() -> crate::input::report_task_runner_heartbeat_input::Builder {
crate::input::report_task_runner_heartbeat_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ReportTaskRunnerHeartbeat {
type Output = std::result::Result<
crate::output::ReportTaskRunnerHeartbeatOutput,
crate::error::ReportTaskRunnerHeartbeatError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_report_task_runner_heartbeat_error(response)
} else {
crate::operation_deser::parse_report_task_runner_heartbeat_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct SetStatus {
_private: (),
}
impl SetStatus {
pub fn builder() -> crate::input::set_status_input::Builder {
crate::input::set_status_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for SetStatus {
type Output = std::result::Result<crate::output::SetStatusOutput, crate::error::SetStatusError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_set_status_error(response)
} else {
crate::operation_deser::parse_set_status_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct SetTaskStatus {
_private: (),
}
impl SetTaskStatus {
pub fn builder() -> crate::input::set_task_status_input::Builder {
crate::input::set_task_status_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for SetTaskStatus {
type Output =
std::result::Result<crate::output::SetTaskStatusOutput, crate::error::SetTaskStatusError>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_set_task_status_error(response)
} else {
crate::operation_deser::parse_set_task_status_response(response)
}
}
}
#[derive(std::clone::Clone, std::default::Default, std::fmt::Debug)]
pub struct ValidatePipelineDefinition {
_private: (),
}
impl ValidatePipelineDefinition {
pub fn builder() -> crate::input::validate_pipeline_definition_input::Builder {
crate::input::validate_pipeline_definition_input::Builder::default()
}
pub fn new() -> Self {
Self { _private: () }
}
}
impl aws_smithy_http::response::ParseStrictResponse for ValidatePipelineDefinition {
type Output = std::result::Result<
crate::output::ValidatePipelineDefinitionOutput,
crate::error::ValidatePipelineDefinitionError,
>;
fn parse(&self, response: &http::Response<bytes::Bytes>) -> Self::Output {
if !response.status().is_success() && response.status().as_u16() != 200 {
crate::operation_deser::parse_validate_pipeline_definition_error(response)
} else {
crate::operation_deser::parse_validate_pipeline_definition_response(response)
}
}
}
pub mod customize;