Struct EventBus 

pub struct EventBus { /* private fields */ }

Event bus for managing skill lifecycle events

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus

pub fn subscribe(&self) -> Receiver<SkillEvent>

Subscribe to events

pub async fn register_handler<H: EventHandler + 'static>( &self, event_type: &str, handler: H, ) -> Result<(), ServiceError>

Register an event handler for a specific event type

pub async fn unregister_handler( &self, event_type: &str, _handler_id: &str, ) -> Result<(), ServiceError>

Unregister an event handler

pub async fn publish_event( &self, event: SkillEvent, ) -> Result<usize, ServiceError>

Publish an event

pub async fn get_event_history(&self) -> Vec<(SkillEvent, Instant)>

Get event history

pub async fn clear_event_history(&self)

Clear event history

pub async fn get_registered_handlers(&self) -> HashMap<String, usize>

Get registered event handlers

impl EventBus

Convenience methods for publishing common events

pub async fn publish_skill_registered( &self, skill_id: String, skill: SkillDefinition, ) -> Result<usize, ServiceError>

Publish skill registered event

pub async fn publish_skill_updated( &self, skill_id: String, changes: SkillUpdate, ) -> Result<usize, ServiceError>

Publish skill updated event

pub async fn publish_skill_unregistered( &self, skill_id: String, ) -> Result<usize, ServiceError>

Publish skill unregistered event

pub async fn publish_skill_reloaded( &self, skill_id: String, success: bool, error_message: Option<String>, ) -> Result<usize, ServiceError>

Publish skill reloaded event

pub async fn publish_skill_validation_failed( &self, skill_id: String, errors: Vec<String>, ) -> Result<usize, ServiceError>

Publish skill validation failed event

pub async fn publish_hot_reload_enabled( &self, config: HotReloadConfig, ) -> Result<usize, ServiceError>

Publish hot reload enabled event

pub async fn publish_hot_reload_disabled(&self) -> Result<usize, ServiceError>

Publish hot reload disabled event

pub async fn publish_skill_enabled( &self, skill_id: String, ) -> Result<usize, ServiceError>

Publish skill enabled event

pub async fn publish_skill_disabled( &self, skill_id: String, ) -> Result<usize, ServiceError>

Publish skill disabled event

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.