Trait twilight_gateway_queue::Queue

pub trait Queue: Debug + Send + Sync {
    fn request<'a>(
        &'a self,
        shard_id: [u64; 2]
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'a>>;
}

Queue for shards to request the ability to initialize new sessions with the gateway.

This will usually only need to be implemented when you have a multi-process cluster setup. Refer to the module-level documentation for more information.

Required Methods

fn request<'a>(
    &'a self,
    shard_id: [u64; 2]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'a>>

A shard has requested the ability to request a session initialization with the gateway.

The returned future must resolve only when the shard can initiate the session.

Implementors

impl Queue for LargeBotQueue

impl Queue for LocalQueue

impl Queue for NoOpQueue