Struct Cache

pub struct Cache { /* private fields */ }

Cache will watch root node and it’s children nodes recursively

 use futures::StreamExt;
 use zookeeper_cache::CacheBuilder;
 async fn dox() -> zookeeper_cache::Result<()>{
    let (cache,mut stream) = CacheBuilder::default().build("localhost:2181").await?;
        tokio::spawn(async move{
            while let Some(_event) = stream.next().await{
                // handle event
            }
        });
    cache.get("/test").await;
    Ok(())
 }

Implementations

impl Cache

pub async fn new( addr: impl Into<String>, builder: CacheBuilder, ) -> Result<(Self, impl Stream<Item = Event>)>

pub async fn get(&self, path: &str) -> Option<SharedChildData>

Get data and stat through path

 use zookeeper_cache::CacheBuilder;
 async fn dox()->zookeeper_cache::Result<()>{
    let (cache, _stream) = CacheBuilder::default().build("localhost:2181").await?;
    cache.get("/test").await;
    Ok(())
 }

Trait Implementations

impl Drop for Cache

fn drop(&mut self)

Executes the destructor for this type.