diff --git a/lib/gat/handlers/discovery/module.go b/lib/gat/handlers/discovery/module.go index 610ce755bcc6d74a0f22f6df81f68dec7e67ffc9..b3d85f293c02fa3071272ec1c5d57cf4bf90e3d4 100644 --- a/lib/gat/handlers/discovery/module.go +++ b/lib/gat/handlers/discovery/module.go @@ -154,13 +154,7 @@ func (T *Module) updated(prev, next Cluster) { // change # of replicas for id, nextReplica := range next.Replicas { - prevReplica, ok := prev.Replicas[id] - if !ok { - T.addReplica(prev.Users, prev.Databases, id, nextReplica) - } else if prevReplica != nextReplica { - T.removeReplica(prev.Users, prev.Databases, id) - T.addReplica(prev.Users, prev.Databases, id, nextReplica) - } + T.addReplica(prev.Users, prev.Databases, id, nextReplica) } for id := range prev.Replicas { _, ok := next.Replicas[id]