Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ If you like to contribute to the Managed Upgrade Operator, please read our [Cont
apiVersion: upgrade.managed.openshift.io/v1alpha1
kind: UpgradeConfig
metadata:
name: osd-upgrade-config
name: managed-upgrade-config
spec:
type: "OSD"
upgradeAt: "2020-01-01T00:00:00Z"
Expand Down
21 changes: 11 additions & 10 deletions pkg/controller/upgradeconfig/upgradeconfig_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package upgradeconfig

import (
"context"
"fmt"
"time"

"sigs.k8s.io/controller-runtime/pkg/event"
Expand Down Expand Up @@ -73,7 +74,7 @@ func add(mgr manager.Manager, r reconcile.Reconciler) error {
}

// Watch for changes to primary resource UpgradeConfig, status change will not trigger a reconcile
err = c.Watch(&source.Kind{Type: &upgradev1alpha1.UpgradeConfig{}}, &handler.EnqueueRequestForObject{}, StatusChangedPredicate, OSDUpgradePredicate)
err = c.Watch(&source.Kind{Type: &upgradev1alpha1.UpgradeConfig{}}, &handler.EnqueueRequestForObject{}, StatusChangedPredicate, ManagedUpgradePredicate)
if err != nil {
return err
}
Expand Down Expand Up @@ -192,7 +193,7 @@ func (r *ReconcileUpgradeConfig) Reconcile(request reconcile.Request) (reconcile
return reconcile.Result{}, err
}

reqLogger.Info("Checking if cluster can commence upgrade.")
reqLogger.Info(fmt.Sprintf("Checking if cluster can commence %s upgrade.", instance.Spec.Type))
schedulerResult := r.scheduler.IsReadyToUpgrade(instance, cfg.GetUpgradeWindowTimeOutDuration())
if schedulerResult.IsReady {
ucMgr, err := r.ucMgrBuilder.NewManager(r.client)
Expand All @@ -210,7 +211,7 @@ func (r *ReconcileUpgradeConfig) Reconcile(request reconcile.Request) (reconcile
}

if remoteChanged {
reqLogger.Info("The remote upgrade policy does not match the local upgrade config, applying the new upgrade policy")
reqLogger.Info("The cluster's upgrade policy has changed, so the operator will re-reconcile.")
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

should this be 'reconcile'?

return reconcile.Result{}, nil
}

Expand All @@ -229,7 +230,7 @@ func (r *ReconcileUpgradeConfig) Reconcile(request reconcile.Request) (reconcile
return reconcile.Result{}, err
}

reqLogger.Info("Cluster is commencing upgrade.", "time", now)
reqLogger.Info(fmt.Sprintf("Cluster is commencing %s upgrade.", instance.Spec.Type), "time", now)
return r.upgradeCluster(upgrader, instance, reqLogger)
}

Expand Down Expand Up @@ -289,22 +290,22 @@ func (r *ReconcileUpgradeConfig) upgradeCluster(upgrader cub.ClusterUpgrader, uc
return reconcile.Result{RequeueAfter: 1 * time.Minute}, me.ErrorOrNil()
}

var OSDUpgradePredicate = predicate.Funcs{
var ManagedUpgradePredicate = predicate.Funcs{
UpdateFunc: func(e event.UpdateEvent) bool {
return isOsdUpgrade(e.MetaNew.GetName())
return isManagedUpgrade(e.MetaNew.GetName())
},
// Create is required to avoid reconciliation at controller initialisation.
CreateFunc: func(e event.CreateEvent) bool {
return isOsdUpgrade(e.Meta.GetName())
return isManagedUpgrade(e.Meta.GetName())
},
DeleteFunc: func(e event.DeleteEvent) bool {
return isOsdUpgrade(e.Meta.GetName())
return isManagedUpgrade(e.Meta.GetName())
},
GenericFunc: func(e event.GenericEvent) bool {
return isOsdUpgrade(e.Meta.GetName())
return isManagedUpgrade(e.Meta.GetName())
},
}

func isOsdUpgrade(name string) bool {
func isManagedUpgrade(name string) bool {
return name == ucmgr.UPGRADECONFIG_CR_NAME
}
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ var _ = Describe("UpgradeConfigController", func() {
mockUCMgrBuilder = ucMgrMocks.NewMockUpgradeConfigManagerBuilder(mockCtrl)
mockUCMgr = ucMgrMocks.NewMockUpgradeConfigManager(mockCtrl)
upgradeConfigName = types.NamespacedName{
Name: "osd-upgrade-config",
Name: "managed-upgrade-config",
Namespace: "test-namespace",
}
upgradeConfig = testStructs.NewUpgradeConfigBuilder().WithNamespacedName(upgradeConfigName).GetUpgradeConfig()
Expand Down
2 changes: 1 addition & 1 deletion pkg/eventmanager/eventmanager_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ import (

const (
TEST_OPERATOR_NAMESPACE = "openshift-managed-upgrade-operator"
TEST_UPGRADECONFIG_CR = "osd-upgrade-config"
TEST_UPGRADECONFIG_CR = "managed-upgrade-config"
TEST_UPGRADE_VERSION = "4.4.4"
TEST_UPGRADE_TIME = "2020-06-20T00:00:00Z"
)
Expand Down
2 changes: 1 addition & 1 deletion pkg/upgradeconfigmanager/upgradeconfigmanager.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ var log = logf.Log.WithName("upgrade-config-manager")

const (
// Name of the Custom Resource that the provider will manage
UPGRADECONFIG_CR_NAME = "osd-upgrade-config"
UPGRADECONFIG_CR_NAME = "managed-upgrade-config"
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

+1

// Jitter factor (percentage / 100) used to alter watch interval
JITTER_FACTOR = 0.1
INITIAL_SYNC_DURATION = 1 * time.Minute
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
apiVersion: upgrade.managed.openshift.io/v1alpha1
kind: UpgradeConfig
metadata:
name: osd-upgrade-config
name: managed-upgrade-config
spec:
type: "OSD"
upgradeAt: "2020-01-01T00:00:00Z"
Expand Down