Struct Store 

pub struct Store { /* private fields */ }

Implementations

impl Store

pub fn load(&self, cap: usize, rt: &Arc<Runtime>) -> Result<Vec<Arc<Process>>>

pub fn load_proc( &self, pid: &str, rt: &Arc<Runtime>, ) -> Result<Option<Arc<Process>>>

pub fn remove_proc(&self, pid: &str) -> Result<bool>

pub fn set_message(&self, id: &str, status: MessageStatus) -> Result<()>

pub fn set_message_with( &self, pid: &str, tid: &str, status: MessageStatus, ) -> Result<bool>

pub fn with_no_response_messages<F: Fn(&Message)>( &self, timeout_millis: i64, max_message_retry_times: i32, f: F, ) -> Result<()>

pub fn resend_error_messages(&self) -> Result<()>

pub fn clear_error_messages(&self, pid: Option<String>) -> Result<()>

pub fn upsert_task(&self, task: &Arc<Task>) -> Result<()>

pub fn upsert_proc(&self, proc: &Arc<Process>) -> Result<()>

impl Store

pub fn new(kv: Arc<dyn KvStore>) -> Self

pub fn create(config: &Config) -> Result<Self>

pub fn register(&self, kv: Arc<dyn KvStore + Send + Sync + 'static>)

pub fn tasks(&self) -> Arc<dyn DbCollection<Item = Task>>

pub fn procs(&self) -> Arc<dyn DbCollection<Item = Proc>>

pub fn packages(&self) -> Arc<dyn DbCollection<Item = Package>>

pub fn models(&self) -> Arc<dyn DbCollection<Item = Model>>

pub fn messages(&self) -> Arc<dyn DbCollection<Item = Message>>

pub fn events(&self) -> Arc<dyn DbCollection<Item = Event>>

pub fn publish(&self, pack: &Package) -> Result<bool>

pub fn deploy(&self, model: &Workflow) -> Result<bool>