rs-zero 0.1.0

Rust-first microservice framework inspired by go-zero engineering practices
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

use crate::cache_redis::{RedisCacheConfig, RedisCacheError, RedisCacheResult};

/// Factory for Redis clients.
#[derive(Debug, Clone)]
pub struct RedisClientFactory {
    config: RedisCacheConfig,
}

impl RedisClientFactory {
    /// Creates a factory and validates the URL shape.
    pub fn new(config: RedisCacheConfig) -> RedisCacheResult<Self> {
        if !config.url.starts_with("redis://") && !config.url.starts_with("rediss://") {
            return Err(RedisCacheError::InvalidUrl { url: config.url });
        }
        Ok(Self { config })
    }

    /// Returns the configured Redis URL.
    pub fn url(&self) -> &str {
        &self.config.url
    }

    /// Creates a real Redis client when the `cache-redis` feature is enabled.
    #[cfg(feature = "cache-redis")]
    pub fn create_client(&self) -> RedisCacheResult<redis::Client> {
        redis::Client::open(self.config.url.as_str())
            .map_err(|error| RedisCacheError::Backend(error.to_string()))
    }
}