Struct LifecycleBroadcastModel 

pub struct LifecycleBroadcastModel { /* private fields */ }

In-repo lifecycle broadcast model for broker-managed backends.

Implementations

impl LifecycleBroadcastModel

pub fn new() -> Self

Create an empty model with the default timeout policy.

pub fn with_policy(policy: BroadcastPolicy) -> Self

Create an empty model with an explicit timeout policy.

pub fn register_backend( &mut self, backend: BroadcastBackend, ) -> Option<BroadcastBackend>

Register or replace one backend endpoint.

pub fn backend(&self, key: &BackendKey) -> Option<&BroadcastBackend>

Return a registered backend by key.

pub fn backends(&self) -> &[BroadcastBackend]

Return all registered backend endpoints in insertion order.

pub fn release_handles_under_path( &mut self, path_prefix: impl Into<PathBuf>, ) -> BroadcastResult

Broadcast a release-handles operation to all live backends.

pub fn quiesce(&mut self, reason: QuiesceReason) -> BroadcastResult

Broadcast a quiesce operation to all live backends.

pub fn broadcast(&mut self, operation: BroadcastOperation) -> BroadcastResult

Broadcast one lifecycle operation to all live backends.

Trait Implementations

impl Debug for LifecycleBroadcastModel

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

Formats the value using the given formatter.

impl Default for LifecycleBroadcastModel

fn default() -> Self

Returns the “default value” for a type.