MCPcopy Create free account
hub / github.com/astercloud/aster / AppendEvent

Method AppendEvent

pkg/session/inmemory.go:129–141  ·  view source on GitHub ↗

AppendEvent 添加事件

(ctx context.Context, sessionID string, event *Event)

Source from the content-addressed store, hash-verified

127
128// AppendEvent 添加事件
129func (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 获取事件列表
144func (s *InMemoryService) GetEvents(ctx context.Context, sessionID string, filter *EventFilter) ([]Event, error) {

Callers 6

mainFunction · 0.95

Calls 1

appendMethod · 0.80