fluvio-protocol-api 0.3.0

fluvio protocol API helpers
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

mod api;
mod request;
mod response;

pub mod core {
    pub use fluvio_protocol::*;
}

pub mod derive {
    pub use fluvio_protocol_derive::*;
}

pub use self::api::*;
pub use self::response::*;
pub use self::request::*;

//pub use self::group_protocol_metadata::ProtocolMetadata;
//pub use self::group_protocol_metadata::Metadata;
//pub use self::group_assigment::GroupAssignment;
//pub use self::group_assigment::Assignment;
// pub use self::common::*;

pub const MAX_BYTES: i32 = 52428800;

#[macro_export]
macro_rules! api_decode {
    ($api:ident,$req:ident,$src:expr,$header:expr) => {{
        use fluvio_protocol::Decoder;
        let request = $req::decode_from($src, $header.api_version())?;
        Ok($api::$req(RequestMessage::new($header, request)))
    }};
}