Struct EventManager 

pub struct EventManager { /* private fields */ }

Publisher side of the cluster events channel.

EventManager is cheap to clone (the inner broadcast::Sender is reference-counted). Hand a clone or an std::sync::Arc handle to every component that needs to publish.

Examples

use dynomite::events::EventManager;
let mgr = EventManager::new(8);
let _sub = mgr.subscribe();
assert_eq!(mgr.subscriber_count(), 1);

Implementations

impl EventManager

pub fn new(buffer: usize) -> Self

Build a fresh manager backed by a broadcast channel of the supplied capacity.

A capacity of zero is rejected by tokio; this constructor silently clamps it to one so embedding code does not have to special-case the empty value.

Examples

use dynomite::events::EventManager;
let mgr = EventManager::new(64);
assert_eq!(mgr.subscriber_count(), 0);

pub fn publish(&self, event: ClusterEvent)

Publish an event to every live subscriber.

Returns silently when there are no subscribers attached; tokio::sync::broadcast::Sender::send reports that case as Err(SendError(_)), which we explicitly drop because “no observers” is normal during quiet periods and is never the publisher’s problem.

Examples

use std::time::SystemTime;
use dynomite::events::{ClusterEvent, EventManager};
let mgr = EventManager::new(4);
// No subscribers attached; publish is still infallible.
mgr.publish(ClusterEvent::RingChanged {
    tag: "init".into(),
    ts: SystemTime::now(),
});

pub fn subscribe(&self) -> Subscriber

Subscribe a fresh receiver.

Each call returns an independent Subscriber whose queue starts empty; events published before the call are not delivered to the new subscriber.

Examples

use dynomite::events::EventManager;
let mgr = EventManager::new(4);
let _a = mgr.subscribe();
let _b = mgr.subscribe();
assert_eq!(mgr.subscriber_count(), 2);

pub fn subscriber_count(&self) -> usize

Number of attached subscribers.

Trait Implementations

impl Clone for EventManager

fn clone(&self) -> EventManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventManager

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

Formats the value using the given formatter.

impl Default for EventManager

fn default() -> Self

Build a manager with a 64-event buffer.

64 matches the default capacity of crate::embed::events::EventBus so embedders that swap one for the other do not see a surprise change in lag behaviour.