Struct googapis::google::cloud::workflows::v1::workflows_client::WorkflowsClient [−][src]
pub struct WorkflowsClient<T> { /* fields omitted */ }
Expand description
Workflows is used to deploy and execute workflow programs. Workflows makes sure the program executes reliably, despite hardware and networking interruptions.
Implementations
impl<T> WorkflowsClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> WorkflowsClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn with_interceptor<F>(
inner: T,
interceptor: F
) -> WorkflowsClient<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,
Compress requests with gzip
.
This requires the server to support it otherwise it might respond with an error.
Enable decompressing responses with gzip
.
pub async fn list_workflows(
&mut self,
request: impl IntoRequest<ListWorkflowsRequest>
) -> Result<Response<ListWorkflowsResponse>, Status>
pub async fn list_workflows(
&mut self,
request: impl IntoRequest<ListWorkflowsRequest>
) -> Result<Response<ListWorkflowsResponse>, Status>
Lists Workflows in a given project and location. The default order is not specified.
pub async fn get_workflow(
&mut self,
request: impl IntoRequest<GetWorkflowRequest>
) -> Result<Response<Workflow>, Status>
pub async fn get_workflow(
&mut self,
request: impl IntoRequest<GetWorkflowRequest>
) -> Result<Response<Workflow>, Status>
Gets details of a single Workflow.
pub async fn create_workflow(
&mut self,
request: impl IntoRequest<CreateWorkflowRequest>
) -> Result<Response<Operation>, Status>
pub async fn create_workflow(
&mut self,
request: impl IntoRequest<CreateWorkflowRequest>
) -> Result<Response<Operation>, Status>
Creates a new workflow. If a workflow with the specified name already exists in the specified project and location, the long running operation will return [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
pub async fn delete_workflow(
&mut self,
request: impl IntoRequest<DeleteWorkflowRequest>
) -> Result<Response<Operation>, Status>
pub async fn delete_workflow(
&mut self,
request: impl IntoRequest<DeleteWorkflowRequest>
) -> Result<Response<Operation>, Status>
Deletes a workflow with the specified name. This method also cancels and deletes all running executions of the workflow.
pub async fn update_workflow(
&mut self,
request: impl IntoRequest<UpdateWorkflowRequest>
) -> Result<Response<Operation>, Status>
pub async fn update_workflow(
&mut self,
request: impl IntoRequest<UpdateWorkflowRequest>
) -> Result<Response<Operation>, Status>
Updates an existing workflow. Running this method has no impact on already running executions of the workflow. A new revision of the workflow may be created as a result of a successful update operation. In that case, such revision will be used in new workflow executions.
Trait Implementations
Auto Trait Implementations
impl<T> RefUnwindSafe for WorkflowsClient<T> where
T: RefUnwindSafe,
impl<T> Send for WorkflowsClient<T> where
T: Send,
impl<T> Sync for WorkflowsClient<T> where
T: Sync,
impl<T> Unpin for WorkflowsClient<T> where
T: Unpin,
impl<T> UnwindSafe for WorkflowsClient<T> where
T: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more