Struct googapis::google::cloud::dataproc::v1::workflow_template_service_client::WorkflowTemplateServiceClient

pub struct WorkflowTemplateServiceClient<T> { /* fields omitted */ }

The API interface for managing Workflow Templates in the Dataproc API.

Implementations

impl<T> WorkflowTemplateServiceClient<T> where
    T: GrpcService<BoxBody>,
    T::ResponseBody: Body + Send + 'static,
    T::Error: Into<StdError>,
    <T::ResponseBody as Body>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor<F>(
    inner: T,
    interceptor: F
) -> WorkflowTemplateServiceClient<InterceptedService<T, F>> where
    F: Interceptor,
    T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
    <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync, 

pub fn send_gzip(self) -> Self

Compress requests with gzip.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_gzip(self) -> Self

Enable decompressing responses with gzip.

pub async fn create_workflow_template(
    &mut self,
    request: impl IntoRequest<CreateWorkflowTemplateRequest>
) -> Result<Response<WorkflowTemplate>, Status>

Creates new workflow template.

pub async fn get_workflow_template(
    &mut self,
    request: impl IntoRequest<GetWorkflowTemplateRequest>
) -> Result<Response<WorkflowTemplate>, Status>

Retrieves the latest workflow template.

Can retrieve previously instantiated template by specifying optional version parameter.

pub async fn instantiate_workflow_template(
    &mut self,
    request: impl IntoRequest<InstantiateWorkflowTemplateRequest>
) -> Result<Response<Operation>, Status>

Instantiates a template and begins execution.

The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.

The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.

The [Operation.metadata][google.longrunning.Operation.metadata] will be WorkflowMetadata. Also see Using WorkflowMetadata.

On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].

pub async fn instantiate_inline_workflow_template(
    &mut self,
    request: impl IntoRequest<InstantiateInlineWorkflowTemplateRequest>
) -> Result<Response<Operation>, Status>

Instantiates a template and begins execution.

This method is equivalent to executing the sequence [CreateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.CreateWorkflowTemplate], [InstantiateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.InstantiateWorkflowTemplate], [DeleteWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.DeleteWorkflowTemplate].

The returned Operation can be used to track execution of workflow by polling [operations.get][google.longrunning.Operations.GetOperation]. The Operation will complete when entire workflow is finished.

The running workflow can be aborted via [operations.cancel][google.longrunning.Operations.CancelOperation]. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.

The [Operation.metadata][google.longrunning.Operation.metadata] will be WorkflowMetadata. Also see Using WorkflowMetadata.

On successful completion, [Operation.response][google.longrunning.Operation.response] will be [Empty][google.protobuf.Empty].

pub async fn update_workflow_template(
    &mut self,
    request: impl IntoRequest<UpdateWorkflowTemplateRequest>
) -> Result<Response<WorkflowTemplate>, Status>

Updates (replaces) workflow template. The updated template must contain version that matches the current server version.

pub async fn list_workflow_templates(
    &mut self,
    request: impl IntoRequest<ListWorkflowTemplatesRequest>
) -> Result<Response<ListWorkflowTemplatesResponse>, Status>

Lists workflows that match the specified filter in the request.

pub async fn delete_workflow_template(
    &mut self,
    request: impl IntoRequest<DeleteWorkflowTemplateRequest>
) -> Result<Response<()>, Status>

Deletes a workflow template. It does not cancel in-progress workflows.

Trait Implementations

impl<T: Clone> Clone for WorkflowTemplateServiceClient<T>

fn clone(&self) -> WorkflowTemplateServiceClient<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for WorkflowTemplateServiceClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.