Struct FenceProducersResult 

pub struct FenceProducersResult { /* private fields */ }

The result of Admin::fence_producers.

Implementations

impl FenceProducersResult

pub fn fenced_producers(&self) -> HashMap<String, KafkaFuture<()>>

Returns a map from transactional id to futures which can be used to check the status of individual fencings.

pub fn producer_id( &self, transactional_id: &str, ) -> Result<KafkaFuture<i64>, Error>

Returns a future that provides the producer id generated while initializing the given transaction when the request completes.

Arguments

• transactional_id - the transactional id of the transaction.

Errors

Returns an error answering Error::is_local_illegal_argument_error if transactional_id was not included in the request.

pub fn epoch_id( &self, transactional_id: &str, ) -> Result<KafkaFuture<i16>, Error>

Returns a future that provides the epoch generated while initializing the given transaction when the request completes.

Arguments

• transactional_id - the transactional id of the transaction.

Errors

Returns an error answering Error::is_local_illegal_argument_error if transactional_id was not included in the request.

pub fn all(&self) -> KafkaFuture<()>

Returns a future which succeeds only if all the producer fencings succeed.

Trait Implementations

impl Clone for FenceProducersResult

fn clone(&self) -> FenceProducersResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FenceProducersResult

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

Formats the value using the given formatter.