worker

type Event struct {
	Type      EventType
	Timestamp time.Time
	Data      any
}

type EventHandler func(event Event)

type EventType string

type JobClaimedData struct {
	JobID     string
	QueueName string
}

type JobCompletedData struct {
	JobID     string
	QueueName string
	Result    map[string]any
	Duration  time.Duration
}

type JobContext struct {
	// Context is the Go context with cancellation
	Context context.Context
	// JobID is the unique job identifier
	JobID string
	// QueueName is the queue this job belongs to
	QueueName string
	// Payload is the job payload when it is a JSON object, and nil for any other
	// JSON value (array, string, number, boolean, null). Use RawPayload to read
	// those.
	Payload map[string]any
	// RawPayload is the decoded job payload whatever its JSON type: a
	// map[string]any for an object, a []any for an array, a string, a float64, a
	// bool, or nil. Integers too large for a float64 (above 2^53) arrive as
	// json.Number so IDs are not rounded; every other number is a float64.
	RawPayload any
	// RetryCount is the current retry attempt number
	RetryCount int
	// MaxRetries is the maximum number of retries
	MaxRetries int
	// Progress is not supported: the Spooled API has no job progress route. It
	// returns an *resources.UnsupportedError (it matches resources.ErrUnsupported
	// with errors.Is) and makes no request. Returning that error from a handler
	// fails the job, so remove the call. Return progress in the job result or
	// report it with Log.
	//
	// Deprecated: the API cannot store job progress.
	Progress func(percent float64, message string) error
	// Log logs a message at the specified level
	Log func(level string, message string, meta map[string]any)
	// contains filtered or unexported fields
}

type JobFailedData struct {
	JobID     string
	QueueName string
	Error     error
	Duration  time.Duration
	WillRetry bool
}

type JobHandler func(ctx *JobContext) (map[string]any, error)

type JobLeaseLostData struct {
	JobID     string
	QueueName string
	LeaseID   string
	Operation string
	Error     error
}

type JobStartedData struct {
	JobID     string
	QueueName string
}

type JobTimeoutData struct {
	JobID          string
	QueueName      string
	TimeoutSeconds int
	Duration       time.Duration
}

type Options struct {
	// QueueName is the name of the queue to process
	QueueName string
	// WorkerID is an optional stable worker identity (1-128 chars from
	// [A-Za-z0-9._-]). Keep it the same across restarts and registration
	// upserts a single worker row, so a restarting process reclaims its
	// identity. Leave it empty and the server mints a fresh UUID on every
	// Start, which leaves the previous row occupying the plan worker cap
	// until the stale-worker reaper clears it (roughly two minutes).
	WorkerID string
	// Hostname is the worker hostname (default: auto-detected)
	Hostname string
	// WorkerType is an identifier for this worker type
	WorkerType string
	// Concurrency is the maximum concurrent jobs (1-100, default: 5)
	Concurrency int
	// PollInterval is the polling interval (default: 1s)
	PollInterval time.Duration
	// LeaseDuration is the job lease duration in seconds (5-3600, default: 30)
	LeaseDuration int
	// HeartbeatFraction is the heartbeat interval as a fraction of lease duration (default: 0.5)
	HeartbeatFraction float64
	// ShutdownTimeout is how long Stop (and cancelling the context given to
	// Start) lets running handlers finish before they are cancelled and their
	// jobs failed with "Worker shutdown timeout" (default: 30s). Handlers that
	// finish inside the window are completed or failed normally.
	ShutdownTimeout time.Duration
	// Version is the worker version string
	Version string
	// Metadata is additional worker metadata
	Metadata map[string]string
	// Debug enables debug logging
	Debug bool
	// Logger is a custom logger function
	Logger func(msg string, args ...any)
}

type State string

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

type WorkerErrorData struct {
	Error error
}

type WorkerStartedData struct {
	WorkerID  string
	QueueName string
}

type WorkerStoppedData struct {
	WorkerID string
	Reason   string
}