Trait fluvio::dataplane::api::ApiMessage

pub trait ApiMessage: Sized + Default {
    type ApiKey: Decoder + Debug;

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

    // 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> { ... }
}

Required Associated Types

type ApiKey: Decoder + Debug

Required Methods

fn decode_with_header<T>( src: &mut T, header: RequestHeader ) -> Result<Self, Error>

where Self: Sized + Default, Self::ApiKey: Sized, T: Buf,

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>,

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl ApiMessage for AdminPublicDecodedRequest

type ApiKey = AdminPublicApiKey

fn decode_with_header<T>( _src: &mut T, _header: RequestHeader ) -> Result<AdminPublicDecodedRequest, Error>

where AdminPublicDecodedRequest: Sized + Default, <AdminPublicDecodedRequest as ApiMessage>::ApiKey: Sized, T: Buf,

fn decode_from<T>(src: &mut T) -> Result<AdminPublicDecodedRequest, Error>

where T: Buf,

impl ApiMessage for SpuClientRequest

type ApiKey = SpuClientApiKey

fn decode_with_header<T>( src: &mut T, header: RequestHeader ) -> Result<SpuClientRequest, Error>

where SpuClientRequest: Sized + Default, <SpuClientRequest as ApiMessage>::ApiKey: Sized, T: Buf,

impl ApiMessage for SpuServerRequest

type ApiKey = SpuServerApiKey

fn decode_with_header<T>( src: &mut T, header: RequestHeader ) -> Result<SpuServerRequest, Error>

where SpuServerRequest: Sized + Default, <SpuServerRequest as ApiMessage>::ApiKey: Sized, T: Buf,

Implementors