Struct QueueManager

pub struct QueueManager {
    inner: RwLock<VecMap<QueueId, Queue>>,
    threads: Semaphore,
}

Fields

inner: RwLock<VecMap<QueueId, Queue>>

threads: Semaphore

Implementations

impl QueueManager

pub fn clear()

pub fn initialize(num_threads: u8)

pub fn get() -> &'static Self

Panics

pub fn new_queue(&self, queue_name: &str) -> QueueId

pub fn all_queues( &self, ) -> Vec<(QueueId, QueueName, Option<Vec<SandboxedRepository>>)>

pub fn with_all_queues<R>(&self, f: impl FnOnce(&[(QueueId, Queue)]) -> R) -> R

pub fn queues_for_user( &self, user_name: &str, ) -> Vec<(QueueId, QueueName, Option<Vec<SandboxedRepository>>)>

pub fn with_queue<R>( &self, id: QueueId, f: impl FnOnce(Option<&Queue>) -> R, ) -> R

pub fn migrate<R>( &self, id: QueueId, then: impl FnOnce(&SandboxedBackend) -> Result<R>, ) -> Result<(R, usize)>

Available on crate feature tokio only.

Errors

fn migrate_i<R>( &self, id: QueueId, then: impl FnOnce(&SandboxedBackend) -> Result<R>, ) -> Result<(R, usize)>

Available on crate feature tokio only.

pub fn delete(&self, id: QueueId)

pub fn start_queue(&self, id: QueueId) -> Result<(), ()>

Errors

if no queue with that id exists

pub fn requeue_failed(&self, id: QueueId) -> Result<(), ()>

Errors

if no queue with that id exists

pub fn with_global<R>(&self, f: impl FnOnce(&Queue) -> R) -> R

Trait Implementations

impl Debug for QueueManager

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

Formats the value using the given formatter.