Uncomment scaling up/down.
This commit is contained in:
parent
77db11e084
commit
22ec987094
|
|
@ -160,9 +160,9 @@ func (z *SpiloSupervisor) spiloUpdate(old, cur interface{}) {
|
||||||
oldSpilo := old.(*Spilo)
|
oldSpilo := old.(*Spilo)
|
||||||
curSpilo := cur.(*Spilo)
|
curSpilo := cur.(*Spilo)
|
||||||
|
|
||||||
//if oldSpilo.Spec.NumberOfInstances != curSpilo.Spec.NumberOfInstances {
|
if oldSpilo.Spec.NumberOfInstances != curSpilo.Spec.NumberOfInstances {
|
||||||
// z.UpdateStatefulSet(curSpilo)
|
z.UpdateStatefulSet(curSpilo)
|
||||||
//}
|
}
|
||||||
|
|
||||||
if oldSpilo.Spec.DockerImage != curSpilo.Spec.DockerImage {
|
if oldSpilo.Spec.DockerImage != curSpilo.Spec.DockerImage {
|
||||||
log.Printf("Updating DockerImage: %s.%s",
|
log.Printf("Updating DockerImage: %s.%s",
|
||||||
|
|
@ -172,7 +172,7 @@ func (z *SpiloSupervisor) spiloUpdate(old, cur interface{}) {
|
||||||
z.UpdateStatefulSetImage(curSpilo)
|
z.UpdateStatefulSetImage(curSpilo)
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Printf("Update spilo old: %+v cur: %+v", *oldSpilo, *curSpilo)
|
log.Printf("Update spilo old: %+v\ncurrent: %+v", *oldSpilo, *curSpilo)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (z *SpiloSupervisor) spiloDelete(obj interface{}) {
|
func (z *SpiloSupervisor) spiloDelete(obj interface{}) {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue