Struct zkstate::ZkState

pub struct ZkState<T: Serialize + DeserializeOwned + Send + Sync> { /* fields omitted */ }

Implementations

impl<T: Serialize + DeserializeOwned + Send + Sync + 'static> ZkState<T>

pub fn new(
    zk: Arc<ZooKeeper>,
    zk_path: String,
    initial_state: T
) -> Result<Self>

pub fn update_handler<M: Fn(Change<Key, Value>) + Send + 'static>(
    &self,
    closure: M
) -> Result<(), ZkStructError>

Method to be invoked to handle state change notifications

pub fn update<M: FnOnce(&mut T)>(&self, closure: M) -> Result<(), ZkStructError>

Update the shared object using a closure.

The closure is passed a reference to the contents of the ZkState. Once the closure returns, the shared state in Zookeeper is committed and the write locks released.

pub fn read(&self) -> Result<RwLockReadGuard<'_, T>, ZkStructError>

Returns a Result<RwLockReadGuard>

pub fn c_read(&self)

Consistent Read.

Preforms a check to make sure the local version is the same as the remote version before returning. If there is a mismatch, will preform a sync and return the latest object

pub fn metadata(&self) -> (usize, i32)

Trait Implementations

impl<T: Clone + Serialize + DeserializeOwned + Send + Sync> Clone for ZkState<T>

fn clone(&self) -> ZkState<T>

Returns a copy of the value.

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

Performs copy-assignment from source.