Skip to main content

SpawnRequest

asupersync::remote

Struct SpawnRequest

pub struct SpawnRequest {
    pub remote_task_id: RemoteTaskId,
    pub computation: ComputationName,
    pub input: RemoteInput,
    pub lease: Duration,
    pub idempotency_key: IdempotencyKey,
    pub budget: Option<Budget>,
    pub origin_node: NodeId,
    pub origin_region: RegionId,
    pub origin_task: TaskId,
}

Expand description

Request to spawn a named computation on a remote node.

Contains all information needed to start a remote task:

What to run (computation name + serialized inputs)
Who is asking (origin node, region, task)
How long to keep it alive (lease)
Deduplication key (idempotency)

§Idempotency

The idempotency_key ensures exactly-once execution. If the remote node receives a duplicate SpawnRequest (same key), it returns the existing SpawnAck without re-executing.

Fields§

§remote_task_id: RemoteTaskId

Unique identifier for this remote task.

§computation: ComputationName

Name of the computation to execute.

§input: RemoteInput

Serialized input data.

§lease: Duration

Requested lease duration.

§idempotency_key: IdempotencyKey

Idempotency key for deduplication.

§budget: Option<Budget>

Budget constraints for the remote task (optional).

§origin_node: NodeId

Node that originated the request.

§origin_region: RegionId

Region that owns the remote task on the originator.

§origin_task: TaskId

Task that spawned the remote task on the originator.

Trait Implementations§

impl Clone for SpawnRequest

fn clone(&self) -> SpawnRequest

Returns a duplicate of the value. Read more

1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more

impl Debug for SpawnRequest

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl Freeze for SpawnRequest

impl RefUnwindSafe for SpawnRequest

impl Send for SpawnRequest

impl Sync for SpawnRequest

impl Unpin for SpawnRequest

impl UnsafeUnpin for SpawnRequest

impl UnwindSafe for SpawnRequest

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, _span: NoopSpan) -> Self

Instruments this future with a span (no-op when disabled).

fn in_current_span(self) -> Self

Instruments this future with the current span (no-op when disabled).

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> Same for T

type Output = T

Should always be Self

impl<T> ToOwned for T
where T: Clone,

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V