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 data
	Payload map[string]any
	// RetryCount is the current retry attempt number
	RetryCount int
	// MaxRetries is the maximum number of retries
	MaxRetries int
	// Progress reports job progress (0-100)
	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 JobProgressData struct {
	JobID   string
	Percent float64
	Message string
}

type JobStartedData struct {
	JobID     string
	QueueName string
}

type Options struct {
	// QueueName is the name of the queue to process
	QueueName 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 the graceful shutdown timeout (default: 30s)
	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
}