if dd.service_name() in self.spec_store.specs:
sm[n].size = self._get_spec_size(spec)
sm[n].created = self.spec_store.spec_created[dd.service_name()]
+ if service_type == 'nfs':
+ spec = cast(NFSServiceSpec, spec)
+ sm[n].rados_config_location = spec.rados_config_location()
else:
sm[n].size = 0
if dd.status == 1:
size=self._get_spec_size(spec),
running=0,
)
+ if service_type == 'nfs':
+ spec = cast(NFSServiceSpec, spec)
+ sm[n].rados_config_location = spec.rados_config_location()
return list(sm.values())
@trivial_completion
# type: () -> str
return '%s.%s' % (self.spec.service_type, self.daemon_id)
- def get_rados_config_name(self):
- # type: () -> str
- return 'conf-' + self.spec.service_name()
-
- def get_rados_config_url(self):
- # type: () -> str
- url = 'rados://' + self.spec.pool + '/'
- if self.spec.namespace:
- url += self.spec.namespace + '/'
- url += self.get_rados_config_name()
- return url
-
def get_keyring_entity(self):
# type: () -> str
return utils.name_to_config_section(self.get_rados_user())
def create_rados_config_obj(self, clobber=False):
# type: (Optional[bool]) -> None
- obj = self.get_rados_config_name()
+ obj = self.spec.rados_config_name()
with self.mgr.rados.open_ioctx(self.spec.pool) as ioctx:
if self.spec.namespace:
%url {url}
'''.format(user=self.get_rados_user(),
- url=self.get_rados_config_url())
+ url=self.spec.rados_config_location())
def get_cephadm_config(self):
# type: () -> Dict
if not self.pool:
raise ServiceSpecValidationError('Cannot add NFS: No Pool specified')
+ def rados_config_name(self):
+ # type: () -> str
+ return 'conf-' + self.service_name()
+
+ def rados_config_location(self):
+ # type: () -> str
+ url = 'rados://' + self.pool + '/'
+ if self.namespace:
+ url += self.namespace + '/'
+ url += self.rados_config_name()
+ return url
+
class RGWSpec(ServiceSpec):
"""