Default number of seeds to 1

jetstack · Feb 27, 2018 · 5d712ff · 5d712ff
1 parent c7d6d0a
commit 5d712ff
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 0 deletions.
diff --git a/pkg/apis/navigator/validation/cassandra.go b/pkg/apis/navigator/validation/cassandra.go
@@ -22,6 +22,12 @@ func ValidateCassandraClusterNodePool(np *navigator.CassandraClusterNodePool, fl
 		)
 	}
 
+	if np.Seeds < 0 {
+		allErrs = append(allErrs,
+			field.Invalid(fldPath.Child("seeds"), np.Seeds, "number of seeds must be 1 or greater"),
+		)
+	}
+
 	return allErrs
 }
 

diff --git a/pkg/registry/navigator/cassandracluster/strategy.go b/pkg/registry/navigator/cassandracluster/strategy.go
@@ -66,10 +66,23 @@ func (cassandraClusterStrategy) NamespaceScoped() bool {
 	return true
 }
 
+func defaultSeeds(new *navigator.CassandraCluster) {
+	// default to 1 seed if not specified
+	for i := 0; i < len(new.Spec.NodePools); i++ {
+		if new.Spec.NodePools[i].Seeds == 0 {
+			new.Spec.NodePools[i].Seeds = 1
+		}
+	}
+}
+
 func (cassandraClusterStrategy) PrepareForCreate(ctx genericapirequest.Context, obj runtime.Object) {
+	new := obj.(*navigator.CassandraCluster)
+	defaultSeeds(new)
 }
 
 func (cassandraClusterStrategy) PrepareForUpdate(ctx genericapirequest.Context, obj, old runtime.Object) {
+	new := obj.(*navigator.CassandraCluster)
+	defaultSeeds(new)
 }
 
 func (cassandraClusterStrategy) Validate(ctx genericapirequest.Context, obj runtime.Object) field.ErrorList {