use aws_sdk_datapipeline::operation::activate_pipeline::{builders::*, *};
use aws_sdk_datapipeline::operation::add_tags::{builders::*, *};
use aws_sdk_datapipeline::operation::create_pipeline::{builders::*, *};
use aws_sdk_datapipeline::operation::deactivate_pipeline::{builders::*, *};
use aws_sdk_datapipeline::operation::delete_pipeline::{builders::*, *};
use aws_sdk_datapipeline::operation::describe_objects::{builders::*, *};
use aws_sdk_datapipeline::operation::describe_pipelines::{builders::*, *};
use aws_sdk_datapipeline::operation::evaluate_expression::{builders::*, *};
use aws_sdk_datapipeline::operation::get_pipeline_definition::{builders::*, *};
use aws_sdk_datapipeline::operation::list_pipelines::{builders::*, *};
use aws_sdk_datapipeline::operation::poll_for_task::{builders::*, *};
use aws_sdk_datapipeline::operation::put_pipeline_definition::{builders::*, *};
use aws_sdk_datapipeline::operation::query_objects::{builders::*, *};
use aws_sdk_datapipeline::operation::remove_tags::{builders::*, *};
use aws_sdk_datapipeline::operation::report_task_progress::{builders::*, *};
use aws_sdk_datapipeline::operation::report_task_runner_heartbeat::{builders::*, *};
use aws_sdk_datapipeline::operation::set_status::{builders::*, *};
use aws_sdk_datapipeline::operation::set_task_status::{builders::*, *};
use aws_sdk_datapipeline::operation::validate_pipeline_definition::{builders::*, *};
use aws_sdk_datapipeline::error::SdkError;
use std::future::Future;
use aws_config::SdkConfig;
#[allow(hidden_glob_reexports)]
use aws_sdk_datapipeline::Client;
use std::ops::Deref;
pub use aws_sdk_datapipeline::*;
pub struct DataPipelineClientImpl(Client);
impl DataPipelineClientImpl {
pub fn new(config: &SdkConfig) -> Self { Self(Client::new(config)) }
}
pub trait DataPipelineClient {
fn activate_pipeline(&self, builder: ActivatePipelineInputBuilder) -> impl Future<Output = Result<ActivatePipelineOutput, SdkError<ActivatePipelineError>>> + Send;
fn add_tags(&self, builder: AddTagsInputBuilder) -> impl Future<Output = Result<AddTagsOutput, SdkError<AddTagsError>>> + Send;
fn create_pipeline(&self, builder: CreatePipelineInputBuilder) -> impl Future<Output = Result<CreatePipelineOutput, SdkError<CreatePipelineError>>> + Send;
fn deactivate_pipeline(&self, builder: DeactivatePipelineInputBuilder) -> impl Future<Output = Result<DeactivatePipelineOutput, SdkError<DeactivatePipelineError>>> + Send;
fn delete_pipeline(&self, builder: DeletePipelineInputBuilder) -> impl Future<Output = Result<DeletePipelineOutput, SdkError<DeletePipelineError>>> + Send;
fn describe_objects(&self, builder: DescribeObjectsInputBuilder) -> impl Future<Output = Result<DescribeObjectsOutput, SdkError<DescribeObjectsError>>> + Send;
fn describe_pipelines(&self, builder: DescribePipelinesInputBuilder) -> impl Future<Output = Result<DescribePipelinesOutput, SdkError<DescribePipelinesError>>> + Send;
fn evaluate_expression(&self, builder: EvaluateExpressionInputBuilder) -> impl Future<Output = Result<EvaluateExpressionOutput, SdkError<EvaluateExpressionError>>> + Send;
fn get_pipeline_definition(&self, builder: GetPipelineDefinitionInputBuilder) -> impl Future<Output = Result<GetPipelineDefinitionOutput, SdkError<GetPipelineDefinitionError>>> + Send;
fn list_pipelines(&self, builder: ListPipelinesInputBuilder) -> impl Future<Output = Result<ListPipelinesOutput, SdkError<ListPipelinesError>>> + Send;
fn poll_for_task(&self, builder: PollForTaskInputBuilder) -> impl Future<Output = Result<PollForTaskOutput, SdkError<PollForTaskError>>> + Send;
fn put_pipeline_definition(&self, builder: PutPipelineDefinitionInputBuilder) -> impl Future<Output = Result<PutPipelineDefinitionOutput, SdkError<PutPipelineDefinitionError>>> + Send;
fn query_objects(&self, builder: QueryObjectsInputBuilder) -> impl Future<Output = Result<QueryObjectsOutput, SdkError<QueryObjectsError>>> + Send;
fn remove_tags(&self, builder: RemoveTagsInputBuilder) -> impl Future<Output = Result<RemoveTagsOutput, SdkError<RemoveTagsError>>> + Send;
fn report_task_progress(&self, builder: ReportTaskProgressInputBuilder) -> impl Future<Output = Result<ReportTaskProgressOutput, SdkError<ReportTaskProgressError>>> + Send;
fn report_task_runner_heartbeat(&self, builder: ReportTaskRunnerHeartbeatInputBuilder) -> impl Future<Output = Result<ReportTaskRunnerHeartbeatOutput, SdkError<ReportTaskRunnerHeartbeatError>>> + Send;
fn set_status(&self, builder: SetStatusInputBuilder) -> impl Future<Output = Result<SetStatusOutput, SdkError<SetStatusError>>> + Send;
fn set_task_status(&self, builder: SetTaskStatusInputBuilder) -> impl Future<Output = Result<SetTaskStatusOutput, SdkError<SetTaskStatusError>>> + Send;
fn validate_pipeline_definition(&self, builder: ValidatePipelineDefinitionInputBuilder) -> impl Future<Output = Result<ValidatePipelineDefinitionOutput, SdkError<ValidatePipelineDefinitionError>>> + Send;
}
impl DataPipelineClient for DataPipelineClientImpl {
fn activate_pipeline(&self, builder: ActivatePipelineInputBuilder) -> impl Future<Output = Result<ActivatePipelineOutput, SdkError<ActivatePipelineError>>> {
builder.send_with(&self.0)
}
fn add_tags(&self, builder: AddTagsInputBuilder) -> impl Future<Output = Result<AddTagsOutput, SdkError<AddTagsError>>> {
builder.send_with(&self.0)
}
fn create_pipeline(&self, builder: CreatePipelineInputBuilder) -> impl Future<Output = Result<CreatePipelineOutput, SdkError<CreatePipelineError>>> {
builder.send_with(&self.0)
}
fn deactivate_pipeline(&self, builder: DeactivatePipelineInputBuilder) -> impl Future<Output = Result<DeactivatePipelineOutput, SdkError<DeactivatePipelineError>>> {
builder.send_with(&self.0)
}
fn delete_pipeline(&self, builder: DeletePipelineInputBuilder) -> impl Future<Output = Result<DeletePipelineOutput, SdkError<DeletePipelineError>>> {
builder.send_with(&self.0)
}
fn describe_objects(&self, builder: DescribeObjectsInputBuilder) -> impl Future<Output = Result<DescribeObjectsOutput, SdkError<DescribeObjectsError>>> {
builder.send_with(&self.0)
}
fn describe_pipelines(&self, builder: DescribePipelinesInputBuilder) -> impl Future<Output = Result<DescribePipelinesOutput, SdkError<DescribePipelinesError>>> {
builder.send_with(&self.0)
}
fn evaluate_expression(&self, builder: EvaluateExpressionInputBuilder) -> impl Future<Output = Result<EvaluateExpressionOutput, SdkError<EvaluateExpressionError>>> {
builder.send_with(&self.0)
}
fn get_pipeline_definition(&self, builder: GetPipelineDefinitionInputBuilder) -> impl Future<Output = Result<GetPipelineDefinitionOutput, SdkError<GetPipelineDefinitionError>>> {
builder.send_with(&self.0)
}
fn list_pipelines(&self, builder: ListPipelinesInputBuilder) -> impl Future<Output = Result<ListPipelinesOutput, SdkError<ListPipelinesError>>> {
builder.send_with(&self.0)
}
fn poll_for_task(&self, builder: PollForTaskInputBuilder) -> impl Future<Output = Result<PollForTaskOutput, SdkError<PollForTaskError>>> {
builder.send_with(&self.0)
}
fn put_pipeline_definition(&self, builder: PutPipelineDefinitionInputBuilder) -> impl Future<Output = Result<PutPipelineDefinitionOutput, SdkError<PutPipelineDefinitionError>>> {
builder.send_with(&self.0)
}
fn query_objects(&self, builder: QueryObjectsInputBuilder) -> impl Future<Output = Result<QueryObjectsOutput, SdkError<QueryObjectsError>>> {
builder.send_with(&self.0)
}
fn remove_tags(&self, builder: RemoveTagsInputBuilder) -> impl Future<Output = Result<RemoveTagsOutput, SdkError<RemoveTagsError>>> {
builder.send_with(&self.0)
}
fn report_task_progress(&self, builder: ReportTaskProgressInputBuilder) -> impl Future<Output = Result<ReportTaskProgressOutput, SdkError<ReportTaskProgressError>>> {
builder.send_with(&self.0)
}
fn report_task_runner_heartbeat(&self, builder: ReportTaskRunnerHeartbeatInputBuilder) -> impl Future<Output = Result<ReportTaskRunnerHeartbeatOutput, SdkError<ReportTaskRunnerHeartbeatError>>> {
builder.send_with(&self.0)
}
fn set_status(&self, builder: SetStatusInputBuilder) -> impl Future<Output = Result<SetStatusOutput, SdkError<SetStatusError>>> {
builder.send_with(&self.0)
}
fn set_task_status(&self, builder: SetTaskStatusInputBuilder) -> impl Future<Output = Result<SetTaskStatusOutput, SdkError<SetTaskStatusError>>> {
builder.send_with(&self.0)
}
fn validate_pipeline_definition(&self, builder: ValidatePipelineDefinitionInputBuilder) -> impl Future<Output = Result<ValidatePipelineDefinitionOutput, SdkError<ValidatePipelineDefinitionError>>> {
builder.send_with(&self.0)
}
}
impl <T> DataPipelineClient for T
where T: Deref,
T::Target: DataPipelineClient {
fn activate_pipeline(&self, builder: ActivatePipelineInputBuilder) -> impl Future<Output = Result<ActivatePipelineOutput, SdkError<ActivatePipelineError>>> {
self.deref().activate_pipeline(builder)
}
fn add_tags(&self, builder: AddTagsInputBuilder) -> impl Future<Output = Result<AddTagsOutput, SdkError<AddTagsError>>> {
self.deref().add_tags(builder)
}
fn create_pipeline(&self, builder: CreatePipelineInputBuilder) -> impl Future<Output = Result<CreatePipelineOutput, SdkError<CreatePipelineError>>> {
self.deref().create_pipeline(builder)
}
fn deactivate_pipeline(&self, builder: DeactivatePipelineInputBuilder) -> impl Future<Output = Result<DeactivatePipelineOutput, SdkError<DeactivatePipelineError>>> {
self.deref().deactivate_pipeline(builder)
}
fn delete_pipeline(&self, builder: DeletePipelineInputBuilder) -> impl Future<Output = Result<DeletePipelineOutput, SdkError<DeletePipelineError>>> {
self.deref().delete_pipeline(builder)
}
fn describe_objects(&self, builder: DescribeObjectsInputBuilder) -> impl Future<Output = Result<DescribeObjectsOutput, SdkError<DescribeObjectsError>>> {
self.deref().describe_objects(builder)
}
fn describe_pipelines(&self, builder: DescribePipelinesInputBuilder) -> impl Future<Output = Result<DescribePipelinesOutput, SdkError<DescribePipelinesError>>> {
self.deref().describe_pipelines(builder)
}
fn evaluate_expression(&self, builder: EvaluateExpressionInputBuilder) -> impl Future<Output = Result<EvaluateExpressionOutput, SdkError<EvaluateExpressionError>>> {
self.deref().evaluate_expression(builder)
}
fn get_pipeline_definition(&self, builder: GetPipelineDefinitionInputBuilder) -> impl Future<Output = Result<GetPipelineDefinitionOutput, SdkError<GetPipelineDefinitionError>>> {
self.deref().get_pipeline_definition(builder)
}
fn list_pipelines(&self, builder: ListPipelinesInputBuilder) -> impl Future<Output = Result<ListPipelinesOutput, SdkError<ListPipelinesError>>> {
self.deref().list_pipelines(builder)
}
fn poll_for_task(&self, builder: PollForTaskInputBuilder) -> impl Future<Output = Result<PollForTaskOutput, SdkError<PollForTaskError>>> {
self.deref().poll_for_task(builder)
}
fn put_pipeline_definition(&self, builder: PutPipelineDefinitionInputBuilder) -> impl Future<Output = Result<PutPipelineDefinitionOutput, SdkError<PutPipelineDefinitionError>>> {
self.deref().put_pipeline_definition(builder)
}
fn query_objects(&self, builder: QueryObjectsInputBuilder) -> impl Future<Output = Result<QueryObjectsOutput, SdkError<QueryObjectsError>>> {
self.deref().query_objects(builder)
}
fn remove_tags(&self, builder: RemoveTagsInputBuilder) -> impl Future<Output = Result<RemoveTagsOutput, SdkError<RemoveTagsError>>> {
self.deref().remove_tags(builder)
}
fn report_task_progress(&self, builder: ReportTaskProgressInputBuilder) -> impl Future<Output = Result<ReportTaskProgressOutput, SdkError<ReportTaskProgressError>>> {
self.deref().report_task_progress(builder)
}
fn report_task_runner_heartbeat(&self, builder: ReportTaskRunnerHeartbeatInputBuilder) -> impl Future<Output = Result<ReportTaskRunnerHeartbeatOutput, SdkError<ReportTaskRunnerHeartbeatError>>> {
self.deref().report_task_runner_heartbeat(builder)
}
fn set_status(&self, builder: SetStatusInputBuilder) -> impl Future<Output = Result<SetStatusOutput, SdkError<SetStatusError>>> {
self.deref().set_status(builder)
}
fn set_task_status(&self, builder: SetTaskStatusInputBuilder) -> impl Future<Output = Result<SetTaskStatusOutput, SdkError<SetTaskStatusError>>> {
self.deref().set_task_status(builder)
}
fn validate_pipeline_definition(&self, builder: ValidatePipelineDefinitionInputBuilder) -> impl Future<Output = Result<ValidatePipelineDefinitionOutput, SdkError<ValidatePipelineDefinitionError>>> {
self.deref().validate_pipeline_definition(builder)
}
}
#[cfg(feature = "mockall")]
mockall::mock! {
pub edDataPipelineClient {}
impl DataPipelineClient for edDataPipelineClient {
async fn activate_pipeline(&self, builder: ActivatePipelineInputBuilder) -> Result<ActivatePipelineOutput, SdkError<ActivatePipelineError>>;
async fn add_tags(&self, builder: AddTagsInputBuilder) -> Result<AddTagsOutput, SdkError<AddTagsError>>;
async fn create_pipeline(&self, builder: CreatePipelineInputBuilder) -> Result<CreatePipelineOutput, SdkError<CreatePipelineError>>;
async fn deactivate_pipeline(&self, builder: DeactivatePipelineInputBuilder) -> Result<DeactivatePipelineOutput, SdkError<DeactivatePipelineError>>;
async fn delete_pipeline(&self, builder: DeletePipelineInputBuilder) -> Result<DeletePipelineOutput, SdkError<DeletePipelineError>>;
async fn describe_objects(&self, builder: DescribeObjectsInputBuilder) -> Result<DescribeObjectsOutput, SdkError<DescribeObjectsError>>;
async fn describe_pipelines(&self, builder: DescribePipelinesInputBuilder) -> Result<DescribePipelinesOutput, SdkError<DescribePipelinesError>>;
async fn evaluate_expression(&self, builder: EvaluateExpressionInputBuilder) -> Result<EvaluateExpressionOutput, SdkError<EvaluateExpressionError>>;
async fn get_pipeline_definition(&self, builder: GetPipelineDefinitionInputBuilder) -> Result<GetPipelineDefinitionOutput, SdkError<GetPipelineDefinitionError>>;
async fn list_pipelines(&self, builder: ListPipelinesInputBuilder) -> Result<ListPipelinesOutput, SdkError<ListPipelinesError>>;
async fn poll_for_task(&self, builder: PollForTaskInputBuilder) -> Result<PollForTaskOutput, SdkError<PollForTaskError>>;
async fn put_pipeline_definition(&self, builder: PutPipelineDefinitionInputBuilder) -> Result<PutPipelineDefinitionOutput, SdkError<PutPipelineDefinitionError>>;
async fn query_objects(&self, builder: QueryObjectsInputBuilder) -> Result<QueryObjectsOutput, SdkError<QueryObjectsError>>;
async fn remove_tags(&self, builder: RemoveTagsInputBuilder) -> Result<RemoveTagsOutput, SdkError<RemoveTagsError>>;
async fn report_task_progress(&self, builder: ReportTaskProgressInputBuilder) -> Result<ReportTaskProgressOutput, SdkError<ReportTaskProgressError>>;
async fn report_task_runner_heartbeat(&self, builder: ReportTaskRunnerHeartbeatInputBuilder) -> Result<ReportTaskRunnerHeartbeatOutput, SdkError<ReportTaskRunnerHeartbeatError>>;
async fn set_status(&self, builder: SetStatusInputBuilder) -> Result<SetStatusOutput, SdkError<SetStatusError>>;
async fn set_task_status(&self, builder: SetTaskStatusInputBuilder) -> Result<SetTaskStatusOutput, SdkError<SetTaskStatusError>>;
async fn validate_pipeline_definition(&self, builder: ValidatePipelineDefinitionInputBuilder) -> Result<ValidatePipelineDefinitionOutput, SdkError<ValidatePipelineDefinitionError>>;
}
}