Struct specifications::working::JobServiceClient

pub struct JobServiceClient { /* private fields */ }

The JobServiceClient can connect to a remote server implementing the DriverService protocol.

Implementations

impl JobServiceClient

pub async fn connect(address: impl Into<String>) -> Result<Self, Error>

Attempts to connect to the remote endpoint.

Arguments

• address: The address of the remote endpoint to connect to.

Returns

A new JobServiceClient instance that is connected to the remove endpoint.

Errors

This function errors if the connection could not be established for whatever reason.

pub async fn check_workflow( &mut self, request: impl IntoRequest<CheckWorkflowRequest>, ) -> Result<Response<CheckReply>, Status>

Send a request to validate a workflow to the connected endpoint.

Arguments

• request: The CheckWorkflowRequest to send to the endpoint.

Returns

The CheckReply the endpoint returns.

Errors

This function errors if either we failed to send the request or the endpoint itself failed to process it.

pub async fn check_task( &mut self, request: impl IntoRequest<CheckTaskRequest>, ) -> Result<Response<CheckReply>, Status>

Send a request to validate a task in a workflow to the connected endpoint.

Arguments

• request: The CheckTaskRequest to send to the endpoint.

Returns

The CheckReply the endpoint returns.

Errors

This function errors if either we failed to send the request or the endpoint itself failed to process it.

pub async fn preprocess( &mut self, request: impl IntoRequest<PreprocessRequest>, ) -> Result<Response<PreprocessReply>, Status>

Send a PreprocessRequest to the connected endpoint.

Arguments

• request: The PreprocessRequest to send to the endpoint.

Returns

The PreprocessReply the endpoint returns.

Errors

This function errors if either we failed to send the request or the endpoint itself failed to process it.

pub async fn execute( &mut self, request: impl IntoRequest<ExecuteRequest>, ) -> Result<Response<Streaming<ExecuteReply>>, Status>

Send an ExecuteRequest to the connected endpoint.

Arguments

• request: The ExecuteRequest to send to the endpoint.

Returns

The ExecuteReply the endpoint returns.

Errors

This function errors if either we failed to send the request or the endpoint itself failed to process it.

pub async fn commit( &mut self, request: impl IntoRequest<CommitRequest>, ) -> Result<Response<CommitReply>, Status>

Send a CommitRequest to the connected endpoint.

Arguments

• request: The CommitRequest to send to the endpoint.

Returns

The CommitReply the endpoint returns.

Errors

This function errors if either we failed to send the request or the endpoint itself failed to process it.

Trait Implementations

impl Clone for JobServiceClient

fn clone(&self) -> JobServiceClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for JobServiceClient

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

Formats the value using the given formatter.