Struct FredDriver

pub struct FredDriver { /* private fields */ }

Available on crate feature fred only.

A driver implementation for the fred pub/sub backend.

Implementations

impl FredDriver

pub async fn new(client: SubscriberClient) -> FredResult<Self>

Create a new redis driver from a redis client.

Trait Implementations

impl Clone for FredDriver

fn clone(&self) -> FredDriver

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Driver for FredDriver

type Error = FredError

The error type for the driver.

async fn publish(&self, chan: String, val: Vec<u8>) -> Result<(), Self::Error>

Publish a message to a channel.

async fn subscribe( &self, chan: String, size: usize, ) -> Result<MessageStream<ChanItem>, Self::Error>

Subscribe to a channel, it will return a stream of messages. The size parameter is the buffer size of the channel.

async fn unsubscribe(&self, chan: String) -> Result<(), Self::Error>

Unsubscribe from a channel.

async fn num_serv(&self, chan: &str) -> Result<u16, Self::Error>

Returns the number of socket.io servers.