sqlite

package

v0.3.1 Latest Latest Go to latest Published: Dec 1, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SqliteCheckpointStore struct {
	// contains filtered or unexported fields
}

SqliteCheckpointStore implements graph.CheckpointStore using SQLite

func NewSqliteCheckpointStore(opts SqliteOptions) (*SqliteCheckpointStore, error)

NewSqliteCheckpointStore creates a new SQLite checkpoint store

func (s *SqliteCheckpointStore) Clear(ctx context.Context, executionID string) error

Clear removes all checkpoints for an execution

func (s *SqliteCheckpointStore) Close() error

Close closes the database connection

func (s *SqliteCheckpointStore) Delete(ctx context.Context, checkpointID string) error

Delete removes a checkpoint

func (s *SqliteCheckpointStore) InitSchema(ctx context.Context) error

InitSchema creates the necessary table if it doesn't exist

func (s *SqliteCheckpointStore) List(ctx context.Context, executionID string) ([]*graph.Checkpoint, error)

List returns all checkpoints for a given execution

func (s *SqliteCheckpointStore) Load(ctx context.Context, checkpointID string) (*graph.Checkpoint, error)

Load retrieves a checkpoint by ID

func (s *SqliteCheckpointStore) Save(ctx context.Context, checkpoint *graph.Checkpoint) error

Save stores a checkpoint

type SqliteOptions struct {
	Path      string
	TableName string // Default "checkpoints"
}

SqliteOptions configuration for SQLite connection