Struct DecommissionObserver 

pub struct DecommissionObserver { /* private fields */ }

Periodically checks the local node’s topology state and fires a shutdown signal on Decommissioned or removal.

Implementations

impl DecommissionObserver

pub fn new( topology: Arc<RwLock<ClusterTopology>>, local_node_id: u64, poll_interval: Duration, ) -> (Self, Receiver<bool>)

Build an observer and return it alongside the receiver half of its shutdown watch channel. Every subsystem that wants to cooperatively drain on decommission can call watch::Receiver::clone on the returned receiver.

pub fn check_once(&self) -> bool

Single check. Returns true iff the observer fired the shutdown signal during this call (or had already fired it previously — the watch is level-triggered, not edge).

pub async fn run(self, cancel: Receiver<bool>)

Run the observer’s poll loop until cancel flips to true. Exits immediately after firing its own shutdown signal — there is nothing more to watch.