Struct EventBusTopic 

pub struct EventBusTopic {
    pub pending: Vec<EventRecord>,
    pub dispatched: Vec<EventRecord>,
    pub subscribers: HashMap<String, Vec<SubscriberId>>,
    pub next_sub_id: SubscriberId,
    pub next_event_id: u64,
    pub last_event_ts: u64,
}

Publish-subscribe event bus with topic-based routing and priority support.

Fields

pending: Vec<EventRecord>

Pending (unprocessed) events, in insertion order.

dispatched: Vec<EventRecord>

All dispatched events, oldest first.

subscribers: HashMap<String, Vec<SubscriberId>>

Subscribers: topic → list of subscriber ids.

next_sub_id: SubscriberId

Next subscriber id to assign.

next_event_id: u64

Next event id to assign.

last_event_ts: u64

Timestamp of the most recently published event (0 if none).