eventbus

package

v0.2.78 Latest Latest Go to latest Published: Sep 12, 2026 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func AddHandlers(handlers ...cqrs.EventHandler)

AddHandlers 添加事件处理器

func Close() error

Close 关闭事件总线

func Init(handlers ...cqrs.EventHandler)

Init 初始化事件总线并注册处理器

func InitEventBus()

InitEventBus 初始化事件总线

func Publish(ctx context.Context, event any)

Publish 发布事件，并在失败时记录日志。

func PublishE(ctx context.Context, event any) error

PublishE 发布事件，并把发布错误返回给调用方。

func Start(handlers ...cqrs.EventHandler)

Start 启动事件处理器

This section is empty.