Struct SimpleNotificationStore

pub struct SimpleNotificationStore {
    pub data: Arc<RwLock<HashMap<Uuid, HashMap<Uuid, NotificationData>>>>,
    pub notification_vs_job: Arc<RwLock<HashMap<Uuid, Uuid>>>,
    pub inited: bool,
}

Fields

data: Arc<RwLock<HashMap<Uuid, HashMap<Uuid, NotificationData>>>>

notification_vs_job: Arc<RwLock<HashMap<Uuid, Uuid>>>

inited: bool

Trait Implementations

impl Default for SimpleNotificationStore

fn default() -> Self

Returns the “default value” for a type.

impl NotificationStore for SimpleNotificationStore

fn list_notification_guids_for_job_and_state( &mut self, job_id: Uuid, state: JobState, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>, JobSchedulerError>> + Send>>

fn list_notification_guids_for_job_id( &mut self, job_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>, JobSchedulerError>> + Send>>

fn delete_notification_for_state( &mut self, notification_id: Uuid, state: JobState, ) -> Pin<Box<dyn Future<Output = Result<bool, JobSchedulerError>> + Send>>

fn delete_for_job( &mut self, job_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), JobSchedulerError>> + Send>>