Struct Queue 

pub struct Queue {
    pub path: PathBuf,
}

Fields

path: PathBuf

Implementations

impl Queue

pub fn new(path: PathBuf) -> Self

pub fn push( &self, sources: Vec<Source>, title: Option<String>, metadata: Value, session_id: Option<String>, blocked_by: Vec<String>, ) -> Result<Item>

Add a new item to the queue. Returns the created Item.

pub fn all(&self) -> Vec<Item>

Get all items, skipping corrupt lines with warnings.

pub fn find(&self, id: &str) -> Option<Item>

Find an item by ID.

pub fn filter(&self, status: Option<&str>) -> Vec<Item>

Filter items by status (optional).

pub fn ready(&self) -> Vec<Item>

Return pending items that are not blocked by any pending item.

pub fn update(&self, id: &str, attrs: UpdateAttrs) -> Result<Option<Item>>

Update an item by ID. Returns the updated Item or None.

pub fn remove(&self, id: &str) -> Result<Option<Item>>

Remove an item by ID. Returns the removed Item or None.