sockudo 3.1.0

A simple, fast, and secure WebSocket server for real-time applications.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use crate::adapter::horizontal_adapter_base::HorizontalAdapterBase;
use crate::adapter::transports::RedisClusterTransport;
use crate::error::Result;
pub(crate) use crate::options::RedisClusterAdapterConfig;

/// Redis Cluster channels
pub const DEFAULT_PREFIX: &str = "sockudo";

/// Redis Cluster adapter for horizontal scaling - now a type alias for the base implementation
pub type RedisClusterAdapter = HorizontalAdapterBase<RedisClusterTransport>;

impl RedisClusterAdapter {
    pub async fn with_nodes(nodes: Vec<String>) -> Result<Self> {
        let config = RedisClusterAdapterConfig {
            nodes,
            ..Default::default()
        };
        HorizontalAdapterBase::new(config).await
    }
}