Trait kf_protocol::api::Request

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

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

Associated Types

type Response: Debug + Decoder + Encoder

Loading content...

Associated Constants

const API_KEY: u16

const DEFAULT_API_VERSION: i16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

Loading content...

Implementors

impl Request for KfApiVersionsRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfApiVersionsResponse

impl Request for KfDeleteGroupsRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfDeleteGroupsResponse

impl Request for KfDescribeGroupsRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfDescribeGroupsResponse

impl Request for KfFindCoordinatorRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfFindCoordinatorResponse

impl Request for KfHeartbeatRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfHeartbeatResponse

impl Request for KfJoinGroupRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfJoinGroupResponse

impl Request for KfLeaveGroupRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfLeaveGroupResponse

impl Request for KfListGroupsRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfListGroupsResponse

impl Request for KfSyncGroupRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfSyncGroupResponse

impl Request for KfLeaderAndIsrRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfLeaderAndIsrResponse

impl Request for KfMetadataRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfMetadataResponse

impl Request for KfUpdateMetadataRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfUpdateMetadataResponse

impl Request for KfListOffsetRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfListOffsetResponse

impl Request for KfOffsetFetchRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfOffsetFetchResponse

impl Request for KfCreateTopicsRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfCreateTopicsResponse

impl Request for KfDeleteTopicsRequest

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfDeleteTopicsResponse

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

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfFetchResponse<R>

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

const API_KEY: u16

const MIN_API_VERSION: i16

const MAX_API_VERSION: i16

const DEFAULT_API_VERSION: i16

type Response = KfProduceResponse

Loading content...