workertracker

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

type WorkerInfo struct {
	// WorkerID is a unique identifier for this worker instance.
	WorkerID string `json:"worker_id"`
	// MaxConcurrentTasks is the maximum number of tasks this worker can run simultaneously.
	MaxConcurrentTasks int `json:"max_concurrent_tasks"`
	// ActiveTasks is the number of tasks currently being executed by this worker.
	ActiveTasks int `json:"active_tasks"`
	// ConnectedAt is when this worker first connected.
	ConnectedAt time.Time `json:"connected_at"`
	// LastPollAt is when this worker last polled for work.
	LastPollAt time.Time `json:"last_poll_at"`
	// UptimeMs is total uptime since the worker first connected.
	UptimeMs int64 `json:"uptime_ms"`
	// Polling indicates whether the worker is currently in a long-poll request.
	Polling bool `json:"polling"`
}