sockudo 2.9.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

use crate::adapter::horizontal_adapter_base::HorizontalAdapterBase;
use crate::adapter::transports::{RedisAdapterConfig, RedisTransport};
use crate::error::Result;

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

// Re-export config for backward compatibility
pub use crate::adapter::transports::RedisAdapterConfig as RedisAdapterOptions;

impl RedisAdapter {
    pub async fn with_url(redis_url: &str) -> Result<Self> {
        let config = RedisAdapterConfig {
            url: redis_url.to_string(),
            ..Default::default()
        };
        HorizontalAdapterBase::new(config).await
    }
}