Struct kafka_protocol::messages::list_offsets_request::ListOffsetsRequestBuilder

source · [−]

pub struct ListOffsetsRequestBuilder { /* private fields */ }

Expand description

Builder for ListOffsetsRequest.

Implementations

impl ListOffsetsRequestBuilder

pub fn replica_id(&mut self, value: BrokerId) -> &mut Self

The broker ID of the requestor, or -1 if this request is being made by a normal consumer.

Supported API versions: 0-7

pub fn isolation_level(&mut self, value: i8) -> &mut Self

This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records

Supported API versions: 2-7

pub fn topics(&mut self, value: Vec<ListOffsetsTopic>) -> &mut Self

Each topic in the request.

Supported API versions: 0-7

pub fn unknown_tagged_fields(
&mut self,
value: BTreeMap<i32, Vec<u8>>
) -> &mut Self

Other tagged fields

pub fn build(
&self
) -> Result<ListOffsetsRequest, ListOffsetsRequestBuilderError>

Builds a new ListOffsetsRequest.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for ListOffsetsRequestBuilder

fn clone(&self) -> ListOffsetsRequestBuilder

Returns a copy of the value. Read more

1.0.0 · source

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

Performs copy-assignment from source. Read more

impl Default for ListOffsetsRequestBuilder

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations

impl RefUnwindSafe for ListOffsetsRequestBuilder

impl Send for ListOffsetsRequestBuilder

impl Sync for ListOffsetsRequestBuilder

impl Unpin for ListOffsetsRequestBuilder

impl UnwindSafe for ListOffsetsRequestBuilder

Blanket Implementations

impl<T> Any for T where
T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

impl<T, U> Into<U> for T where
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> ToOwned for T where
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

fn clone_into(&self, target: &mut T)

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

impl<T, U> TryFrom<U> for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.