Struct DescribeClusterResult 

pub struct DescribeClusterResult { /* private fields */ }

The result of the Admin::describe_cluster call.

Implementations

impl DescribeClusterResult

pub fn nodes(&self) -> KafkaFuture<Vec<Node>>

Returns a future which yields a collection of nodes in the cluster.

pub fn controller(&self) -> KafkaFuture<Option<Node>>

Returns a future which yields the current controller node, or None if there is no current controller.

When using bootstrap.servers, the controller refer to a random broker.

pub fn cluster_id(&self) -> KafkaFuture<String>

Returns a future which yields the id of the cluster.

pub fn authorized_operations( &self, ) -> KafkaFuture<Option<BTreeSet<AclOperation>>>

Returns a future which yields the authorized operations of the cluster.

The value is None if the operations were not requested or the broker omitted them.

Trait Implementations

impl Debug for DescribeClusterResult

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

Formats the value using the given formatter.