Documentation
¶
Overview ¶
Package redis provides a Redis-backed Storage adapter for Chronos. Uses the Redis RESP protocol via a minimal TCP client.
Index ¶
- type Store
- func (s *Store) AppendAuditLog(ctx context.Context, log *storage.AuditLog) error
- func (s *Store) AppendEvent(ctx context.Context, e *storage.Event) error
- func (s *Store) Close() error
- func (s *Store) CreateSession(ctx context.Context, sess *storage.Session) error
- func (s *Store) DeleteMemory(ctx context.Context, id string) error
- func (s *Store) GetCheckpoint(ctx context.Context, id string) (*storage.Checkpoint, error)
- func (s *Store) GetLatestCheckpoint(_ context.Context, sessionID string) (*storage.Checkpoint, error)
- func (s *Store) GetMemory(ctx context.Context, agentID, key string) (*storage.MemoryRecord, error)
- func (s *Store) GetSession(ctx context.Context, id string) (*storage.Session, error)
- func (s *Store) GetTrace(ctx context.Context, id string) (*storage.Trace, error)
- func (s *Store) InsertTrace(ctx context.Context, t *storage.Trace) error
- func (s *Store) ListAuditLogs(_ context.Context, sessionID string, limit, offset int) ([]*storage.AuditLog, error)
- func (s *Store) ListCheckpoints(_ context.Context, sessionID string) ([]*storage.Checkpoint, error)
- func (s *Store) ListEvents(_ context.Context, sessionID string, afterSeq int64) ([]*storage.Event, error)
- func (s *Store) ListMemory(_ context.Context, agentID, kind string) ([]*storage.MemoryRecord, error)
- func (s *Store) ListSessions(_ context.Context, agentID string, limit, offset int) ([]*storage.Session, error)
- func (s *Store) ListTraces(_ context.Context, sessionID string) ([]*storage.Trace, error)
- func (s *Store) Migrate(_ context.Context) error
- func (s *Store) PutMemory(ctx context.Context, m *storage.MemoryRecord) error
- func (s *Store) SaveCheckpoint(ctx context.Context, cp *storage.Checkpoint) error
- func (s *Store) UpdateSession(ctx context.Context, sess *storage.Session) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store implements storage.Storage using Redis.
func (*Store) AppendAuditLog ¶
func (*Store) AppendEvent ¶
func (*Store) CreateSession ¶
func (*Store) GetCheckpoint ¶
func (*Store) GetLatestCheckpoint ¶
func (*Store) GetSession ¶
func (*Store) InsertTrace ¶
func (*Store) ListAuditLogs ¶
func (*Store) ListCheckpoints ¶
func (*Store) ListEvents ¶
func (*Store) ListMemory ¶
func (*Store) ListSessions ¶
func (*Store) ListTraces ¶
func (*Store) SaveCheckpoint ¶
Source Files
Click to show internal directories.
Click to hide internal directories.