Struct ClusterState

pub struct ClusterState { /* private fields */ }

Implementations

impl ClusterState

pub fn get_keyspace(&self, keyspace: impl AsRef<str>) -> Option<&Keyspace>

Access keyspace details collected by the driver.

pub fn keyspaces_iter(&self) -> impl Iterator<Item = (&str, &Keyspace)>

Returns an iterator over keyspaces.

pub fn get_nodes_info(&self) -> &[Arc<Node>]

Access details about nodes known to the driver

pub fn compute_token( &self, keyspace: &str, table: &str, partition_key: &dyn SerializeRow, ) -> Result<Token, ClusterStateTokenError>

Compute token of a table partition key

partition_key argument contains the values of all partition key columns. You can use both unnamed values like a tuple (e.g. (1, 5, 5)) or named values (e.g. struct that derives SerializeRow), as you would when executing a request. No additional values are allowed besides values for primary key columns.

pub fn get_token_endpoints( &self, keyspace: &str, table: &str, token: Token, ) -> Vec<(Arc<Node>, Shard)>

Access to replicas owning a given token

pub fn get_endpoints( &self, keyspace: &str, table: &str, partition_key: &dyn SerializeRow, ) -> Result<Vec<(Arc<Node>, Shard)>, ClusterStateTokenError>

Access to replicas owning a given partition key (similar to nodetool getendpoints)

partition_key argument contains the values of all partition key columns. You can use both unnamed values like a tuple (e.g. (1, 5, 5)) or named values (e.g. struct that derives SerializeRow), as you would when executing a request. No additional values are allowed besides values for primary key columns.

pub fn replica_locator(&self) -> &ReplicaLocator

Access replica location info

Trait Implementations

impl Clone for ClusterState

fn clone(&self) -> ClusterState

Returns a copy of the value.

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

Performs copy-assignment from source.