Struct ngtask_queue_basic::TaskQueue

pub struct TaskQueue {
    pub is_initialised: bool,
    pub id_queue: HashMap<String, String>,
    pub category_queues: HashMap<String, Vec<String>>,
}

Fields

is_initialised: bool

id_queue: HashMap<String, String>

category_queues: HashMap<String, Vec<String>>

Trait Implementations

impl NGTQ for TaskQueue

fn initialise() -> Arc<Mutex<TaskQueue>>

Returns an instance of your TaskQueue wrapped in Arc<Mutex<>>

fn get_id_queue_len(&self) -> Result<usize, NGTQError>

Returns the current number of tasks in the ID queue

fn get_category_queue_len(&self, category: &str) -> Result<usize, NGTQError>

Returns the current number of tasks in a specific category queue

fn push_id_task_to_queue( &mut self, payload: String, ) -> Result<String, NGTQError>

Push a new task to the id queue - Return queue size after adding the new task

fn push_category_task_to_queue( &mut self, category: String, payload: String, ) -> Result<(), NGTQError>

Push a new task to the category queue

fn pull_id_task_from_queue(&mut self, id: &str) -> Result<String, NGTQError>

Pull a payload from the id queue based on the givin id - Return payload (String)

fn pull_category_task_from_queue( &mut self, category: &str, ) -> Result<String, NGTQError>

Pull a payload from the category queue - Return payload (String)