Method processEventsAsync

pkg/middleware/logic_memory.go:360–383

processEventsAsync 异步处理事件的 goroutine

()

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

	for {
		select {
		case <-m.stopCh:
			// 处理剩余的事件
			for {
				select {
				case event := <-m.eventBuffer:
					if err := m.manager.ProcessEvent(context.Background(), *event); err != nil {
						lmLog.Error(context.Background(), "failed to process event", map[string]any{"error": err.Error()})
					}
				default:
					return
				}
			}
		case event := <-m.eventBuffer:
			if err := m.manager.ProcessEvent(context.Background(), *event); err != nil {
				lmLog.Error(context.Background(), "failed to process event", map[string]any{"error": err.Error()})
			}
		}
	}
}

// buildMemorySection 构建 Memory 注入文本
func (m *LogicMemoryMiddleware) buildMemorySection(memories []*logic.LogicMemory) string {