job

Dec 16, 2024

Changes in this version

+ func NewService(repo Repository) core.JobService

+ type Handler interface

+ Cancel func(c echo.Context) error

+ Create func(c echo.Context) error

+ List func(c echo.Context) error

+ func NewHandler(service core.JobService) Handler

+ type Job struct

+ Payload string

+ Scheduled time.Time

+ Type string

+ type Reactor interface

+ Start func(ctx context.Context)

+ func NewReactor(store core.StoreService, job core.JobService) Reactor

+ type Repository interface

+ Cancel func(ctx context.Context, id string) (core.Job, error)

+ Clean func(ctx context.Context, olderThan time.Time) ([]core.Job, error)

+ Complete func(ctx context.Context, id, status, result string) (core.Job, error)

+ Dequeue func(ctx context.Context) (*core.Job, error)

+ Enqueue func(ctx context.Context, author, typ, payload string, scheduled time.Time) (core.Job, error)

+ List func(ctx context.Context, authorID string) ([]core.Job, error)

+ func NewRepository(db *gorm.DB) Repository