Struct ZkQueue 

pub struct ZkQueue { /* private fields */ }

Implementations

impl ZkQueue

pub fn new(zk: Arc<ZooKeeper>, dir: String) -> ZkResult<Self>

pub fn offer(&self, data: Vec<u8>) -> ZkResult<String>

Inserts data into the queue

pub fn take(&self) -> ZkResult<Vec<u8>>

Removes the head of the queue and returns it, blocking until it succeeds or throws an error

pub fn peek(&self) -> ZkResult<Option<Vec<u8>>>

Returns the data at the first element of the queue, or Ok(None) if the queue is empty.

pub fn poll(&self) -> ZkResult<Option<Vec<u8>>>

Attempts to remove the head of the queue and return it. Returns Ok(None) if the queue is empty.