server

type Accumulator struct {
	Count int32
	Sum   float64
	Min   float64
	Max   float64
}

type AuthenticatedUser struct {
	UserID   int
	Username string
	IsAdmin  bool
}

type Job struct {
	JobID         int32
	WorkerID      int32
	WorkerName    string
	ProviderID    int32
	ProviderName  string
	Region        string
	Flavor        string
	Action        rune // "C", "D", "R"
	Retry         int
	Timeout       time.Duration
	FromRecruiter bool
}

type ParamSpec struct {
	Name     string   `json:"name"`
	Type     string   `json:"type"`
	Required bool     `json:"required"`
	Default  string   `json:"default"`
	Help     string   `json:"help"` // Or `json:"description"` if your field is named so
	Choices  []string `json:"choices,omitempty"`
}

type QualityDefinition struct {
	Variables map[string]string `json:"variables"` // name -> regex pattern (one capture group)
	Formula   string            `json:"formula"`   // arithmetic expression over variable names
}

type QualityResult struct {
	Vars  map[string]float64 `json:"vars"`
	Score float64            `json:"score"`
}

type StepAgg struct {
	// Task status counters
	Waiting      int32
	Pending      int32
	Accepted     int32
	Running      int32
	Uploading    int32
	Succeeded    int32
	Failed       int32
	ReallyFailed int32          // tasks that have exhausted all retries and are failed
	Retrying     int32          // tasks currently being retried
	RetryingSet  map[int32]bool // set of task IDs currently retrying
	Total        int32

	// Accumulators for durations
	Download   Accumulator
	Upload     Accumulator
	SuccessRun Accumulator
	FailRun    Accumulator

	// RunningTasks maps taskID to start time
	RunningTasks map[int32]time.Time

	// Time bounds (epoch seconds)
	StartTime *int64
	EndTime   *int64
}

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

type TaskUpdateBroadcast struct {
	TaskId   int32
	Status   string
	WorkerId int32
}