errors.go

package scheduler

import "errors"

var (
	// ErrJobNotFound indicates that a referenced job record does not exist.
	ErrJobNotFound = errors.New("job not found")
	// ErrLeaseConflict indicates that the caller does not own the current lease.
	ErrLeaseConflict = errors.New("lease conflict")
	// ErrHandlerNotFound indicates that no worker handler was registered for a job type.
	ErrHandlerNotFound = errors.New("handler not found")
	// ErrDuplicateJobID indicates that a job with the same ID already exists.
	ErrDuplicateJobID = errors.New("duplicate job id")
	// ErrInvalidJobState indicates that a job transition was attempted from an invalid state.
	ErrInvalidJobState = errors.New("invalid job state")
	// ErrDuplicateKey indicates that an idempotency key is already associated with another job.
	ErrDuplicateKey = errors.New("duplicate idempotency key")
	// ErrStoreRequired indicates that a producer or worker was created without a store.
	ErrStoreRequired = errors.New("store is required")
)