Merge pull request #4566 from wengyao04/estimator-resoucequota-plugin-part-2

[MVP] add resourcequota plugin in scheduler-estimator: add resourcequota plugin

Author: karmada-bot

Diff for: api/openapi-spec/swagger.json

@@ -17952,10 +17952,18 @@
       "description": "ReplicaRequirements represents the requirements required by each replica.",
       "type": "object",
       "properties": {
+        "namespace": {
+          "description": "Namespace represents the resources namespaces",
+          "type": "string"
+        },
         "nodeClaim": {
           "description": "NodeClaim represents the node claim HardNodeAffinity, NodeSelector and Tolerations required by each replica.",
           "$ref": "#/definitions/com.github.karmada-io.karmada.pkg.apis.work.v1alpha2.NodeClaim"
         },
+        "priorityClassName": {
+          "description": "PriorityClassName represents the resources priorityClassName",
+          "type": "string"
+        },
         "resourceRequest": {
           "description": "ResourceRequest represents the resources required by each replica.",
           "type": "object",

Diff for: charts/karmada/_crds/bases/work/work.karmada.io_clusterresourcebindings.yaml

@@ -919,6 +919,9 @@ spec:
                 description: ReplicaRequirements represents the requirements required
                   by each replica.
                 properties:
+                  namespace:
+                    description: Namespace represents the resources namespaces
+                    type: string
                   nodeClaim:
                     description: NodeClaim represents the node claim HardNodeAffinity,
                       NodeSelector and Tolerations required by each replica.
@@ -1066,6 +1069,9 @@ spec:
                           type: object
                         type: array
                     type: object
+                  priorityClassName:
+                    description: PriorityClassName represents the resources priorityClassName
+                    type: string
                   resourceRequest:
                     additionalProperties:
                       anyOf:

Diff for: charts/karmada/_crds/bases/work/work.karmada.io_resourcebindings.yaml

@@ -919,6 +919,9 @@ spec:
                 description: ReplicaRequirements represents the requirements required
                   by each replica.
                 properties:
+                  namespace:
+                    description: Namespace represents the resources namespaces
+                    type: string
                   nodeClaim:
                     description: NodeClaim represents the node claim HardNodeAffinity,
                       NodeSelector and Tolerations required by each replica.
@@ -1066,6 +1069,9 @@ spec:
                           type: object
                         type: array
                     type: object
+                  priorityClassName:
+                    description: PriorityClassName represents the resources priorityClassName
+                    type: string
                   resourceRequest:
                     additionalProperties:
                       anyOf:

Diff for: pkg/apis/work/v1alpha2/binding_types.go

@@ -175,6 +175,14 @@ type ReplicaRequirements struct {
 	// ResourceRequest represents the resources required by each replica.
 	// +optional
 	ResourceRequest corev1.ResourceList `json:"resourceRequest,omitempty"`
+
+	// Namespace represents the resources namespaces
+	// +optional
+	Namespace string `json:"namespace,omitempty"`
+
+	// PriorityClassName represents the resources priorityClassName
+	// +optional
+	PriorityClassName string `json:"priorityClassName,omitempty"`
 }
 
 // NodeClaim represents the node claim HardNodeAffinity, NodeSelector and Tolerations required by each replica.

Diff for: pkg/estimator/client/accurate.go

@@ -91,6 +91,8 @@ func (se *SchedulerEstimator) maxAvailableReplicas(ctx context.Context, cluster
 	}
 	if replicaRequirements != nil {
 		req.ReplicaRequirements.ResourceRequest = replicaRequirements.ResourceRequest
+		req.ReplicaRequirements.Namespace = replicaRequirements.Namespace
+		req.ReplicaRequirements.PriorityClassName = replicaRequirements.PriorityClassName
 		if replicaRequirements.NodeClaim != nil {
 			req.ReplicaRequirements.NodeClaim = &pb.NodeClaim{
 				NodeAffinity: replicaRequirements.NodeClaim.HardNodeAffinity,

Diff for: pkg/estimator/pb/generated.pb.go

@@ -57,6 +57,15 @@ type ReplicaRequirements struct {
 	// ResourceRequest represents the resources required by each replica.
 	// +optional
 	ResourceRequest corev1.ResourceList `json:"resourceRequest,omitempty" protobuf:"bytes,2,rep,name=resourceRequest,casttype=k8s.io/api/core/v1.ResourceList,castkey=k8s.io/api/core/v1.ResourceName"`
+	// Namespace represents the namespaces belonged to a ResourceRequest
+	// +optional
+	Namespace string `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"`
+	// PriorityClassName represents the priority class name for a given ResourceRequest
+	// Resource quotas are introduced for multi tenants sharing a cluster
+	// Besides estimate the replica based on nodes' resources, we need to consider the resource quota of a ResourceRequest
+	// ResourceQuota have an associated set of scopes, one of them is priority class
+	// +optional
+	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,4,opt,name=priorityClassName"`
 }
 
 // MaxAvailableReplicasResponse represents the response that sent by gRPC server to calculate max available replicas.

Diff for: pkg/estimator/pb/generated.proto

@@ -17,11 +17,14 @@ limitations under the License.
 package plugins
 
 import (
+	"github.com/karmada-io/karmada/pkg/estimator/server/framework/plugins/resourcequota"
 	"github.com/karmada-io/karmada/pkg/estimator/server/framework/runtime"
 )
 
 // NewInTreeRegistry builds the registry with all the in-tree plugins.
 func NewInTreeRegistry() runtime.Registry {
-	registry := runtime.Registry{}
+	registry := runtime.Registry{
+		resourcequota.Name: resourcequota.New,
+	}
 	return registry
 }