Enum homestar_invocation::task::instruction::input::Input

pub enum Input<T> {
    Ipld(Ipld),
    Deferred(Await),
    Arg(Result<T>),
}

Contains parameters expected by the URI/Ability pair.

Left to the executor to define the shape of this data, per job.

Variants

Ipld(Ipld)

[Ipld] Literals.

Deferred(Await)

Promise-links awaiting the output of another Instruction’s invocation, directly.

Arg(Result<T>)

General argument, wrapping an task::Result over a task-specific implementation’s own input type(s).

Implementations

impl<T> Input<T>

pub async fn resolve<'a, F>(self, lookup_fn: F) -> Input<T>

where F: Fn(Cid) -> BoxFuture<'a, Result<Result<T>, ResolveError>> + Clone + Send + Sync, Ipld: From<T>,

Resolve [awaited promise] of an Input into a task-specific Input::Arg, given a successful lookup function; otherwise, return Input::Deferred for an unresolved promise, or just return Input::Ipld, resolving Ipld links if the lookup function expected [Ipld] input data.

Trait Implementations

impl<T: Clone> Clone for Input<T>

fn clone(&self) -> Input<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Input<T>

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for Input<T>

where T: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> From<Await> for Input<T>

fn from(await_promise: Await) -> Self

Converts to this type from the input type.

impl<T> From<Input<T>> for Ipld

where Ipld: From<T>,

fn from(input: Input<T>) -> Self

Converts to this type from the input type.

impl Parse<Unit> for Input<Unit>

fn parse(&self) -> Result<Parsed<Unit>, InputParseError<Unit>>

Function returning Parsed structure for execution/invocation.

impl<T: PartialEq> PartialEq for Input<T>

fn eq(&self, other: &Input<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T> Serialize for Input<T>

where T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T> TryFrom<Ipld> for Input<T>

where T: From<Ipld>,

type Error = Error<String>

The type returned in the event of a conversion error.

fn try_from(ipld: Ipld) -> Result<Self, Self::Error>

Performs the conversion.

impl<T> StructuralPartialEq for Input<T>