Trait fluvio::dataplane::api::Request

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

    const API_KEY: u16;
    const DEFAULT_API_VERSION: i16 = 0i16;
    const MIN_API_VERSION: i16 = _;
    const MAX_API_VERSION: i16 = Self::DEFAULT_API_VERSION;
}

Required Associated Types

type Response: Encoder + Decoder + Debug

Required Associated Constants

const API_KEY: u16

Provided Associated Constants

const DEFAULT_API_VERSION: i16 = 0i16

const MIN_API_VERSION: i16 = _

const MAX_API_VERSION: i16 = Self::DEFAULT_API_VERSION

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl Request for MirroringRemoteClusterRequest<MirrorConnect>

const API_KEY: u16 = 3_000u16

type Response = MirroringStatusResponse

impl Request for ObjectMirroringRequest

const API_KEY: u16 = 1_005u16

const MIN_API_VERSION: i16 = 14i16

const DEFAULT_API_VERSION: i16 = 14i16

type Response = MirroringStatusResponse

impl Request for ReplicaOffsetUpdateRequest

const API_KEY: u16 = 1_001u16

const DEFAULT_API_VERSION: i16 = 23i16

type Response = ReplicaOffsetUpdateResponse

impl Request for DeleteConsumerOffsetRequest

const API_KEY: u16 = 1_007u16

const DEFAULT_API_VERSION: i16 = 23i16

type Response = DeleteConsumerOffsetResponse

impl Request for FetchConsumerOffsetsRequest

const API_KEY: u16 = 1_008u16

const DEFAULT_API_VERSION: i16 = 23i16

type Response = FetchConsumerOffsetsResponse

impl Request for UpdateConsumerOffsetRequest

const API_KEY: u16 = 1_006u16

const DEFAULT_API_VERSION: i16 = 23i16

type Response = UpdateConsumerOffsetResponse

impl Request for FetchOffsetsRequest

const API_KEY: u16 = 1_002u16

const DEFAULT_API_VERSION: i16 = 23i16

type Response = FetchOffsetsResponse

impl Request for UpdateOffsetsRequest

const API_KEY: u16 = 1_005u16

const DEFAULT_API_VERSION: i16 = 0i16

type Response = UpdateOffsetsResponse

impl<R> Request for FetchRequest<R>

where R: Debug + Decoder + Encoder,

const API_KEY: u16 = 1u16

const MIN_API_VERSION: i16 = 0i16

const DEFAULT_API_VERSION: i16 = 23i16

type Response = FetchResponse<R>

impl<R> Request for ProduceRequest<R>

where R: Debug + Decoder + Encoder,

const API_KEY: u16 = 0u16

const MIN_API_VERSION: i16 = 0i16

const DEFAULT_API_VERSION: i16 = 23i16

type Response = ProduceResponse

impl<R> Request for StreamFetchRequest<R>

where R: Debug + Decoder + Encoder,

const API_KEY: u16 = 1_003u16

const DEFAULT_API_VERSION: i16 = 23i16

type Response = StreamFetchResponse<R>

Implementors

impl Request for ObjectApiCreateRequest

const API_KEY: u16 = 1_001u16

const MIN_API_VERSION: i16 = 9i16

const DEFAULT_API_VERSION: i16 = 14i16

type Response = Status

impl Request for ObjectApiDeleteRequest

const API_KEY: u16 = 1_002u16

const MIN_API_VERSION: i16 = 1i16

const DEFAULT_API_VERSION: i16 = 14i16

type Response = Status

impl Request for ObjectApiListRequest

const API_KEY: u16 = 1_003u16

const DEFAULT_API_VERSION: i16 = 14i16

type Response = ObjectApiListResponse

impl Request for ObjectApiWatchRequest

const API_KEY: u16 = 1_004u16

const DEFAULT_API_VERSION: i16 = 14i16

type Response = ObjectApiWatchResponse

impl Request for ApiVersionsRequest

const API_KEY: u16 = 18u16

const DEFAULT_API_VERSION: i16 = 2i16

type Response = ApiVersionsResponse