Struct DescribeTransactionsResult 

pub struct DescribeTransactionsResult { /* private fields */ }

The result of Admin::describe_transactions.

Corresponds to org.apache.kafka.clients.admin.DescribeTransactionsResult. Java keys the per-transaction futures by CoordinatorKey; since CoordinatorKey is an internal (pub(crate)) type, the Rust result keys them by the transactional id string (the idValue), following the DescribeConsumerGroupsResult precedent.

Implementations

impl DescribeTransactionsResult

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

Get the description of a specific transactional id.

Mirrors DescribeTransactionsResult.description.

Errors

Returns Error::local_illegal_argument if transactional_id was not included in the request (mirroring Java’s IllegalArgumentException).

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

Get a future yielding a map of every requested transactional id’s description. Fails if any transactional id’s request fails.

Mirrors DescribeTransactionsResult.all.

Trait Implementations

impl Clone for DescribeTransactionsResult

fn clone(&self) -> DescribeTransactionsResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DescribeTransactionsResult

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

Formats the value using the given formatter.