Struct FjallTaskQueue 

pub struct FjallTaskQueue<D, S>
where
    S: TaskSerializer,
{ /* private fields */ }

Fjall-backed task queue (default backend).

Layout:

• tasks: task_id -> serialized task bytes
• queue: task_id (uuid v7 bytes) -> empty value (work to do)
• inflight: task_id -> empty value (leased to a worker, not yet acked)
• dlq: task_id -> serialized task bytes

Implementations

impl<D, S> FjallTaskQueue<D, S>

where S: TaskSerializer,

pub fn open(path: impl AsRef<Path>) -> Result<Self, TaskQueueError>

Trait Implementations

impl<D, S> Debug for FjallTaskQueue<D, S>

where S: TaskSerializer,

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

Formats the value using the given formatter.

impl<D, S> TaskQueue<D> for FjallTaskQueue<D, S>

where D: Debug + Clone + Serialize + DeserializeOwned + Send + Sync + 'static, S: TaskSerializer + Send + Sync,

fn push<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task<D>, ) -> Pin<Box<dyn Future<Output = Result<(), TaskQueueError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn pop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Task<D>, TaskQueueError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn ack<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<(), TaskQueueError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn nack<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task<D>, ) -> Pin<Box<dyn Future<Output = Result<(), TaskQueueError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn set<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task<D>, ) -> Pin<Box<dyn Future<Output = Result<(), TaskQueueError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn recover_inflight<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64, TaskQueueError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Move any tasks left in the in-flight set back to the queue. Called once at runtime startup to recover work owned by a previous process that crashed before acking. Returns the number of tasks recovered.