AppendEvent 添加事件
(ctx context.Context, sessionID string, event *Event)
| 127 | |
| 128 | // AppendEvent 添加事件 |
| 129 | func (s *InMemoryService) AppendEvent(ctx context.Context, sessionID string, event *Event) error { |
| 130 | s.mu.Lock() |
| 131 | defer s.mu.Unlock() |
| 132 | |
| 133 | session, ok := s.sessions[sessionID] |
| 134 | if !ok { |
| 135 | return ErrSessionNotFound |
| 136 | } |
| 137 | |
| 138 | session.events.append(event) |
| 139 | session.lastUpdateTime = time.Now() |
| 140 | return nil |
| 141 | } |
| 142 | |
| 143 | // GetEvents 获取事件列表 |
| 144 | func (s *InMemoryService) GetEvents(ctx context.Context, sessionID string, filter *EventFilter) ([]Event, error) { |