Trait Driver 

pub trait Driver {
    type Error: Error + Send + Sync + 'static;

    // Required methods
    fn node_id(&self) -> String;
    fn get_nodes<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

    // Provided method
    fn start<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: Send + 'async_trait,
             'life0: 'async_trait { ... }
}

The driver trait, which defines the node list management interface.

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn node_id(&self) -> String

Get the local node id.

fn get_nodes<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the node list in the cluster

Provided Methods

fn start<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

Start the driver, blocking the current thread.

Implementors

impl Driver for EtcdDriver

type Error = Error

impl Driver for LocalDriver

type Error = Infallible

impl<C> Driver for RedisDriver<C>

where C: ConnectionLike + Send + Sync + Clone + 'static,

type Error = Error

impl<C> Driver for RedisZSetDriver<C>

where C: ConnectionLike + Send + Sync + Clone + 'static,

type Error = Error