zookeeper-client 0.6.1

ZooKeeper async client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use bytes::BufMut;

use crate::record::{ReadingBuf, SerializableRecord, StaticRecord, UnsafeBuf, UnsafeRead};

#[derive(Copy, Clone, Debug)]
pub struct ReplyHeader {
    pub xid: i32,
    pub zxid: i64,
    pub err: i32,
}

impl SerializableRecord for ReplyHeader {
    fn serialize(&self, buf: &mut dyn BufMut) {
        buf.put_i32(self.xid);
        buf.put_i64(self.zxid);
        buf.put_i32(self.err);
    }
}

impl StaticRecord for ReplyHeader {
    fn record_len() -> usize {
        16
    }
}

impl UnsafeRead<'_> for ReplyHeader {
    type Error = std::convert::Infallible;

    unsafe fn read(buf: &mut ReadingBuf) -> Result<Self, Self::Error> {
        let xid = buf.get_unchecked_i32();
        let zxid = buf.get_unchecked_i64();
        let err = buf.get_unchecked_i32();
        Ok(ReplyHeader { xid, zxid, err })
    }
}