pub struct DequeueWithReceipt {
pub message: InfraQueueMessage,
pub receipt: String,
}Expand description
Result of dequeue with receipt token for ack/nack.
In LLM workflows, treat receipt like a visibility token; your worker:
- dequeues with a visibility window sized to the expected generation time,
- runs the model call,
- ACKs on success (deletes inflight and body), or NACKs on transient failure to reschedule.
Note: If the worker crashes or the visibility window elapses before ACK/NACK, the message becomes eligible for reclaim and may be delivered again (at-least-once).
Fields§
§message: InfraQueueMessage§receipt: StringTrait Implementations§
Source§impl Clone for DequeueWithReceipt
impl Clone for DequeueWithReceipt
Source§fn clone(&self) -> DequeueWithReceipt
fn clone(&self) -> DequeueWithReceipt
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for DequeueWithReceipt
impl RefUnwindSafe for DequeueWithReceipt
impl Send for DequeueWithReceipt
impl Sync for DequeueWithReceipt
impl Unpin for DequeueWithReceipt
impl UnsafeUnpin for DequeueWithReceipt
impl UnwindSafe for DequeueWithReceipt
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more