Function NewEventBusWithConfig

pkg/events/bus.go:66–87

NewEventBusWithConfig 创建带配置的事件总线

(config *EventBusConfig)

// NewEventBusWithConfig 创建带配置的事件总线
func NewEventBusWithConfig(config *EventBusConfig) *EventBus {
	if config == nil {
		config = DefaultEventBusConfig()
	}

	eb := &EventBus{
		config:          config,
		timeline:        make([]types.AgentEventEnvelope, 0, 1000),
		bookmarks:       make(map[int64]types.Bookmark),
		progressSubs:    make(map[string]chan types.AgentEventEnvelope),
		controlSubs:     make(map[string]chan types.AgentEventEnvelope),
		monitorSubs:     make(map[string]chan types.AgentEventEnvelope),
		controlHandlers: make(map[string][]EventHandler),
		monitorHandlers: make(map[string][]EventHandler),
		cleanupDone:     make(chan struct{}),
	}

	// 启动清理 worker
	eb.startCleanupWorker()

	return eb
}

// startCleanupWorker 启动后台清理协程
func (eb *EventBus) startCleanupWorker() {