rustium 0.1.4

A Rust application framework that values concurrency, performance, and scalability
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

use axum::async_trait;
use di::injectable;
use redis::{
    Client, Commands, Connection, ConnectionAddr, ConnectionInfo, RedisConnectionInfo, SetExpiry,
    SetOptions, Value,
};

use crate::{datastore::ikv_dal::IKvDal, prelude::*, settings::redis::RedisSettings};
// region: Structs

#[injectable(IKvDal)]
pub struct RedisDAL {
    pub con: Option<Connection>,
}
// endregion: Structs

// region: Implementation

impl Default for RedisDAL {
    fn default() -> Self {
        Self { con: Option::None }
    }
}

impl RedisDAL {
    pub async fn new(conf: RedisSettings) -> RustiumResult<Self> {
        let client = Client::open(ConnectionInfo {
            addr: ConnectionAddr::Tcp(conf.server.into(), conf.port.into()),
            redis: RedisConnectionInfo {
                db: conf.dbidx.into(),
                protocol: redis::ProtocolVersion::RESP3,
                username: Some(conf.username.into()),
                password: Some(conf.password.into()),
            },
        })?;
        let con = client.get_connection()?;
        Ok(Self { con: Some(con) })
    }
}

#[async_trait]
impl IKvDal for RedisDAL {
    async fn get(&mut self, key: &str) -> RustiumResult<Value> {
        Ok(self
            .con
            .as_mut()
            .expect("Redis service not initialized")
            .get(key)?)
    }

    async fn set(&mut self, key: &str, val: u64, exp: SetExpiry) -> RustiumResult<Value> {
        Ok(self
            .con
            .as_mut()
            .expect("Redis service not initialized")
            .set_options(
                key,
                val,
                SetOptions::default().get(true).with_expiration(exp),
            )?)
    }
}
// endregion: Implementation