Struct CloudTaskQueue 

pub struct CloudTaskQueue { /* private fields */ }

A priority-ordered queue of CloudTask items.

Tasks are stored in four internal lanes — one per QueuePriority — so that higher-priority tasks are always served before lower-priority ones, regardless of submission order.

Implementations

impl CloudTaskQueue

pub fn new(capacity: usize) -> Self

Create a new queue with the given maximum capacity.

pub fn len(&self) -> usize

Total number of tasks currently held (excluding expired tasks).

pub fn is_empty(&self) -> bool

Returns true when the queue holds no tasks.

pub fn enqueue( &mut self, priority: QueuePriority, payload: Vec<u8>, ) -> Result<u64, TaskQueueError>

Submit a task at the specified priority.

Expired tasks are purged from the queue before the capacity check so that the caller can always make room by waiting for TTLs to elapse.

pub fn enqueue_task(&mut self, task: CloudTask) -> Result<(), TaskQueueError>

Submit a pre-built CloudTask directly.

pub fn dequeue(&mut self) -> Result<CloudTask, TaskQueueError>

Dequeue the next highest-priority, non-expired task (Critical → Low).

pub fn dequeue_batch( &mut self, max_count: usize, ) -> Result<Vec<CloudTask>, TaskQueueError>

Dequeue up to max_count tasks in priority order.

Returns an error if max_count is zero; returns a (possibly shorter) Vec if fewer than max_count tasks are available.

pub fn lane_depth(&self, priority: QueuePriority) -> usize

Number of tasks waiting in the given priority lane.

pub fn clear(&mut self)

Discard all tasks in every lane.

Trait Implementations

impl Debug for CloudTaskQueue

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

Formats the value using the given formatter.