Skip to content

Commit

Permalink
getMultusAdmissionControllerReplicas for non-hypershift externalTopol…
Browse files Browse the repository at this point in the history
…ogy clusters

a5edddf introduced a change that doesn't work on
non-hypershift clusters with external controllplane. Re-introduce the original
logic for this type of clusters.

Signed-off-by: Patryk Diak <pdiak@redhat.com>
(cherry picked from commit 21a564c)
Signed-off-by: Patryk Diak <pdiak@redhat.com>
  • Loading branch information
kyrtapz committed Feb 19, 2024
1 parent 8283f85 commit 4193961
Show file tree
Hide file tree
Showing 3 changed files with 43 additions and 6 deletions.
4 changes: 2 additions & 2 deletions pkg/network/multus_admission_controller.go
Expand Up @@ -50,7 +50,8 @@ func renderMultusAdmissonControllerConfig(manifestDir string, externalControlPla
objs := []*uns.Unstructured{}
var err error

replicas := getMultusAdmissionControllerReplicas(bootstrapResult)
hsc := hypershift.NewHyperShiftConfig()
replicas := getMultusAdmissionControllerReplicas(bootstrapResult, hsc.Enabled)
if ignoredNamespaces == "" {
ignoredNamespaces, err = getOpenshiftNamespaces(client)
if err != nil {
Expand All @@ -68,7 +69,6 @@ func renderMultusAdmissonControllerConfig(manifestDir string, externalControlPla
data.Data["ExternalControlPlane"] = externalControlPlane
data.Data["Replicas"] = replicas
// Hypershift
hsc := hypershift.NewHyperShiftConfig()
data.Data["HyperShiftEnabled"] = hsc.Enabled
data.Data["ManagementClusterName"] = names.ManagementClusterName
data.Data["AdmissionControllerNamespace"] = "openshift-multus"
Expand Down
10 changes: 8 additions & 2 deletions pkg/network/render.go
Expand Up @@ -15,6 +15,7 @@ import (
operv1 "github.com/openshift/api/operator/v1"
"github.com/openshift/cluster-network-operator/pkg/bootstrap"
cnoclient "github.com/openshift/cluster-network-operator/pkg/client"
"github.com/openshift/cluster-network-operator/pkg/hypershift"
"github.com/openshift/cluster-network-operator/pkg/render"
iputil "github.com/openshift/cluster-network-operator/pkg/util/ip"
"github.com/openshift/library-go/pkg/operator/configobserver/featuregates"
Expand Down Expand Up @@ -742,10 +743,15 @@ func renderAdditionalNetworks(conf *operv1.NetworkSpec, manifestDir string) ([]*
return out, nil
}

func getMultusAdmissionControllerReplicas(bootstrapResult *bootstrap.BootstrapResult) int {
func getMultusAdmissionControllerReplicas(bootstrapResult *bootstrap.BootstrapResult, hyperShiftEnabled bool) int {
replicas := 2
if bootstrapResult.Infra.ControlPlaneTopology == configv1.ExternalTopologyMode {
if bootstrapResult.Infra.InfrastructureTopology == configv1.SingleReplicaTopologyMode {
// In HyperShift check HostedControlPlane.ControllerAvailabilityPolicy, otherwise rely on Infra.InfrastructureTopology
if hyperShiftEnabled {
if bootstrapResult.Infra.HostedControlPlane.ControllerAvailabilityPolicy == hypershift.SingleReplica {
replicas = 1
}
} else if bootstrapResult.Infra.InfrastructureTopology == configv1.SingleReplicaTopologyMode {
replicas = 1
}
} else if bootstrapResult.Infra.ControlPlaneTopology == configv1.SingleReplicaTopologyMode {
Expand Down
35 changes: 33 additions & 2 deletions pkg/network/render_test.go
Expand Up @@ -426,13 +426,44 @@ func TestRenderUnknownNetwork(t *testing.T) {

func Test_getMultusAdmissionControllerReplicas(t *testing.T) {
type args struct {
bootstrapResult *bootstrap.BootstrapResult
bootstrapResult *bootstrap.BootstrapResult
hypershiftEnabled bool
}
tests := []struct {
name string
args args
want int
}{
{
name: "External control plane, HyperShift, highly available infra",
args: args{
bootstrapResult: &bootstrap.BootstrapResult{
Infra: bootstrap.InfraStatus{
ControlPlaneTopology: configv1.ExternalTopologyMode,
HostedControlPlane: &hypershift.HostedControlPlane{
ControllerAvailabilityPolicy: hypershift.HighlyAvailable,
},
},
},
hypershiftEnabled: true,
},
want: 2,
},
{
name: "External control plane, HyperShift, single-replica infra",
args: args{
bootstrapResult: &bootstrap.BootstrapResult{
Infra: bootstrap.InfraStatus{
ControlPlaneTopology: configv1.ExternalTopologyMode,
HostedControlPlane: &hypershift.HostedControlPlane{
ControllerAvailabilityPolicy: hypershift.SingleReplica,
},
},
},
hypershiftEnabled: true,
},
want: 1,
},
{
name: "External control plane, highly available infra",
args: args{
Expand Down Expand Up @@ -508,7 +539,7 @@ func Test_getMultusAdmissionControllerReplicas(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
if got := getMultusAdmissionControllerReplicas(tt.args.bootstrapResult); got != tt.want {
if got := getMultusAdmissionControllerReplicas(tt.args.bootstrapResult, tt.args.hypershiftEnabled); got != tt.want {
t.Errorf("getMultusAdmissionControllerReplicas() = %v, want %v", got, tt.want)
}
})
Expand Down

0 comments on commit 4193961

Please sign in to comment.