Struct ListOffsetsResult 

pub struct ListOffsetsResult { /* private fields */ }

The result of Admin::list_offsets.

Implementations

impl ListOffsetsResult

pub fn new( futures: HashMap<TopicPartition, KafkaFuture<ListOffsetsResultInfo>>, ) -> Self

Creates a result from the per-partition futures.

Arguments

• futures - the future of each partition’s offset.

pub fn partition_result( &self, partition: &TopicPartition, ) -> Result<KafkaFuture<ListOffsetsResultInfo>, Error>

Returns a future which can be used to check the result for a given partition.

Arguments

• partition - the partition to check.

Errors

Returns an error answering Error::is_local_illegal_argument_error if the offset for partition was not attempted.

pub fn all(&self) -> KafkaFuture<HashMap<TopicPartition, ListOffsetsResultInfo>>

Returns a future which succeeds only if offsets for all specified partitions have been successfully retrieved.

Trait Implementations

impl Clone for ListOffsetsResult

fn clone(&self) -> ListOffsetsResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ListOffsetsResult

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

Formats the value using the given formatter.