Struct ClusterDirectory 

pub struct ClusterDirectory { /* private fields */ }

Available on crate feature cluster only.

In-memory cluster directory (control plane): which nodes serve which streams. Shared (Arc) by every node’s relay in the process.

Implementations

impl ClusterDirectory

pub fn new() -> Self

A fresh, empty directory.

pub fn announce(&self, node: &NodeAddr, key: &StreamKey)

Record that node serves key.

pub fn withdraw(&self, node: &NodeAddr, key: &StreamKey)

Drop node from key’s server set.

pub fn locate(&self, key: &StreamKey, exclude: &NodeAddr) -> Option<NodeAddr>

A node serving key other than exclude (the local node), if any.

Trait Implementations

impl Debug for ClusterDirectory

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

Formats the value using the given formatter.

impl Default for ClusterDirectory

fn default() -> ClusterDirectory

Returns the “default value” for a type.