eventbus

type Channel ¶

type Channel string

Channel 标识一条实时推送通道（如 "task:123"）。

func TaskChannel(taskID int64) Channel

type EventBus ¶

type EventBus struct {
	// contains filtered or unexported fields
}

EventBus — AI Engine Event Infrastructure V2

事件分层路由：

• Transient → WS only（不入库，不 replay，丢失没关系）
• Persistent → DB + WS + Sequence（状态恢复、Timeline 重建）
• Audit → DB only（不推送 WS）

Phase 2 roadmap:

• timeline_patch: PatchImportance tiers (structural/visual/ephemeral), only structural persists
• Client: Snapshot + Incremental Events instead of full replay
• inferGrade: remove fallback, all emitters set Grade explicitly

func NewEventBus(
	repo repository.EventRepository,
	pub Publisher,
) *EventBus

func (b *EventBus) Publish(taskID int64, event *domain.TaskEvent)

func (b *EventBus) PublishToChannel(ch Channel, event *domain.TaskEvent)

func (b *EventBus) Subscribe(eventType string) <-chan *domain.TaskEvent

func (b *EventBus) Unsubscribe(eventType string, ch <-chan *domain.TaskEvent)

type Publisher ¶

type Publisher interface {
	Publish(ch Channel, event any)
}

Publisher 是实时事件推送的传输抽象。EventBus 只依赖此接口， 具体实现（WebSocket、SSE、日志等）由业务侧注入。传输层实现只需 提供一个 Publish 方法即可满足该接口。