Struct RedisZSetDriver 

pub struct RedisZSetDriver<C>
where
    C: ConnectionLike,
{ /* private fields */ }

Implementations

impl<C> RedisZSetDriver<C>

where C: ConnectionLike,

pub async fn new( con: C, service_name: &str, node_id: &str, ) -> Result<Self, Error>

pub fn with_timeout(self, timeout: u64) -> Self

Trait Implementations

impl<C> Clone for RedisZSetDriver<C>

where C: ConnectionLike + Clone,

fn clone(&self) -> RedisZSetDriver<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> Debug for RedisZSetDriver<C>

where C: ConnectionLike,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C> Driver for RedisZSetDriver<C>

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

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 list of nodes from the redis server, use ZRANGEBYSCORE to get the latest nodes

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

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

Start a routine to send the heartbeat to the redis server

type Error = Error

fn node_id(&self) -> String

Get the local node id.

impl<C> Drop for RedisZSetDriver<C>

where C: ConnectionLike,

fn drop(&mut self)

Executes the destructor for this type.