Enum Request 

pub enum Request {
    RegisterBroker(BrokerRegistrationRequest),
    IncrementalAlterResource(AlterConfigsResource),
    CreateTopic {
        topic: CreatableTopic,
        validate_only: bool,
    },
    DeleteRecords(Vec<DeleteRecordsTopic>),
    DeleteTopic(TopicId),
    Brokers,
    Produce {
        transaction_id: Option<String>,
        topition: Topition,
        batch: Batch,
    },
    Fetch {
        topition: Topition,
        offset: i64,
        min_bytes: u32,
        max_bytes: u32,
        isolation: IsolationLevel,
    },
    OffsetStage(Topition),
    ListOffsets {
        isolation_level: IsolationLevel,
        offsets: Vec<(Topition, ListOffset)>,
    },
    OffsetCommit {
        group_id: String,
        retention_time_ms: Option<Duration>,
        offsets: Vec<(Topition, OffsetCommitRequest)>,
    },
    CommittedOffsetTopitions(String),
    OffsetFetch {
        group_id: Option<String>,
        topics: Vec<Topition>,
        require_stable: Option<bool>,
    },
    Metadata(Option<Vec<TopicId>>),
    DescribeConfig {
        name: String,
        resource: ConfigResource,
        keys: Option<Vec<String>>,
    },
    DescribeTopicPartitions {
        topics: Option<Vec<TopicId>>,
        partition_limit: i32,
        cursor: Option<Topition>,
    },
    ListGroups(Option<Vec<String>>),
    DeleteGroups(Option<Vec<String>>),
    DescribeGroups {
        group_ids: Option<Vec<String>>,
        include_authorized_operations: bool,
    },
    UpdateGroup {
        group_id: String,
        detail: GroupDetail,
        version: Option<Version>,
    },
    InitProducer {
        transaction_id: Option<String>,
        transaction_timeout_ms: i32,
        producer_id: Option<i64>,
        producer_epoch: Option<i16>,
    },
    TxnAddOffsets {
        transaction_id: String,
        producer_id: i64,
        producer_epoch: i16,
        group_id: String,
    },
    TxnAddPartitions(TxnAddPartitionsRequest),
    TxnOffsetCommit(TxnOffsetCommitRequest),
    TxnEnd {
        transaction_id: String,
        producer_id: i64,
        producer_epoch: i16,
        committed: bool,
    },
    Maintain(SystemTime),
    ClusterId,
    Node,
    AdvertisedListener,
    DeleteUserScramCredential {
        user: String,
        mechanism: ScramMechanism,
    },
    UpsertUserScramCredential {
        user: String,
        mechanism: ScramMechanism,
        credential: ScramCredential,
    },
    UserScramCredential {
        user: String,
        mechanism: ScramMechanism,
    },
    Ping,
}

Variants

RegisterBroker(BrokerRegistrationRequest)

IncrementalAlterResource(AlterConfigsResource)

CreateTopic

Fields

topic: CreatableTopic

validate_only: bool

DeleteRecords(Vec<DeleteRecordsTopic>)

DeleteTopic(TopicId)

Brokers

Produce

Fields

transaction_id: Option<String>

topition: Topition

batch: Batch

Fetch

Fields

topition: Topition

offset: i64

min_bytes: u32

max_bytes: u32

isolation: IsolationLevel

OffsetStage(Topition)

ListOffsets

Fields

isolation_level: IsolationLevel

offsets: Vec<(Topition, ListOffset)>

OffsetCommit

Fields

group_id: String

retention_time_ms: Option<Duration>

offsets: Vec<(Topition, OffsetCommitRequest)>

CommittedOffsetTopitions(String)

OffsetFetch

Fields

group_id: Option<String>

topics: Vec<Topition>

require_stable: Option<bool>

Metadata(Option<Vec<TopicId>>)

DescribeConfig

Fields

name: String

resource: ConfigResource

keys: Option<Vec<String>>

DescribeTopicPartitions

Fields

topics: Option<Vec<TopicId>>

partition_limit: i32

cursor: Option<Topition>

ListGroups(Option<Vec<String>>)

DeleteGroups(Option<Vec<String>>)

DescribeGroups

Fields

group_ids: Option<Vec<String>>

include_authorized_operations: bool

UpdateGroup

Fields

group_id: String

detail: GroupDetail

version: Option<Version>

InitProducer

Fields

transaction_id: Option<String>

transaction_timeout_ms: i32

producer_id: Option<i64>

producer_epoch: Option<i16>

TxnAddOffsets

Fields

transaction_id: String

producer_id: i64

producer_epoch: i16

group_id: String

TxnAddPartitions(TxnAddPartitionsRequest)

TxnOffsetCommit(TxnOffsetCommitRequest)

TxnEnd

Fields

transaction_id: String

producer_id: i64

producer_epoch: i16

committed: bool

Maintain(SystemTime)

ClusterId

Node

AdvertisedListener

DeleteUserScramCredential

Fields

user: String

mechanism: ScramMechanism

UpsertUserScramCredential

Fields

user: String

mechanism: ScramMechanism

credential: ScramCredential

UserScramCredential

Fields

user: String

mechanism: ScramMechanism

Ping

Trait Implementations

impl Clone for Request

fn clone(&self) -> Request

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Request

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for Request

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Hash for Request

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for Request

fn cmp(&self, other: &Request) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for Request

fn eq(&self, other: &Request) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for Request

fn partial_cmp(&self, other: &Request) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl<State> Service<State, Request> for RequestChannelService

where State: Send + Sync + 'static,

type Response = Response

The type of response returned by the service.

type Error = ServiceError

The type of error returned by the service.

async fn serve( &self, ctx: Context<State>, req: Request, ) -> Result<Self::Response, Self::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.

impl<State, S> Service<State, Request> for RequestService<S>

where S: Service<State, Request>, State: Send + Sync + 'static,

type Response = <S as Service<State, Request>>::Response

The type of response returned by the service.

type Error = <S as Service<State, Request>>::Error

The type of error returned by the service.

async fn serve( &self, ctx: Context<State>, req: Request, ) -> Result<Self::Response, Self::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.

impl<G, State> Service<State, Request> for RequestStorageService<G>

where G: Storage, State: Clone + Send + Sync + 'static,

type Response = Response

The type of response returned by the service.

type Error = Error

The type of error returned by the service.

async fn serve( &self, _ctx: Context<State>, req: Request, ) -> Result<Self::Response, Self::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.

impl Eq for Request

impl StructuralPartialEq for Request