log = logging.getLogger(__name__)
+
def available_clusters(mgr):
'''
This method returns list of available cluster ids.
ret, out, err = self.mgr.check_mon_command({
'prefix': 'auth get-or-create',
'entity': 'client.{}'.format(entity),
- 'caps' : ['mon', 'allow r', 'osd', osd_cap, 'mds', 'allow rw path={}'.format(path)],
+ 'caps': ['mon', 'allow r', 'osd', osd_cap, 'mds', 'allow rw path={}'.format(path)],
'format': 'json',
})
raw_config = obj.read(size)
raw_config = raw_config.decode("utf-8")
log.debug("read export configuration from rados "
- "object %s/%s/%s:\n%s", self.rados_pool,
- rados_namespace, obj.key, raw_config)
+ "object %s/%s/%s:\n%s", self.rados_pool,
+ rados_namespace, obj.key, raw_config)
self.export_conf_objs.append(Export.from_export_block(
GaneshaConfParser(raw_config).parse()[0], rados_namespace))
common_conf = 'conf-nfs.ganesha-{}'.format(cluster_id)
conf_blocks = {
'block_name': '%url',
- 'value': self._make_rados_url(
- 'export-{}'.format(ex_id))
+ 'value': self._make_rados_url('export-{}'.format(ex_id))
}
self._write_raw_config(conf_blocks, common_conf, True)
'cluster_id': cluster_id,
'access_type': access_type,
'fsal': {"name": "CEPH", "user_id": user_id,
- "fs_name": fs_name, "sec_label_xattr": ""},
+ "fs_name": fs_name, "sec_label_xattr": ""},
'clients': []
}
export = Export.from_dict(ex_id, ex_dict)
log.info(f"Pool Status: {out}")
self.mgr.check_mon_command({'prefix': 'osd pool application enable',
- 'pool': self.pool_name, 'app': 'nfs'})
+ 'pool': self.pool_name, 'app': 'nfs'})
self.create_empty_rados_obj()