domain

type Handler interface {
	Prepare(any) (JobData, monad.Maybe[string], error) // Try to prepare a job payload and returns the JobData needed to process it and an eventual dedupe name to use
	Process(context.Context, Job) error
}

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

type JobData storage.Discriminated

type JobDone struct {
	ID JobID
}

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

type JobID string

type JobQueued struct {
	ID         JobID
	DedupeName string
	Data       JobData
	QueuedAt   time.Time
}

type JobsReader interface {
	GetRunningJobs(context.Context) ([]Job, error)
	GetNextPendingJobs(context.Context, []string) ([]Job, error)
}

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