memory

func (*Store) AppendAuditLog ¶

func (s *Store) AppendAuditLog(ctx context.Context, log *storage.AuditLog) error

func (*Store) AppendEvent ¶

func (s *Store) AppendEvent(ctx context.Context, e *storage.Event) error

func (*Store) Close ¶

func (s *Store) Close() error

func (*Store) CreateSession ¶

func (s *Store) CreateSession(ctx context.Context, sess *storage.Session) error

func (*Store) DeleteMemory ¶

func (s *Store) DeleteMemory(ctx context.Context, id string) error

func (*Store) GetCheckpoint ¶

func (s *Store) GetCheckpoint(ctx context.Context, id string) (*storage.Checkpoint, error)

func (*Store) GetLatestCheckpoint ¶

func (s *Store) GetLatestCheckpoint(ctx context.Context, sessionID string) (*storage.Checkpoint, error)

GetLatestCheckpoint returns the checkpoint with the highest seq_num for the session, not the one with the latest wall-clock CreatedAt: same-tick checkpoints (or a clock step) would otherwise make the "latest" checkpoint non-deterministic, the bug PLAN.md P0-003 fixed for the SQL adapters — this applies the same fix here.

func (*Store) GetMemory ¶

func (s *Store) GetMemory(ctx context.Context, agentID, key string) (*storage.MemoryRecord, error)

func (*Store) GetSession ¶

func (s *Store) GetSession(ctx context.Context, id string) (*storage.Session, error)

func (*Store) GetTrace ¶

func (s *Store) GetTrace(ctx context.Context, id string) (*storage.Trace, error)

func (*Store) InsertTrace ¶

func (s *Store) InsertTrace(ctx context.Context, t *storage.Trace) error

func (*Store) ListAuditLogs ¶

func (s *Store) ListAuditLogs(ctx context.Context, sessionID string, limit, offset int) ([]*storage.AuditLog, error)

func (*Store) ListCheckpoints ¶

func (s *Store) ListCheckpoints(ctx context.Context, sessionID string) ([]*storage.Checkpoint, error)

func (*Store) ListEvents ¶

func (s *Store) ListEvents(ctx context.Context, sessionID string, afterSeq int64) ([]*storage.Event, error)

func (*Store) ListMemory ¶

func (s *Store) ListMemory(ctx context.Context, agentID, kind string) ([]*storage.MemoryRecord, error)

func (*Store) ListSessions ¶

func (s *Store) ListSessions(ctx context.Context, agentID string, limit, offset int) ([]*storage.Session, error)

func (*Store) ListTraces ¶

func (s *Store) ListTraces(ctx context.Context, sessionID string) ([]*storage.Trace, error)

func (*Store) Migrate ¶

func (s *Store) Migrate(_ context.Context) error

func (*Store) PutMemory ¶

func (s *Store) PutMemory(ctx context.Context, m *storage.MemoryRecord) error

func (*Store) SaveCheckpoint ¶

func (s *Store) SaveCheckpoint(ctx context.Context, cp *storage.Checkpoint) error

func (*Store) UpdateSession ¶

func (s *Store) UpdateSession(ctx context.Context, sess *storage.Session) error

func (*Store) UpdateSessionStatus ¶ added in v0.13.0

func (s *Store) UpdateSessionStatus(ctx context.Context, sessionID, status string, updatedAt time.Time) error

UpdateSessionStatus implements storage.SessionStatusUpdater: a narrow write that only touches Status/UpdatedAt, so it can never race with (and clobber) a concurrent Metadata writer the way a GetSession->mutate->UpdateSession read-modify-write could.