Struct ManagedLockRevokeNotify

pub struct ManagedLockRevokeNotify { /* private fields */ }

Used to notify when a lock is revoked.

Examples

use etcd_client::Client;
use rust_etcd_utils::{lease::ManagedLeaseFactory, lock::spawn_lock_manager, ManagedLock};

let etcd = Client::connect(["http://localhost:2379"], None).await.expect("failed to connect to etcd");

let managed_lease_factory = ManagedLeaseFactory::new(etcd.clone());

let (lock_man_handle, lock_man) = spawn_lock_manager(etcd.clone(), managed_lease_factory.clone());

// Do something with the lock manager

let managed_lock: ManagedLock = lock_man.try_lock("test").await.expect("failed to lock");

let revoke_notify = managed_lock.get_revoke_notify();

// Can be cloned
let revoke_notify2 = revoke_notify.clone();

// Can create multiple instances..

let revoke_notify3 = managed_lock.get_revoke_notify();

etcd.delete("test", None).await.expect("failed to delete");

revoke_notify.wait_for_revoke().await;
revoke_notify2.wait_for_revoke().await;
revoke_notify3.wait_for_revoke().await;

println!("All revoke notify received");

Implementations

impl ManagedLockRevokeNotify

pub async fn wait_for_revoke(self)

Wait for the lock to be revoked.

Trait Implementations

impl Clone for ManagedLockRevokeNotify

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.