pub enum EventBusMessage {
PublishEvent {
event: Event,
},
AddHandler {
handler: Arc<dyn EventHandler<Event> + Send + Sync>,
reply: Sender<HandlerId>,
},
RemoveHandler {
handler_id: HandlerId,
reply: Sender<ForgeResult<()>>,
},
GetStats {
reply: Sender<EventBusStats>,
},
UpdateConfig {
config: EventConfig,
reply: Sender<ForgeResult<()>>,
},
}Expand description
事件总线消息类型
Variants§
PublishEvent
发布事件
AddHandler
添加事件处理器
RemoveHandler
移除事件处理器
GetStats
获取事件总线统计信息
Fields
§
reply: Sender<EventBusStats>UpdateConfig
更新配置
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for EventBusMessage
impl !UnwindSafe for EventBusMessage
impl Freeze for EventBusMessage
impl Send for EventBusMessage
impl Sync for EventBusMessage
impl Unpin for EventBusMessage
impl UnsafeUnpin for EventBusMessage
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage