Struct google_api_proto::google::cloud::lifesciences::v2beta::workflows_service_v2_beta_client::WorkflowsServiceV2BetaClient
source · pub struct WorkflowsServiceV2BetaClient<T> { /* private fields */ }
Expand description
A service for running workflows, such as pipelines consisting of Docker containers.
Implementations§
source§impl<T> WorkflowsServiceV2BetaClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> WorkflowsServiceV2BetaClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn new(inner: T) -> Self
pub fn with_origin(inner: T, origin: Uri) -> Self
pub fn with_interceptor<F>(
inner: T,
interceptor: F
) -> WorkflowsServiceV2BetaClient<InterceptedService<T, F>>where
F: Interceptor,
T::ResponseBody: Default,
T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
<T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,
sourcepub fn send_compressed(self, encoding: CompressionEncoding) -> Self
pub fn send_compressed(self, encoding: CompressionEncoding) -> Self
Compress requests with the given encoding.
This requires the server to support it otherwise it might respond with an error.
sourcepub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
Enable decompressing responses.
sourcepub fn max_decoding_message_size(self, limit: usize) -> Self
pub fn max_decoding_message_size(self, limit: usize) -> Self
Limits the maximum size of a decoded message.
Default: 4MB
sourcepub fn max_encoding_message_size(self, limit: usize) -> Self
pub fn max_encoding_message_size(self, limit: usize) -> Self
Limits the maximum size of an encoded message.
Default: usize::MAX
sourcepub async fn run_pipeline(
&mut self,
request: impl IntoRequest<RunPipelineRequest>
) -> Result<Response<Operation>, Status>
pub async fn run_pipeline( &mut self, request: impl IntoRequest<RunPipelineRequest> ) -> Result<Response<Operation>, Status>
Runs a pipeline. The returned Operation’s [metadata] [google.longrunning.Operation.metadata] field will contain a [google.cloud.lifesciences.v2beta.Metadata][google.cloud.lifesciences.v2beta.Metadata] object describing the status of the pipeline execution. The [response][google.longrunning.Operation.response] field will contain a [google.cloud.lifesciences.v2beta.RunPipelineResponse][google.cloud.lifesciences.v2beta.RunPipelineResponse] object if the pipeline completes successfully.
Note: Before you can use this method, the Life Sciences Service Agent must have access to your project. This is done automatically when the Cloud Life Sciences API is first enabled, but if you delete this permission you must disable and re-enable the API to grant the Life Sciences Service Agent the required permissions. Authorization requires the following Google IAM permission:
lifesciences.workflows.run
Trait Implementations§
source§impl<T: Clone> Clone for WorkflowsServiceV2BetaClient<T>
impl<T: Clone> Clone for WorkflowsServiceV2BetaClient<T>
source§fn clone(&self) -> WorkflowsServiceV2BetaClient<T>
fn clone(&self) -> WorkflowsServiceV2BetaClient<T>
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl<T> !Freeze for WorkflowsServiceV2BetaClient<T>
impl<T> RefUnwindSafe for WorkflowsServiceV2BetaClient<T>where
T: RefUnwindSafe,
impl<T> Send for WorkflowsServiceV2BetaClient<T>where
T: Send,
impl<T> Sync for WorkflowsServiceV2BetaClient<T>where
T: Sync,
impl<T> Unpin for WorkflowsServiceV2BetaClient<T>where
T: Unpin,
impl<T> UnwindSafe for WorkflowsServiceV2BetaClient<T>where
T: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request