return self._rados
- def get_localized_config(self, key):
- r = self.get_config(self.get_mgr_id() + '/' + key)
- if r is None:
- r = self.get_config(key)
- return r
-
def update_pool_stats(self):
df = global_instance().get("df")
pool_stats = dict([(p['id'], p['stats']) for p in df['pools']])
"""
return ceph_state.get_config_prefix(self._handle, key_prefix)
+ def get_localized_config(self, key, default=None):
+ """
+ Retrieve localized configuration for this ceph-mgr instance
+ :param key: str
+ :param default: str
+ :return: str
+ """
+ r = self.get_config(self.get_mgr_id() + '/' + key)
+ if r is None:
+ r = self.get_config(key)
+
+ if r is None:
+ r = default
+ return r
+
def set_config(self, key, val):
"""
Set the value of a persistent configuration setting
"""
ceph_state.set_config(self._handle, key, val)
+ def set_localized_config(self, key, val):
+ """
+ Set localized configuration for this ceph-mgr instance
+ :param key: str
+ :param default: str
+ :return: str
+ """
+ return self.set_config(self.get_mgr_id() + '/' + key, val)
+
def set_config_json(self, key, val):
"""
Helper for setting json-serialized-config
return None
else:
return json.loads(raw)
+
self.serve_event.wait()
self.serve_event.clear()
- def get_localized_config(self, key):
- r = self.get_config(self.get_mgr_id() + '/' + key)
- if r is None:
- r = self.get_config(key)
- return r
-
def refresh_keys(self):
self.keys = {}
rawkeys = self.get_config_prefix('keys/') or {}