nodezone schedule plugin (#265)

vesoft-inc · Sep 12, 2023 · 0cd35fa · 0cd35fa
1 parent 15ee7c2
commit 0cd35fa
Show file tree

Hide file tree

Showing 22 changed files with 1,397 additions and 697 deletions.
diff --git a/apis/apps/v1alpha1/nebulacluster_common.go b/apis/apps/v1alpha1/nebulacluster_common.go
@@ -49,6 +49,8 @@ const (
 	agentPortNameGRPC         = "grpc"
 	defaultAgentImage         = "vesoft/nebula-agent"
 	defaultAlpineImage        = "vesoft/nebula-alpine:latest"
+
+	ZoneSuffix = "zone"
 )
 
 func getComponentName(clusterName string, typ ComponentType) string {
@@ -606,9 +608,7 @@ func generateStatefulSet(c NebulaClusterComponent, cm *corev1.ConfigMap) (*appsv
 		ServiceAccountName: NebulaServiceAccountName,
 	}
 
-	if nc.Spec.SchedulerName == corev1.DefaultSchedulerName {
-		podSpec.TopologySpreadConstraints = getTopologySpreadConstraints(nc.Spec.TopologySpreadConstraints, componentLabel)
-	}
+	podSpec.TopologySpreadConstraints = getTopologySpreadConstraints(nc.Spec.TopologySpreadConstraints, componentLabel)
 
 	volumeClaim, err := c.GenerateVolumeClaim()
 	if err != nil {