Struct RedisLivenessStore 

pub struct RedisLivenessStore { /* private fields */ }

Redis implementation of the LivenessStore trait.

Implementations

impl RedisLivenessStore

pub fn new(client: RedisClient) -> Self

Create a new Redis liveness store with the given client.

Trait Implementations

impl Clone for RedisLivenessStore

fn clone(&self) -> RedisLivenessStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl LivenessStore for RedisLivenessStore

fn update_heartbeat<'life0, 'async_trait>( &'life0 self, worker_id: usize, timestamp: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), LivenessStoreError>> + Send + 'async_trait>>

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

Update the heartbeat timestamp for a worker.

fn get_heartbeat<'life0, 'async_trait>( &'life0 self, worker_id: usize, ) -> Pin<Box<dyn Future<Output = Result<Option<DateTime<Utc>>, LivenessStoreError>> + Send + 'async_trait>>

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

Get the last heartbeat timestamp for a worker.

fn list_workers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<usize>, LivenessStoreError>> + Send + 'async_trait>>

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

List all known worker IDs.

fn update_health<'life0, 'async_trait>( &'life0 self, worker_id: usize, health: WorkerHealth, ) -> Pin<Box<dyn Future<Output = Result<(), LivenessStoreError>> + Send + 'async_trait>>

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

Update the health status for a worker.

fn get_health<'life0, 'async_trait>( &'life0 self, worker_id: usize, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkerHealth>, LivenessStoreError>> + Send + 'async_trait>>

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

Get the health status for a worker.

fn list_health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkerHealth>, LivenessStoreError>> + Send + 'async_trait>>

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

List health status for all workers.