fluvio_protocol_api/
lib.rs

1mod api;
2mod request;
3mod response;
4
5pub mod core {
6    pub use fluvio_protocol::*;
7}
8
9pub mod derive {
10    pub use fluvio_protocol_derive::*;
11}
12
13pub use self::api::*;
14pub use self::response::*;
15pub use self::request::*;
16
17pub const MAX_BYTES: i32 = 52428800;
18
19#[macro_export]
20macro_rules! api_decode {
21    ($api:ident,$req:ident,$src:expr,$header:expr) => {{
22        use fluvio_protocol::Decoder;
23        let request = $req::decode_from($src, $header.api_version())?;
24        Ok($api::$req(RequestMessage::new($header, request)))
25    }};
26}