Versions in this module Expand all Collapse all v0 v0.1.0 Sep 6, 2026retracted Changes in this version + type SQLiteOption func(*SQLiteStore) + func WithLogger(logger *slog.Logger) SQLiteOption + type SQLiteStore struct + func NewSQLiteStore(dbPath string, opts ...SQLiteOption) (*SQLiteStore, error) + func (s *SQLiteStore) Close() error + func (s *SQLiteStore) DeleteTask(ctx context.Context, taskID string) error + func (s *SQLiteStore) GetTask(ctx context.Context, taskID string) (durable.TaskInfo, bool, error) + func (s *SQLiteStore) ListStepIDs(ctx context.Context, taskID string) ([]string, error) + func (s *SQLiteStore) ListTasks(ctx context.Context) ([]durable.TaskInfo, error) + func (s *SQLiteStore) LoadStep(ctx context.Context, taskID, stepID string) (durable.StepRecord, bool, error) + func (s *SQLiteStore) LoadSteps(ctx context.Context, taskID string) ([]durable.StepRecord, error) + func (s *SQLiteStore) PurgeTasks(ctx context.Context, status durable.TaskStatus, before time.Time) (int64, error) + func (s *SQLiteStore) SaveStep(ctx context.Context, taskID string, step durable.StepRecord) error + func (s *SQLiteStore) SaveTask(ctx context.Context, task durable.TaskInfo) error
Go to main page