mincat 0.1.0

Web framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use mincat_core::error::Error;

#[async_trait::async_trait]
pub trait SessionStore: Send + Sync + 'static {
    async fn init(&mut self) -> Result<(), Error> {
        self.delete_exp_task();
        Ok(())
    }

    async fn has_session(&self, session_id: &str) -> Result<bool, Error>;

    async fn register_key(&self, session_id: &str) -> Result<(), Error>;

    async fn set(&self, session_id: &str, key: &str, value: &str) -> Result<(), Error>;

    async fn get(&self, session_id: &str, key: &str) -> Result<Option<String>, Error>;

    async fn delete_exp(&self) -> Result<(), Error>;

    async fn update_exp(&self, session_id: &str) -> Result<(), Error>;

    fn get_delete_exp_task_boot_tag(&self) -> bool;

    fn get_delete_exp_task_interval(&self) -> u64;

    fn delete_exp_task(&self) {
        if self.get_delete_exp_task_boot_tag() {
            let self_task = self.clone_box();
            let interval = self.get_delete_exp_task_interval();
            tokio::spawn(async move {
                let mut interval =
                    tokio::time::interval(tokio::time::Duration::from_secs(interval));
                loop {
                    if let Err(e) = self_task.delete_exp().await {
                        tracing::error!("session delete exp key task error:{}", e);
                    }

                    interval.tick().await;
                }
            });
        }
    }

    fn clone_box(&self) -> Box<dyn SessionStore>;
}