add field for supporting multi-cluster scheduling (volcano-sh#49)

Signed-off-by: william-wang <[email protected]>

Author: william-wang

pkg/apis/batch/v1alpha1/labels.go

@@ -35,4 +35,12 @@ const (
 	PodgroupNamePrefix = "podgroup-"
 	// PodTemplateKey type specify a equivalence pod class
 	PodTemplateKey = "volcano.sh/template-uid"
+	// JobForwardingKey job forwarding key used in job annotation
+	JobForwardingKey = "volcano.sh/job-forwarding"
+	// ForwardClusterKey cluster key used in pod annotation
+	ForwardClusterKey = "volcano.sh/forward-cluster"
+	// OrginalNameKey annotation key for resource name
+	OrginalNameKey = "volcano.sh/burst-name"
+	// BurstToSiloClusterAnnotation labels key for resource only in silo cluster
+	BurstToSiloClusterAnnotation = "volcano.sh/silo-resource"
 )

pkg/apis/scheduling/types.go

@@ -278,6 +278,13 @@ type QueueStatus struct {
 	Reservation Reservation `json:"reservation,omitempty" protobuf:"bytes,6,opt,name=reservation"`
 }
 
+// CluterSpec represents the template of Cluster
+type Cluster struct {
+	Name string
+	Weight int32
+	Capacity v1.ResourceList
+}
+
 // QueueSpec represents the template of Queue.
 type QueueSpec struct {
 	Weight     int32
@@ -288,6 +295,9 @@ type QueueSpec struct {
 	// Reclaimable indicate whether the queue can be reclaimed by other queue
 	Reclaimable *bool
 
+	// extendCluster indicate the jobs in this Queue will be dispatched to these clusters.
+	ExtendClusters []Cluster
+
 	// Guarantee indicate configuration about resource reservation
 	Guarantee Guarantee `json:"guarantee,omitempty" protobuf:"bytes,4,opt,name=guarantee"`
 }

pkg/apis/scheduling/v1beta1/types.go

@@ -294,6 +294,13 @@ type QueueStatus struct {
 	Reservation Reservation `json:"reservation,omitempty" protobuf:"bytes,6,opt,name=reservation"`
 }
 
+// CluterSpec represents the template of Cluster
+type Cluster struct {
+	Name string              `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
+	Weight int32             `json:"weight,omitempty" protobuf:"bytes,2,opt,name=weight"`
+	Capacity v1.ResourceList `json:"capacity,omitempty" protobuf:"bytes,3,opt,name=capacity"`
+}
+
 // QueueSpec represents the template of Queue.
 type QueueSpec struct {
 	Weight     int32           `json:"weight,omitempty" protobuf:"bytes,1,opt,name=weight"`
@@ -302,6 +309,9 @@ type QueueSpec struct {
 	// Reclaimable indicate whether the queue can be reclaimed by other queue
 	Reclaimable *bool `json:"reclaimable,omitempty" protobuf:"bytes,3,opt,name=reclaimable"`
 
+    // extendCluster indicate the jobs in this Queue will be dispatched to these clusters.
+	ExtendClusters []Cluster `json:"extendClusters,omitempty" protobuf:"bytes,4,opt,name=extendClusters"`
+
 	// Guarantee indicate configuration about resource reservation
 	Guarantee Guarantee `json:"guarantee,omitempty" protobuf:"bytes,4,opt,name=guarantee"`
 }