Method captureEvent

pkg/middleware/logic_memory.go:337–357

captureEvent 内部方法：捕获事件

(event *logic.Event)

// captureEvent 内部方法：捕获事件
func (m *LogicMemoryMiddleware) captureEvent(event *logic.Event) {
	if !m.config.EnableCapture {
		return
	}

	if m.config.AsyncCapture && m.eventBuffer != nil {
		// 异步捕获：发送到缓冲区
		select {
		case m.eventBuffer <- event:
			// 成功放入缓冲区
		default:
			// 缓冲区满，丢弃事件（记录警告）
			lmLog.Warn(context.Background(), "event buffer full, dropping event", map[string]any{"type": event.Type})
		}
	} else {
		// 同步捕获：直接处理
		if err := m.manager.ProcessEvent(context.Background(), *event); err != nil {
			lmLog.Error(context.Background(), "failed to process event", map[string]any{"error": err.Error()})
		}
	}
}

// processEventsAsync 异步处理事件的 goroutine
func (m *LogicMemoryMiddleware) processEventsAsync() {