Struct BackgroundExecutionQueue 

pub struct BackgroundExecutionQueue { /* private fields */ }

BackgroundExecutionQueue - Queue for managing background executions This is an in-memory implementation for testing. Production uses Redis/Postgres.

Implementations

impl BackgroundExecutionQueue

pub fn new() -> Self

Create a new empty queue

pub fn enqueue(&mut self, execution: BackgroundExecution)

Enqueue a new execution

pub fn dequeue(&mut self) -> Option<BackgroundExecution>

Dequeue the next execution to run

pub fn peek(&self) -> Option<&BackgroundExecution>

Peek at the next execution without removing it

pub fn len(&self) -> usize

Get queue length

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn execution_ids(&self) -> Vec<ExecutionId>

Get all queued execution IDs

Trait Implementations

impl Debug for BackgroundExecutionQueue

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

Formats the value using the given formatter.

impl Default for BackgroundExecutionQueue

fn default() -> BackgroundExecutionQueue

Returns the “default value” for a type.