Struct aruna_cache::notifications::NotificationCache

pub struct NotificationCache {
    pub cache: Cache,
    /* private fields */
}

Fields

cache: Cache

Implementations

impl NotificationCache

pub async fn new( token: impl Into<String>, server: impl Into<String>, qhandler: Box<dyn QueryHandler + Send + Sync> ) -> Result<Self>

pub async fn create_notifications_channel( &mut self, stream_consumer: String ) -> Result<()>

pub fn get_resource(&self, res: &Resource) -> Option<Resource>

pub fn get_user(&self, user_id: DieselUlid) -> Option<User>

pub fn check_with_targets( &self, from: &Resource, targets: Vec<Resource> ) -> Result<()>

pub fn traverse_graph( &self, from: &Resource ) -> Result<Vec<(Resource, Resource)>>

pub fn resource_update( &self, res: ApiResource, shared_id: DieselUlid, persistent_resource: Resource )

pub fn user_update(&self, user: User) -> Result<()>