'orchestrator mds update',
"name=fs_name,type=CephString "
"name=num,type=CephInt,req=false "
- "name=hosts,type=CephString,n=N,req=false "
"name=label,type=CephString,req=false",
+ "name=hosts,type=CephString,n=N,req=false "
'Update the number of MDS instances for the given fs_name')
- def _mds_update(self, fs_name, num=None, hosts=[], label=None):
+ def _mds_update(self, fs_name, num=None, label=None, hosts=[]):
placement = orchestrator.PlacementSpec(label=label, count=num, nodes=hosts)
placement.validate()
'NFS', name, lambda: self.rook_cluster.rm_service('cephnfses', name)
)
- def update_mons(self, num, hosts):
- if hosts:
+ def update_mons(self, spec):
+ if spec.placement.nodes:
raise RuntimeError("Host list is not supported by rook.")
return write_completion(
- lambda: self.rook_cluster.update_mon_count(num),
- "Updating mon count to {0}".format(num),
+ lambda: self.rook_cluster.update_mon_count(spec.placement.count),
+ "Updating mon count to {0}".format(spec.placement.count),
mgr=self
)