sqlite

func (s *Store) ClaimTaskForRun(ctx context.Context, now time.Time, leaseToken string, leaseGrace time.Duration, taskPK int64) (store.Task, bool, error)

func (s *Store) ClaimTasks(ctx context.Context, now time.Time, leaseToken string, leaseGrace time.Duration, budgets []store.ClaimBudget) ([]store.Task, error)

func (s *Store) CleanupTerminal(ctx context.Context, now time.Time, succeededTTL, failedTTL, dedupWindow time.Duration, limit int) (int64, error)

func (s *Store) Close() error

func (s *Store) CreateQueue(ctx context.Context, u store.QueueUpsert, now time.Time) (store.Queue, error)

func (s *Store) CreateTask(ctx context.Context, t store.NewTask, now time.Time) (store.Task, error)

func (s *Store) CreateTasks(ctx context.Context, ts []store.NewTask, now time.Time) ([]store.TaskResult, error)

func (s *Store) DeleteQueue(ctx context.Context, name string) error

func (s *Store) DeleteTask(ctx context.Context, queue, taskID string, now time.Time) error

func (s *Store) Dialect() string

func (s *Store) Events() <-chan store.Event

func (s *Store) FinishAttempt(ctx context.Context, now time.Time, taskPK int64, leaseToken string, att store.Attempt, outcome store.Outcome, nextSchedule time.Time) (bool, error)

func (s *Store) ForceRun(ctx context.Context, queue, taskID string, now time.Time) (store.Task, error)

func (s *Store) GetQueue(ctx context.Context, name string) (store.Queue, error)

func (s *Store) GetQueuesByID(ctx context.Context, ids []int64) ([]store.Queue, error)

func (s *Store) GetTask(ctx context.Context, queue, taskID string, view store.View) (store.Task, error)

func (s *Store) HardDeletePurged(ctx context.Context, limit int) (int64, error)

func (s *Store) ListAttempts(ctx context.Context, queue, taskID string) ([]store.Attempt, error)

func (s *Store) ListExpiredLeases(ctx context.Context, now time.Time, limit int) ([]store.Task, error)

func (s *Store) ListQueues(ctx context.Context, opts store.ListQueuesOpts) ([]store.Queue, string, error)

func (s *Store) ListTasks(ctx context.Context, opts store.ListTasksOpts) ([]store.Task, string, error)

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

func (s *Store) NextPending(ctx context.Context, queueID int64, now time.Time) (*time.Time, error)

func (s *Store) PatchQueue(ctx context.Context, name string, p store.QueuePatch, now time.Time) (store.Queue, error)

func (s *Store) Ping(ctx context.Context) error

func (s *Store) PurgeQueue(ctx context.Context, name string, now time.Time) (store.Queue, error)

func (s *Store) QueueStats(ctx context.Context, name, idPrefix string, now time.Time) (store.QueueStats, error)

func (s *Store) SeedDispatch(ctx context.Context) ([]store.QueueSeed, error)

func (s *Store) SetQueueState(ctx context.Context, name string, state store.QueueState, now time.Time) (store.Queue, error)

func (s *Store) UpsertQueue(ctx context.Context, u store.QueueUpsert, now time.Time) (store.Queue, store.UpsertOutcome, error)