scheduler_pg

package

v0.1.26 Latest Latest Go to latest Published: Feb 8, 2026 License: MIT Imports: 8 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewRepo(pool *pgxpool.Pool) *Repo

func (r *Repo) Create(ctx context.Context, policyID uuid.UUID, next time.Time) error

func (r *Repo) Delete(ctx context.Context, policyID uuid.UUID) error

func (r *Repo) GetByPolicy(ctx context.Context, policyID uuid.UUID) (scheduler.Scheduler, error)

func (r *Repo) GetPending(ctx context.Context) ([]scheduler.Scheduler, error)

func (r *Repo) SetNext(ctx context.Context, policyID uuid.UUID, next time.Time) error

func (r *Repo) Tx() storage.Tx