Trait fluvio::dataplane::core::api::Request

pub trait Request: Encoder + Decoder + Debug {
    type Response: Encoder + Decoder + Debug;

    pub const API_KEY: u16;
    pub const DEFAULT_API_VERSION: i16;
    pub const MIN_API_VERSION: i16;
    pub const MAX_API_VERSION: i16;
}

Associated Types

type Response: Encoder + Decoder + Debug

Loading content...

Associated Constants

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

pub const MIN_API_VERSION: i16

pub const MAX_API_VERSION: i16

Loading content...

Implementations on Foreign Types

impl<R> Request for StreamFetchRequest<R> where
    R: Debug + Decoder + Encoder, 

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

type Response = StreamFetchResponse<R>

impl Request for UpdateOffsetsRequest

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

type Response = UpdateOffsetsResponse

impl Request for ReplicaOffsetUpdateRequest

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

type Response = ReplicaOffsetUpdateResponse

impl Request for FetchOffsetsRequest

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

type Response = FetchOffsetsResponse

Loading content...

Implementors

impl Request for DeleteRequest

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

type Response = Status

impl Request for ListRequest

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

type Response = ListResponse

impl Request for WatchRequest

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

type Response = WatchResponse

impl Request for ApiVersionsRequest

pub const API_KEY: u16

type Response = ApiVersionsResponse

impl Request for CreateRequest

pub const API_KEY: u16

pub const DEFAULT_API_VERSION: i16

type Response = Status

impl<R> Request for FetchRequest<R> where
    R: Debug + Decoder + Encoder, 

pub const API_KEY: u16

pub const MIN_API_VERSION: i16

pub const MAX_API_VERSION: i16

pub const DEFAULT_API_VERSION: i16

type Response = FetchResponse<R>

impl<R> Request for ProduceRequest<R> where
    R: Debug + Decoder + Encoder, 

pub const API_KEY: u16

pub const MIN_API_VERSION: i16

pub const MAX_API_VERSION: i16

pub const DEFAULT_API_VERSION: i16

type Response = ProduceResponse

Loading content...