Method OnAgentStart

pkg/middleware/logic_memory.go:158–166

OnAgentStart Agent 启动时启动事件处理器

(ctx context.Context, agentID string)

// OnAgentStart Agent 启动时启动事件处理器
func (m *LogicMemoryMiddleware) OnAgentStart(ctx context.Context, agentID string) error {
	// 启动异步事件处理 goroutine
	if m.config.AsyncCapture && m.config.EnableCapture && m.eventBuffer != nil {
		m.wg.Add(1)
		go m.processEventsAsync()
		lmLog.Info(context.Background(), "started async event processor", map[string]any{"agent_id": agentID})
	}
	return nil
}

// OnAgentStop Agent 停止时停止事件处理器
func (m *LogicMemoryMiddleware) OnAgentStop(ctx context.Context, agentID string) error {