sockudo-adapter 5.0.0

Connection adapters and horizontal scaling for Sockudo
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
40
41
42
43
44
45
46
47
48

pub mod channel_manager;
pub mod cleanup;
pub mod connection_manager;
pub mod factory;
#[cfg(feature = "tag-filtering")]
pub mod filter_index;
#[cfg(feature = "google-pubsub")]
pub mod google_pubsub_adapter;
pub mod handler;
pub mod horizontal_adapter;
pub mod horizontal_adapter_base;
pub mod horizontal_transport;
#[cfg(feature = "iggy")]
pub mod iggy_adapter;
#[cfg(feature = "kafka")]
pub mod kafka_adapter;
pub mod local_adapter;
pub mod memory_rate_limiter;
#[cfg(feature = "tag-filtering")]
pub(crate) mod message_predicate;
#[cfg(feature = "nats")]
pub mod nats_adapter;
pub mod presence;
#[cfg(feature = "pulsar")]
pub mod pulsar_adapter;
#[cfg(feature = "rabbitmq")]
pub mod rabbitmq_adapter;
#[cfg(feature = "redis")]
pub mod redis_adapter;
#[cfg(feature = "redis-cluster")]
pub mod redis_cluster_adapter;
#[cfg(feature = "recovery")]
pub mod replay_buffer;
pub mod services;
pub mod transports;
pub(crate) mod v2_broadcast;
pub mod watchlist;

/// Shared test infrastructure for `ConnectionManager` mocks.
/// Gated behind `cfg(any(test, doctest))` for unit tests and always available
/// to integration tests via the implicit dev-dependency on the crate.
#[doc(hidden)]
pub mod test_support;

pub use self::{
    connection_manager::ConnectionManager,
    handler::{ConnectionHandler, ConnectionHandlerBuilder, RealtimeEgressTap},
};