Struct BatchStore 

pub struct BatchStore { /* private fields */ }

Implementations

impl BatchStore

pub fn new(dir: PathBuf) -> BatchStore

pub fn start( self: &Arc<Self>, endpoint: &str, input_file_id: &str, completion_window: &str, total: u64, owner: Option<&str>, job: impl FnOnce(String) + Send + 'static, ) -> Result<Batch, BatchesBusy>

Creates a batch and runs job with its id on a batch worker, or queues it behind the running ones. Refuses, creating nothing, when the queue is full.

pub fn create( &self, endpoint: &str, input_file_id: &str, completion_window: &str, total: u64, owner: Option<&str>, ) -> Batch

pub fn get(&self, id: &str) -> Option<Batch>

pub fn list(&self) -> Vec<Batch>

pub fn cancel(&self, id: &str) -> Option<(Batch, bool)>