worker

type ActiveClaimEntry struct {
	JobRunID       string     `json:"job_run_id"`
	TaskID         string     `json:"task_id"`
	Status         string     `json:"status"`
	ClaimAttempt   int        `json:"claim_attempt"`
	ClaimExpiresAt *time.Time `json:"claim_expires_at,omitempty"`
	UpdatedAt      time.Time  `json:"updated_at"`
}

type Service interface {
	WithDatabase(*gorm.DB) Service
	Status(string) (*StatusResponse, error)
}

type StatusResponse struct {
	Address            string             `json:"address"`
	ObservedAt         time.Time          `json:"observed_at"`
	TotalClaimedTasks  int64              `json:"total_claimed_tasks"`
	ClaimedByStatus    map[string]int64   `json:"claimed_by_status"`
	RunningClaims      int64              `json:"running_claims"`
	ExpiredLeases      int64              `json:"expired_leases"`
	TotalClaimAttempts int64              `json:"total_claim_attempts"`
	LastActivityAt     *time.Time         `json:"last_activity_at,omitempty"`
	ActiveClaims       []ActiveClaimEntry `json:"active_claims"`
}