Trait fluvio::dataplane::api::ApiMessage

pub trait ApiMessage: Default {
    type ApiKey: Debug + Decoder;
    fn decode_with_header<T>(
        src: &mut T, 
        header: RequestHeader
    ) -> Result<Self, Error>
    where
        Self: Default,
        T: Buf,
        Self::ApiKey: Sized;

    fn decode_from<T>(src: &mut T) -> Result<Self, Error>
    where
        T: Buf,
    { ... }
    fn decode_from_file<P>(file_name: P) -> Result<Self, Error>
    where
        P: AsRef<Path>,
    { ... }
}

Associated Types

type ApiKey: Debug + Decoder

Loading content...

Required methods

fn decode_with_header<T>(
    src: &mut T,
    header: RequestHeader
) -> Result<Self, Error> where
    Self: Default,
    T: Buf,
    Self::ApiKey: Sized, 

Loading content...

Provided methods

fn decode_from<T>(src: &mut T) -> Result<Self, Error> where
    T: Buf, 

fn decode_from_file<P>(file_name: P) -> Result<Self, Error> where
    P: AsRef<Path>, 

Loading content...

Implementations on Foreign Types

impl ApiMessage for AdminPublicRequest

type ApiKey = AdminPublicApiKey

fn decode_with_header<T>(
    src: &mut T,
    header: RequestHeader
) -> Result<AdminPublicRequest, Error> where
    T: Buf,
    AdminPublicRequest: Default,
    AdminPublicRequest: Sized,
    <AdminPublicRequest as ApiMessage>::ApiKey: Sized, 

impl ApiMessage for SpuServerRequest

type ApiKey = SpuServerApiKey

fn decode_with_header<T>(
    src: &mut T,
    header: RequestHeader
) -> Result<SpuServerRequest, Error> where
    T: Buf,
    SpuServerRequest: Default,
    SpuServerRequest: Sized,
    <SpuServerRequest as ApiMessage>::ApiKey: Sized, 

impl ApiMessage for SpuClientRequest

type ApiKey = SpuClientApiKey

fn decode_with_header<T>(
    src: &mut T,
    header: RequestHeader
) -> Result<SpuClientRequest, Error> where
    T: Buf,
    SpuClientRequest: Default,
    SpuClientRequest: Sized,
    <SpuClientRequest as ApiMessage>::ApiKey: Sized, 

Loading content...

Implementors

Loading content...