workload

type Handler interface {
	UpdateWorkloadState(ctx context.Context, workloadState *State, workload *tfv1.TensorFusionWorkload) error
	ApplyRecommendationToWorkload(ctx context.Context, workloadState *State, recommendation *tfv1.Resources) error
	UpdateWorkloadStatus(ctx context.Context, state *State, recommendation *tfv1.Resources) error
	GetMaxAllowedResourcesSpec(workload *State) (*tfv1.Resource, error)
}

type State struct {
	Namespace             string
	Name                  string
	Spec                  tfv1.WorkloadProfileSpec
	Status                tfv1.TensorFusionWorkloadStatus
	CurrentActiveWorkers  map[string]*corev1.Pod
	WorkerUsageSamplers   map[string]*metrics.WorkerUsageSampler
	WorkerUsageAggregator *metrics.WorkerUsageAggregator
}