Enum Invocation 

#[non_exhaustive]
pub enum Invocation<R: DeserializeOwned> {
    Sync(SyncInvocation<R>),
    Distributed(InvocationHandle<R>),
}

Unified invocation type — same API for sync and distributed execution.

Created by app.call(). The caller doesn’t need to know whether the task was executed synchronously or routed through the broker.

Matches pynenc’s pattern where Task._call() returns either a ConcurrentInvocation or DistributedInvocation through a common BaseInvocation interface.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Sync(SyncInvocation<R>)

Sync execution (dev mode). Result is already computed.

Distributed(InvocationHandle<R>)

Distributed execution. Result available after runner processes it.

Implementations

impl<R: DeserializeOwned> Invocation<R>

pub fn invocation_id(&self) -> &InvocationId

Get the invocation’s unique identifier.

pub async fn status(&self) -> RustvelloResult<InvocationStatus>

Get the current status of this invocation.

pub async fn is_done(&self) -> RustvelloResult<bool>

Check if the invocation has finished (success or failure).

pub async fn result(self) -> RustvelloResult<R>

Get the typed result.

For sync invocations, returns immediately. For distributed invocations, may fail if not yet complete.

pub async fn wait(self, poll_interval: Duration) -> RustvelloResult<R>

Wait for the invocation to complete, polling at the given interval.

pub async fn wait_timeout( self, timeout: Duration, poll_interval: Duration, ) -> RustvelloResult<R>

Wait with a timeout.

pub fn is_sync(&self) -> bool

Returns true if this is a sync invocation.

pub fn is_distributed(&self) -> bool

Returns true if this is a distributed invocation.

Trait Implementations

impl<R: DeserializeOwned> Debug for Invocation<R>

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

Formats the value using the given formatter.