recruitment

type FlavorDetail struct {
	FlavorID int32
	RegionID int32
	Cpu      int32
	Memory   float64
	Disk     float64
}

type QuotaManager struct {
	Quotas map[string]RegionalQuota // keyed by region/provider
	Usage  sync.Map                 // key = region/provider string, value = RegionalUsage
}

type Recruiter struct {
	StepID                int32
	Rank                  int
	TimeoutSeconds        int
	Protofilter           string
	WorkerConcurrency     *int
	WorkerPrefetch        *int
	CpuPerTask            *int
	MemoryPerTask         *float32
	DiskPerTask           *float32
	ConcurrencyMax        *int
	ConcurrencyMin        *int
	PrefetchPercent       *int
	MaximumWorkers        *int
	CurrentWorkers        int
	Rounds                int
	PendingTasks          int
	ActiveTaskrate        int
	TargetTaskrate        int
	PotentialTaskrate     int
	WorkflowID            int32
	TimeoutPassed         bool // <- new field
	LastTrigger           time.Time
	RemainingUntilTimeout time.Duration
}

type RecruiterKey struct {
	StepID int32
	Rank   int
}

type RecruiterState struct {
	LastTrigger time.Time
}

type RecyclableWorker struct {
	WorkerID    int32
	FlavorID    int32
	RegionID    int32
	StepID      *int32
	Concurrency int
	Scope       string
	WorkflowID  *int32
	Cpu         *int32
	Memory      *float64
	Disk        *float64
	Occupation  float64
}

type RegionInfo struct {
	Name       string
	Provider   string
	ProviderID int32
}

type RegionalQuota struct {
	Region       string
	Provider     string
	MaxCPU       int32
	MaxMemGB     float32
	MaxInstances int32 // 0 = unlimited (learned from failures)
}

type RegionalUsage struct {
	Region    string
	Provider  string
	UsedCPU   int32
	UsedMemGB float32
	Instances int32
}

type WorkerCreator interface {
	CreateWorker(ctx context.Context, req *pb.WorkerRequest) (*pb.WorkerIds, error)
}

type WorkflowCounter struct {
	Counter int
	Maximum *int
}