Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
Signed-off-by: YZ775 <yuzuki-mimura@cybozu.co.jp>
  • Loading branch information
YZ775 committed Jul 26, 2023
1 parent 1cb5123 commit c2723bb
Show file tree
Hide file tree
Showing 5 changed files with 26 additions and 26 deletions.
2 changes: 1 addition & 1 deletion api/v1beta1/mysqlcluster_types.go
Original file line number Diff line number Diff line change
Expand Up @@ -291,7 +291,7 @@ const (
ConditionInitialized string = "Initialized"
ConditionAvailable string = "Available"
ConditionHealthy string = "Healthy"
ConditionUpdated string = "Updated"
ConditionUpToDate string = "UpToDate"
)

// BackupStatus represents the status of the last successful backup.
Expand Down
2 changes: 1 addition & 1 deletion api/v1beta2/mysqlcluster_types.go
Original file line number Diff line number Diff line change
Expand Up @@ -605,7 +605,7 @@ const (
ConditionInitialized string = "Initialized"
ConditionAvailable string = "Available"
ConditionHealthy string = "Healthy"
ConditionUpdated string = "Updated"
ConditionUpToDate string = "UpToDate"
)

// BackupStatus represents the status of the last successful backup.
Expand Down
6 changes: 3 additions & 3 deletions controllers/mysqlcluster_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -1879,14 +1879,14 @@ func (r *MySQLClusterReconciler) UpdateStatus(ctx context.Context, req ctrl.Requ
cluster.Status.ReconcileInfo.ReconcileVersion = 1
needUpdate = true
}
conditionUpdated := meta.FindStatusCondition(cluster.Status.Conditions, mocov1beta2.ConditionUpdated)
ConditionUpToDate := meta.FindStatusCondition(cluster.Status.Conditions, mocov1beta2.ConditionUpToDate)
// if current status and new status are different, update status
if conditionUpdated == nil || conditionUpdated.Status != updated {
if ConditionUpToDate == nil || ConditionUpToDate.Status != updated {
needUpdate = true
}
if needUpdate {
cond := metav1.Condition{
Type: mocov1beta2.ConditionUpdated,
Type: mocov1beta2.ConditionUpToDate,
Status: updated,
Reason: reason,
Message: "the current state is " + reason,
Expand Down
36 changes: 18 additions & 18 deletions controllers/mysqlcluster_controller_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1614,7 +1614,7 @@ var _ = Describe("MySQLCluster reconciler", func() {
}).Should(Succeed())
})

It("should sets ConditionUpdated to be true when StatefulSet is ready", func() {
It("should sets ConditionUpToDate to be true when StatefulSet is ready", func() {
cluster := testNewMySQLCluster("test")
err := k8sClient.Create(ctx, cluster)
Expect(err).NotTo(HaveOccurred())
Expand Down Expand Up @@ -1646,18 +1646,18 @@ var _ = Describe("MySQLCluster reconciler", func() {
if err := k8sClient.Get(ctx, client.ObjectKeyFromObject(cluster), cluster2); err != nil {
return err
}
conditionUpdated := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpdated)
if conditionUpdated == nil {
ConditionUpToDate := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpToDate)
if ConditionUpToDate == nil {
return fmt.Errorf("not yet updated")
}
if conditionUpdated.Status != metav1.ConditionTrue {
if ConditionUpToDate.Status != metav1.ConditionTrue {
return fmt.Errorf("not yet updated")
}
return nil
}).Should(Succeed())
})

It("should not sets ConditionUpdated to be true when StatefulSet is not ready", func() {
It("should not sets ConditionUpToDate to be true when StatefulSet is not ready", func() {
cluster := testNewMySQLCluster("test")
err := k8sClient.Create(ctx, cluster)
Expect(err).NotTo(HaveOccurred())
Expand Down Expand Up @@ -1689,11 +1689,11 @@ var _ = Describe("MySQLCluster reconciler", func() {
if err := k8sClient.Get(ctx, client.ObjectKeyFromObject(cluster), cluster2); err != nil {
return err
}
conditionUpdated := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpdated)
if conditionUpdated == nil {
ConditionUpToDate := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpToDate)
if ConditionUpToDate == nil {
return fmt.Errorf("not yet updated")
}
if conditionUpdated.Status != metav1.ConditionTrue {
if ConditionUpToDate.Status != metav1.ConditionTrue {
return fmt.Errorf("not yet updated")
}
return nil
Expand All @@ -1717,15 +1717,15 @@ var _ = Describe("MySQLCluster reconciler", func() {
if err := k8sClient.Get(ctx, client.ObjectKeyFromObject(cluster), cluster2); err != nil {
return err
}
conditionUpdated := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpdated)
if conditionUpdated == nil {
ConditionUpToDate := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpToDate)
if ConditionUpToDate == nil {
return fmt.Errorf("not yet updated")
}
if err != nil {
return err
}
if conditionUpdated.Status != metav1.ConditionFalse {
fmt.Printf("condition: %+v\n", conditionUpdated)
if ConditionUpToDate.Status != metav1.ConditionFalse {
fmt.Printf("condition: %+v\n", ConditionUpToDate)
return fmt.Errorf("not yet updated")
}
return nil
Expand All @@ -1749,11 +1749,11 @@ var _ = Describe("MySQLCluster reconciler", func() {
if err := k8sClient.Get(ctx, client.ObjectKeyFromObject(cluster), cluster2); err != nil {
return err
}
conditionUpdated := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpdated)
if conditionUpdated == nil {
ConditionUpToDate := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpToDate)
if ConditionUpToDate == nil {
return fmt.Errorf("not yet updated")
}
if conditionUpdated.Status != metav1.ConditionTrue {
if ConditionUpToDate.Status != metav1.ConditionTrue {
return fmt.Errorf("not yet updated")
}
return nil
Expand All @@ -1777,11 +1777,11 @@ var _ = Describe("MySQLCluster reconciler", func() {
if err := k8sClient.Get(ctx, client.ObjectKeyFromObject(cluster), cluster2); err != nil {
return err
}
conditionUpdated := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpdated)
if conditionUpdated == nil {
ConditionUpToDate := meta.FindStatusCondition(cluster2.Status.Conditions, mocov1beta2.ConditionUpToDate)
if ConditionUpToDate == nil {
return fmt.Errorf("not yet updated")
}
if conditionUpdated.Status != metav1.ConditionFalse {
if ConditionUpToDate.Status != metav1.ConditionFalse {
return fmt.Errorf("not yet updated")
}
return nil
Expand Down
6 changes: 3 additions & 3 deletions e2e/upgrade_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -155,11 +155,11 @@ var _ = Context("upgrade", func() {
if err != nil {
return err
}
conditionUpdated := meta.FindStatusCondition(cluster.Status.Conditions, mocov1beta2.ConditionUpdated)
if conditionUpdated == nil {
ConditionUpToDate := meta.FindStatusCondition(cluster.Status.Conditions, mocov1beta2.ConditionUpToDate)
if ConditionUpToDate == nil {
return fmt.Errorf("statefulset is not updated yet")
}
if conditionUpdated.Status != metav1.ConditionTrue {
if ConditionUpToDate.Status != metav1.ConditionTrue {
return fmt.Errorf("statefulset is not updated yet")
}
return nil
Expand Down

0 comments on commit c2723bb

Please sign in to comment.