(_ context.Context, conversationID string)
| 57 | } |
| 58 | |
| 59 | func (m *MemoryEventLog) Events(_ context.Context, conversationID string) ([]*proto.ConversationEvent, error) { |
| 60 | m.mu.Lock() |
| 61 | defer m.mu.Unlock() |
| 62 | |
| 63 | out := make([]*proto.ConversationEvent, 0) |
| 64 | for _, ev := range m.AllEvents { |
| 65 | if ev.ConversationId == conversationID { |
| 66 | out = append(out, ev) |
| 67 | } |
| 68 | } |
| 69 | return out, nil |
| 70 | } |
| 71 | |
| 72 | func (m *MemoryEventLog) ExecEvents(_ context.Context, execID string) ([]*proto.ExecutionEvent, error) { |
| 73 | m.mu.Lock() |
no outgoing calls