Struct ListTransactionsResult 

pub struct ListTransactionsResult { /* private fields */ }

The result of Admin::list_transactions.

Implementations

impl ListTransactionsResult

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

Get all transaction listings. If any of the underlying requests fail, the returned future also fails with the first encountered error.

Returns

A future containing the collection of transaction listings. The future completes when all transaction listings are available and fails after any non-retriable error.

pub fn by_broker_id( &self, ) -> KafkaFuture<HashMap<i32, KafkaFuture<Vec<TransactionListing>>>>

Get a future returning the per-broker listing futures. Useful for a partial listing or more granular error details.

Returns

A future containing a map of futures by broker which complete individually when their respective transaction listings are available. The top-level future returned from this method may fail if the admin client is unable to lookup the available brokers in the cluster.

pub fn all_by_broker_id( &self, ) -> KafkaFuture<HashMap<i32, Vec<TransactionListing>>>

Get all transaction listings keyed by the broker id currently managing them. If any underlying request fails, the returned future also fails.

Returns

A future containing a map from the broker ID to the transactions hosted by that broker respectively. This future completes when all transaction listings are available and fails after any non-retriable error.

Trait Implementations

impl Clone for ListTransactionsResult

fn clone(&self) -> ListTransactionsResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ListTransactionsResult

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

Formats the value using the given formatter.