domain

package

v1.0.0 Latest Latest Go to latest Published: May 22, 2023 License: GPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Handler interface {
	Process(context.Context, Job) error
}

type Job struct {
	event.Emitter
	// contains filtered or unexported fields
}

func JobFrom(scanner storage.Scanner) (j Job, err error)

Recreates a job from a storage scanner

func NewJob(name, payload string) (j Job)

Creates a new job which will be processed by a worker later on.

func (j *Job) Done()

Mark a job as done.

func (j *Job) Failed(err error)

Mark the job has failed. It will be retried later on.

func (j Job) ID() JobID

func (j Job) Name() string

func (j Job) Payload() string

type JobDone struct {
	ID JobID
}

type JobFailed struct {
	ID      JobID
	ErrCode string
	RetryAt time.Time
}

type JobID string

type JobQueued struct {
	ID       JobID
	Name     string
	Payload  string
	QueuedAt time.Time
}

type JobsReader interface {
	GetNextPendingJob(context.Context) (Job, error)
}

type JobsWriter interface {
	Write(context.Context, ...*Job) error
}