@@ -424,15 +424,15 @@ func (r *PravegaClusterReconciler) syncSegmentStoreVersion(p *pravegav1beta1.Pra
424
424
return false , nil
425
425
}
426
426
427
- //this function is to check are we doing a rollback in case of a upgrade failure while upgrading from a version below 07 to a version above 07
427
+ // this function is to check are we doing a rollback in case of a upgrade failure while upgrading from a version below 07 to a version above 07
428
428
func (r * PravegaClusterReconciler ) IsClusterRollbackingFrom07 (p * pravegav1beta1.PravegaCluster ) bool {
429
429
if util .IsVersionBelow (p .Spec .Version , "0.7.0" ) && r .IsAbove07STSPresent (p ) {
430
430
return true
431
431
}
432
432
return false
433
433
}
434
434
435
- //This function checks if stsabove07 exsists
435
+ // This function checks if stsabove07 exsists
436
436
func (r * PravegaClusterReconciler ) IsAbove07STSPresent (p * pravegav1beta1.PravegaCluster ) bool {
437
437
stsAbove07 := & appsv1.StatefulSet {}
438
438
name := p .StatefulSetNameForSegmentstoreAbove07 ()
@@ -491,7 +491,7 @@ func (r *PravegaClusterReconciler) deleteExternalServices(p *pravegav1beta1.Prav
491
491
return nil
492
492
}
493
493
494
- //To handle upgrade/rollback from Pravega version < 0.7 to Pravega Version >= 0.7
494
+ // To handle upgrade/rollback from Pravega version < 0.7 to Pravega Version >= 0.7
495
495
func (r * PravegaClusterReconciler ) syncSegmentStoreVersionTo07 (p * pravegav1beta1.PravegaCluster ) (synced bool , err error ) {
496
496
p .Status .UpdateProgress (pravegav1beta1 .UpdatingSegmentstoreReason , "0" )
497
497
newsts := MakeSegmentStoreStatefulSet (p )
@@ -581,23 +581,23 @@ func (r *PravegaClusterReconciler) syncSegmentStoreVersionTo07(p *pravegav1beta1
581
581
return false , nil
582
582
}
583
583
584
- //this function will check if furter increment or decrement in pods needed in case of rollback from version 0.7
584
+ // this function will check if furter increment or decrement in pods needed in case of rollback from version 0.7
585
585
func (r * PravegaClusterReconciler ) rollbackConditionFor07 (p * pravegav1beta1.PravegaCluster , sts * appsv1.StatefulSet ) bool {
586
586
if r .IsClusterRollbackingFrom07 (p ) && sts .Status .ReadyReplicas == * sts .Spec .Replicas {
587
587
return true
588
588
}
589
589
return false
590
590
}
591
591
592
- //this function will check if furter increment or decrement in pods needed in case of upgrade to version 0.7 or above
592
+ // this function will check if furter increment or decrement in pods needed in case of upgrade to version 0.7 or above
593
593
func (r * PravegaClusterReconciler ) upgradeConditionFor07 (p * pravegav1beta1.PravegaCluster , newsts * appsv1.StatefulSet , oldsts * appsv1.StatefulSet ) bool {
594
594
if oldsts .Status .ReadyReplicas + newsts .Status .ReadyReplicas == p .Spec .Pravega .SegmentStoreReplicas && newsts .Status .ReadyReplicas == * newsts .Spec .Replicas {
595
595
return true
596
596
}
597
597
return false
598
598
}
599
599
600
- //this function will increase two replicas of the new sts and delete 2 replicas of the old sts everytime it's called
600
+ // this function will increase two replicas of the new sts and delete 2 replicas of the old sts everytime it's called
601
601
func (r * PravegaClusterReconciler ) scaleSegmentStoreSTS (p * pravegav1beta1.PravegaCluster , newsts * appsv1.StatefulSet , oldsts * appsv1.StatefulSet ) error {
602
602
* newsts .Spec .Replicas = * newsts .Spec .Replicas + 2
603
603
err := r .Client .Update (context .TODO (), newsts )
@@ -612,7 +612,7 @@ func (r *PravegaClusterReconciler) scaleSegmentStoreSTS(p *pravegav1beta1.Praveg
612
612
return nil
613
613
}
614
614
615
- //This function will remove the pvc's attached with the old sts and deleted it when old sts replicas have become 0
615
+ // This function will remove the pvc's attached with the old sts and deleted it when old sts replicas have become 0
616
616
func (r * PravegaClusterReconciler ) transitionToNewSTS (p * pravegav1beta1.PravegaCluster , newsts * appsv1.StatefulSet , oldsts * appsv1.StatefulSet ) error {
617
617
* newsts .Spec .Replicas = p .Spec .Pravega .SegmentStoreReplicas
618
618
err := r .Client .Update (context .TODO (), newsts )
0 commit comments