Documentation
¶
Overview ¶
Package eventbus 提供进程内事件总线（发布/订阅）。 支持同步与异步两种投递模式；异步模式下发布不阻塞调用方。 典型用途：业务模块解耦（订单创建后通知库存/通知/审计）、进程内观察者模式。
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Bus ¶
type Bus struct {
// contains filtered or unexported fields
}
Bus 是进程内事件总线。
func (*Bus) Publish ¶
Publish 发布事件。 同步模式：按订阅顺序执行，任一订阅者返回错误即停止并返回该错误。 异步模式：每个订阅者在独立 goroutine 中执行，错误仅记录到日志输出（不返回）。
func (*Bus) SubscribeAll ¶
SubscribeAll 订阅全部事件（用于日志、审计等横切关注点）。
type Event ¶
type Event struct {
// Name 是事件名（如 order.created），订阅者按名称匹配。
Name string
// Data 是事件附带数据。
Data interface{}
}
Event 是事件负载。
type RedisBridge ¶ added in v1.66.0
type RedisBridge struct {
// contains filtered or unexported fields
}
RedisBridge 通过 Redis Pub/Sub 桥接多个实例的进程内事件总线。 场景:多实例部署时,实例 A 发布的业务事件可被实例 B 的订阅者接收 (如分布式缓存失效通知、跨实例业务联动)。 注意:事件负载必须可 JSON 序列化;跨实例收到的 data 类型为 map[string]interface{}。
func NewRedisBridge ¶ added in v1.66.0
func NewRedisBridge(client *redis.Client, channel string, bus *Bus) *RedisBridge
NewRedisBridge 创建桥接器。 client 为 go-redis 客户端;channel 为 Redis 频道名(多环境隔离用不同频道); bus 为本地事件总线(同步/异步均可,桥接按本地语义投递)。
Source Files
Click to show internal directories.
Click to hide internal directories.