#[async_trait::async_trait]
pub trait DocumentProcessorService: std::fmt::Debug + Send + Sync {
async fn process_document(
&self,
req: crate::model::ProcessRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ProcessResponse>>;
async fn batch_process_documents(
&self,
req: crate::model::BatchProcessRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn fetch_processor_types(
&self,
req: crate::model::FetchProcessorTypesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchProcessorTypesResponse>>;
async fn list_processor_types(
&self,
req: crate::model::ListProcessorTypesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListProcessorTypesResponse>>;
async fn get_processor_type(
&self,
req: crate::model::GetProcessorTypeRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ProcessorType>>;
async fn list_processors(
&self,
req: crate::model::ListProcessorsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListProcessorsResponse>>;
async fn get_processor(
&self,
req: crate::model::GetProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Processor>>;
async fn train_processor_version(
&self,
req: crate::model::TrainProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn get_processor_version(
&self,
req: crate::model::GetProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ProcessorVersion>>;
async fn list_processor_versions(
&self,
req: crate::model::ListProcessorVersionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListProcessorVersionsResponse>>;
async fn delete_processor_version(
&self,
req: crate::model::DeleteProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn deploy_processor_version(
&self,
req: crate::model::DeployProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn undeploy_processor_version(
&self,
req: crate::model::UndeployProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn create_processor(
&self,
req: crate::model::CreateProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Processor>>;
async fn delete_processor(
&self,
req: crate::model::DeleteProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn enable_processor(
&self,
req: crate::model::EnableProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn disable_processor(
&self,
req: crate::model::DisableProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn set_default_processor_version(
&self,
req: crate::model::SetDefaultProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn review_document(
&self,
req: crate::model::ReviewDocumentRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn evaluate_processor_version(
&self,
req: crate::model::EvaluateProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn get_evaluation(
&self,
req: crate::model::GetEvaluationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Evaluation>>;
async fn list_evaluations(
&self,
req: crate::model::ListEvaluationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListEvaluationsResponse>>;
async fn list_locations(
&self,
req: google_cloud_location::model::ListLocationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_location::model::ListLocationsResponse>>;
async fn get_location(
&self,
req: google_cloud_location::model::GetLocationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_location::model::Location>>;
async fn list_operations(
&self,
req: google_cloud_longrunning::model::ListOperationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn cancel_operation(
&self,
req: google_cloud_longrunning::model::CancelOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
fn get_polling_error_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;
fn get_polling_backoff_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}
#[async_trait::async_trait]
impl<T: super::DocumentProcessorService> DocumentProcessorService for T {
async fn process_document(
&self,
req: crate::model::ProcessRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ProcessResponse>> {
T::process_document(self, req, options).await
}
async fn batch_process_documents(
&self,
req: crate::model::BatchProcessRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::batch_process_documents(self, req, options).await
}
async fn fetch_processor_types(
&self,
req: crate::model::FetchProcessorTypesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchProcessorTypesResponse>> {
T::fetch_processor_types(self, req, options).await
}
async fn list_processor_types(
&self,
req: crate::model::ListProcessorTypesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListProcessorTypesResponse>> {
T::list_processor_types(self, req, options).await
}
async fn get_processor_type(
&self,
req: crate::model::GetProcessorTypeRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ProcessorType>> {
T::get_processor_type(self, req, options).await
}
async fn list_processors(
&self,
req: crate::model::ListProcessorsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListProcessorsResponse>> {
T::list_processors(self, req, options).await
}
async fn get_processor(
&self,
req: crate::model::GetProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Processor>> {
T::get_processor(self, req, options).await
}
async fn train_processor_version(
&self,
req: crate::model::TrainProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::train_processor_version(self, req, options).await
}
async fn get_processor_version(
&self,
req: crate::model::GetProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ProcessorVersion>> {
T::get_processor_version(self, req, options).await
}
async fn list_processor_versions(
&self,
req: crate::model::ListProcessorVersionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListProcessorVersionsResponse>> {
T::list_processor_versions(self, req, options).await
}
async fn delete_processor_version(
&self,
req: crate::model::DeleteProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_processor_version(self, req, options).await
}
async fn deploy_processor_version(
&self,
req: crate::model::DeployProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::deploy_processor_version(self, req, options).await
}
async fn undeploy_processor_version(
&self,
req: crate::model::UndeployProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::undeploy_processor_version(self, req, options).await
}
async fn create_processor(
&self,
req: crate::model::CreateProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Processor>> {
T::create_processor(self, req, options).await
}
async fn delete_processor(
&self,
req: crate::model::DeleteProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_processor(self, req, options).await
}
async fn enable_processor(
&self,
req: crate::model::EnableProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::enable_processor(self, req, options).await
}
async fn disable_processor(
&self,
req: crate::model::DisableProcessorRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::disable_processor(self, req, options).await
}
async fn set_default_processor_version(
&self,
req: crate::model::SetDefaultProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::set_default_processor_version(self, req, options).await
}
async fn review_document(
&self,
req: crate::model::ReviewDocumentRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::review_document(self, req, options).await
}
async fn evaluate_processor_version(
&self,
req: crate::model::EvaluateProcessorVersionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::evaluate_processor_version(self, req, options).await
}
async fn get_evaluation(
&self,
req: crate::model::GetEvaluationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Evaluation>> {
T::get_evaluation(self, req, options).await
}
async fn list_evaluations(
&self,
req: crate::model::ListEvaluationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListEvaluationsResponse>> {
T::list_evaluations(self, req, options).await
}
async fn list_locations(
&self,
req: google_cloud_location::model::ListLocationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_location::model::ListLocationsResponse>> {
T::list_locations(self, req, options).await
}
async fn get_location(
&self,
req: google_cloud_location::model::GetLocationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_location::model::Location>> {
T::get_location(self, req, options).await
}
async fn list_operations(
&self,
req: google_cloud_longrunning::model::ListOperationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
{
T::list_operations(self, req, options).await
}
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::get_operation(self, req, options).await
}
async fn cancel_operation(
&self,
req: google_cloud_longrunning::model::CancelOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::cancel_operation(self, req, options).await
}
fn get_polling_error_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
T::get_polling_error_policy(self, options)
}
fn get_polling_backoff_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
T::get_polling_backoff_policy(self, options)
}
}