Struct TopologyRequest 

pub struct TopologyRequest(/* private fields */);

Request to obtain the current cluster topology.

This request is used to retrieve detailed information about the Zeebe cluster’s topology, including broker nodes, partition distribution, cluster size, replication factor, and gateway version.

Example

let topology = client.topology().send().await;

Errors

Returns a ClientError if the request fails.

Implementations

impl TopologyRequest

pub async fn send(self) -> Result<TopologyResponse, ClientError>

Sends a request to get the current cluster topology

Returns

A Result containing either:

• TopologyResponse with information about:
  • Broker nodes in the cluster
  • Partition distribution
  • Cluster size and replication factor
  • Gateway version
• ClientError if the request fails

Examples found in repository

examples/hello_client.rs (line 8)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = zeebe_rs::Client::builder()
        .with_address("http://localhost", 26500)
        .build()
        .await?;

    let topology = client.topology().send().await;
    println!("{:?}", topology);

    Ok(())
}

examples/oauth.rs (line 28)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    unsafe { std::env::set_var("RUST_BACKTRACE", "1") };
    let client = zeebe_rs::Client::builder()
        .with_address("http://localhost", 26500)
        .with_oauth(
            String::from("zeebe"),
            String::from("zecret"),
            String::from(
                "http://localhost:18080/auth/realms/camunda-platform/protocol/openid-connect/token",
            ),
            String::from("zeebe-api"),
            Duration::from_secs(30),
            None,
        )
        .build()
        .await?;

    let _ = client.auth_initialized().await;
    let topology = client.topology().send().await;
    println!("{:?}", topology);

    Ok(())
}

Trait Implementations

impl Clone for TopologyRequest

fn clone(&self) -> TopologyRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopologyRequest

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

Formats the value using the given formatter.