Trait vqueue::FilesystemQueueManagerExt

pub trait FilesystemQueueManagerExt {
    // Required methods
    fn init(
        config: Arc<Config>,
        transport_deserializer: Vec<DeserializerFn>
    ) -> Result<Arc<Self>>
       where Self: Sized;
    fn get_config(&self) -> &Config;
    fn get_transport_deserializer(&self) -> &[DeserializerFn];

    // Provided methods
    fn get_root_folder(config: &Config, queue: &QueueID) -> PathBuf { ... }
    fn get_queue_path(&self, queue: &QueueID) -> PathBuf { ... }
}

Extension to the GenericQueueManager to simplify filesystem implementation.

Required Methods

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

fn get_config(&self) -> &Config

fn get_transport_deserializer(&self) -> &[DeserializerFn]

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.