Enum QueuePayload 

pub enum QueuePayload {
    Function {
        args: Vec<u8>,
        fn_sig_hash: u64,
    },
    Fetch {
        method: String,
        url: String,
        headers: HashMap<String, String>,
        body: Vec<u8>,
    },
}

The work a queue item represents. Persists in yeti-queue as msgpack inside the payload column.

Variants

Function

Dispatch a registered #[queue_fn] in the owning wasm app.

Fields

args: Vec<u8>

Serialized (msgpack) tuple of the user function’s arguments after the leading &Context.

fn_sig_hash: u64

xxh3_64 of the canonicalized function signature. The worker rejects the item if the currently-registered function’s sig_hash differs (signature changed since enqueue — fail fast, don’t silently drop or mis-interpret args).

Fetch

Dispatch a cross-node fetch!() call — routes through the existing host reqwest bridge with the same HttpStats + inflight cap the synchronous fetch! macro uses.

Fields

method: String

HTTP method (uppercase).

url: String

Fully-qualified URL.

headers: HashMap<String, String>

HTTP headers, verbatim.

body: Vec<u8>

Request body bytes (may be empty).

Trait Implementations

impl Clone for QueuePayload

fn clone(&self) -> QueuePayload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueuePayload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueuePayload

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueuePayload

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

where __S: Serializer,

Serialize this value into the given Serde serializer.