jono_core 0.1.5

Shared core utilities for Jono queue libraries
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

use crate::{Error, Result};
use redis::Client as RedisClient;

/// Central Redis connection pool that manages access to all topics
pub struct Forum {
    redis_client: RedisClient,
}

impl Forum {
    /// Create a new forum with the specified Redis URL
    pub fn new(redis_url: &str) -> Result<Self> {
        let redis_client = RedisClient::open(redis_url).map_err(Error::Redis)?;
        Ok(Self { redis_client })
    }

    /// Create a forum with the default Redis URL from environment
    pub fn default() -> Result<Self> {
        let redis_url = crate::util::get_redis_url();
        Self::new(&redis_url)
    }

    /// Create a context for a specific topic
    pub fn topic(&self, topic: &str) -> crate::Context {
        crate::Context::new(self.clone(), topic)
    }

    /// Get a reference to the underlying Redis client
    pub(crate) fn redis_client(&self) -> &RedisClient {
        &self.redis_client
    }
}

impl Clone for Forum {
    fn clone(&self) -> Self {
        Self {
            redis_client: self.redis_client.clone(),
        }
    }
}