sockudo 3.0.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::NatsTransport;
use crate::error::Result;
pub(crate) use crate::options::NatsAdapterConfig;

/// NATS channels/subjects
pub const DEFAULT_PREFIX: &str = "sockudo";

/// NATS adapter for horizontal scaling - now a type alias for the base implementation
pub type NatsAdapter = HorizontalAdapterBase<NatsTransport>;

impl NatsAdapter {
    pub async fn with_servers(servers: Vec<String>) -> Result<Self> {
        let config = NatsAdapterConfig {
            servers,
            ..Default::default()
        };
        HorizontalAdapterBase::new(config).await
    }
}