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
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 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))) }}; }