pub trait FilesystemQueueManagerExt {
    fn init(config: Arc<Config>) -> Result<Arc<Self>>
    where
        Self: Sized
; fn get_config(&self) -> &Config; fn get_root_folder(config: &Config, queue: &QueueID) -> PathBuf { ... } fn get_queue_path(&self, queue: &QueueID) -> PathBuf { ... } }
Expand description

Extension to the GenericQueueManager to simplify filesystem implementation.

Required Methods§

fn init(config: Arc<Config>) -> Result<Arc<Self>>where
    Self: Sized,

fn get_config(&self) -> &Config

Provided Methods§

fn get_root_folder(config: &Config, queue: &QueueID) -> PathBuf

fn get_queue_path(&self, queue: &QueueID) -> PathBuf

Implementors§

§

impl FilesystemQueueManagerExt for vqueue::fs::QueueManager

§

impl FilesystemQueueManagerExt for vqueue::temp::QueueManager

Available on crate feature testing only.