Struct JobHandle

pub struct JobHandle<J = (), C = Channel> { /* private fields */ }

A handle to a single job.

The handle also caches the details of the job, so that they can be accessed without making a network request.

Implementations

impl<J, C> JobHandle<J, C>

where C: GrpcService<BoxBody> + Clone, C::Error: Into<StdError>, C::ResponseBody: Body<Data = Bytes> + Send + 'static, <C::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn id(&self) -> Uuid

Get the ID of the job.

pub async fn details(&self) -> Result<Arc<JobDetails>>

Get the details of the job.

pub async fn status(&self) -> Result<JobStatus>

Get the status of the job.

pub fn details_cached(&self) -> Option<Arc<JobDetails>>

Get the cached details of the job, if available.

This is useful for getting the details of a job without making a network request.

pub async fn cancel(&self) -> Result<()>

Cancel the job.

pub fn cast_type<T: JobType>(&self) -> JobHandle<T, C>

Cast the job handle to a specific job type.

This does not perform any runtime checks, so it is up to the caller to ensure that the job type is correct.

pub fn cast_unknown(&self) -> JobHandle<(), C>

Cast the job handle to an unknown job type.

impl<J, C> JobHandle<J, C>

where J: JobType, C: GrpcService<BoxBody> + Clone, C::Error: Into<StdError>, C::ResponseBody: Body<Data = Bytes> + Send + 'static, <C::ResponseBody as Body>::Error: Into<StdError> + Send,

pub async fn input(&self) -> Result<J>

Retrieve the input of the job.

pub async fn wait(&self) -> Result<J::Output>

Retrieve the output of the job.

pub async fn wait_with_interval(&self, interval: Duration) -> Result<J::Output>

Retrieve the output of the job with a given polling interval.

Trait Implementations

impl<J> Clone for JobHandle<J>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<J: Debug, C: Debug> Debug for JobHandle<J, C>

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

Formats the value using the given formatter.

impl<J, C> IntoFuture for JobHandle<J, C>

where J: JobType, C: GrpcService<BoxBody> + Clone + Send + Sync + 'static, <C as GrpcService<BoxBody>>::Future: Send, C::Error: Into<StdError> + Send, C::ResponseBody: Body<Data = Bytes> + Send + 'static, <C::ResponseBody as Body>::Error: Into<StdError> + Send,

type Output = Result<<J as JobType>::Output, Report>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <JobHandle<J, C> as IntoFuture>::Output> + Send>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.