sqlite

package

v0.2.0 Latest Latest Go to latest Published: Mar 23, 2026 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/spawn08/chronos

Links

Open Source Insights

Documentation ¶

Overview ¶

Package sqlite provides a SQLite-backed Storage adapter for Chronos.

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 SQLite.

func New ¶

func New(dsn string) (*Store, error)

New opens a SQLite database at the given DSN (file path or ":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)

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(ctx context.Context) error

Migrate creates all required tables.

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

Source Files ¶

View all Source files

sqlite.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL