Struct CustomMongoDbAdapter

pub struct CustomMongoDbAdapter<E, D> { /* private fields */ }

The mongodb adapter implementation. It is generic over the Driver used to communicate with the mongodb server. And over the SocketEmitter used to communicate with the local server. This allows to avoid cyclic dependencies between the adapter, socketioxide-core and socketioxide crates.

Trait Implementations

impl<E: SocketEmitter, D: Driver> CoreAdapter<E> for CustomMongoDbAdapter<E, D>

async fn server_count(&self) -> Result<u16, Self::Error>

Get the number of servers by iterating over the node liveness heartbeats.

async fn broadcast( &self, packet: Packet, opts: BroadcastOptions, ) -> Result<(), BroadcastError>

Broadcast a packet to all the servers to send them through their sockets.

async fn broadcast_with_ack( &self, packet: Packet, opts: BroadcastOptions, timeout: Option<Duration>, ) -> Result<Self::AckStream, Self::Error>

Broadcast a packet to all the servers to send them through their sockets.

Returns a Stream that is a combination of the local ack stream and a remote ack stream. Here is a specific protocol in order to know how many message the server expect to close the stream at the right time:

• Get the number n of remote servers.
• Send the broadcast request.
• Expect n BroadcastAckCount response in the stream to know the number m of expected ack responses.
• Expect sum(m) broadcast counts sent by the servers.

Example with 3 remote servers (n = 3):

+---+                   +---+                   +---+
| A |                   | B |                   | C |
+---+                   +---+                   +---+
  |                       |                       |
  |---BroadcastWithAck--->|                       |
  |---BroadcastWithAck--------------------------->|
  |                       |                       |
  |<-BroadcastAckCount(2)-|     (n = 2; m = 2)    |
  |<-BroadcastAckCount(2)-------(n = 2; m = 4)----|
  |                       |                       |
  |<----------------Ack---------------------------|
  |<----------------Ack---|                       |
  |                       |                       |
  |<----------------Ack---------------------------|
  |<----------------Ack---|                       |

type Error = Error<D>

An error that can occur when using the adapter.

type State = MongoDbAdapterCtr<D>

A shared state between all the namespace CoreAdapter. This can be used to share a connection for example.

type AckStream = AckStream<<E as SocketEmitter>::AckStream>

A stream that emits the acknowledgments of multiple sockets.

type InitRes = InitRes<D>

A named result type for the initialization of the adapter.

fn new(state: &Self::State, local: CoreLocalAdapter<E>) -> Self

Creates a new adapter with the given state and local adapter.

fn init( self: Arc<Self>, on_success: impl FnOnce() + Send + 'static, ) -> Self::InitRes

Initializes the adapter. The on_success callback should be called when the adapter ready.

async fn close(&self) -> Result<(), Self::Error>

Closes the adapter.

async fn disconnect_socket( &self, opts: BroadcastOptions, ) -> Result<(), BroadcastError>

Disconnects the sockets that match the BroadcastOptions.

async fn rooms(&self, opts: BroadcastOptions) -> Result<Vec<Room>, Self::Error>

Fetches rooms that match the BroadcastOptions

async fn add_sockets( &self, opts: BroadcastOptions, rooms: impl RoomParam, ) -> Result<(), Self::Error>

Adds the sockets that match the BroadcastOptions to the rooms.

async fn del_sockets( &self, opts: BroadcastOptions, rooms: impl RoomParam, ) -> Result<(), Self::Error>

Removes the sockets that match the BroadcastOptions from the rooms.

async fn fetch_sockets( &self, opts: BroadcastOptions, ) -> Result<Vec<RemoteSocketData>, Self::Error>

Fetches remote sockets that match the BroadcastOptions.

fn get_local(&self) -> &CoreLocalAdapter<E>

Returns the local adapter. Used to enable default behaviors.

impl<E, D> DefinedAdapter for CustomMongoDbAdapter<E, D>