"kWpZ2ypBDH45h2o3LyqvGjsu/BFkeG6JpEDCWbClKWcjKxOrLVDufhSDduffDjja",
"zOsgQJg0Yf//Ubb5p0c54GjHM/XDXEcV3m3sEtbmMYz6xGwuag4bx8P2E/QY8sFp",
"JxgIdS8vdl6YhDCjKJ2XzI30JwCdftgDIAiWSE0ivoDc+8+gG1nb11GT52HFzA==",
- "-----END CERTIFICATE-----"
- ],
- "rgw_frontend_ssl_key": [
+ "-----END CERTIFICATE-----",
"-----BEGIN PRIVATE KEY-----",
"MIIJQwIBADANBgkqhkiG9w0BAQEFAASCCS0wggkpAgEAAoICAQDKbRiedt0JBG3N",
"+82vIrgk2oY9Ga+ocvk6El/1X3c8Y4mB7g9j4mWciQe7dnjqogPLEOTeddxFLX9m",
% spec.rgw_frontend_ssl_certificate)
ret, out, err = self.mgr.check_mon_command({
'prefix': 'config-key set',
- 'key': f'rgw/cert/{spec.service_name()}.crt',
+ 'key': f'rgw/cert/{spec.service_name()}.crt', # NOTE: actually a .pem!
'val': cert_data,
})
- if spec.rgw_frontend_ssl_key:
- if isinstance(spec.rgw_frontend_ssl_key, list):
- key_data = '\n'.join(spec.rgw_frontend_ssl_key)
- elif isinstance(spec.rgw_frontend_ssl_certificate, str):
- key_data = spec.rgw_frontend_ssl_key
- else:
- raise OrchestratorError(
- 'Invalid rgw_frontend_ssl_key: %s'
- % spec.rgw_frontend_ssl_key)
- ret, out, err = self.mgr.check_mon_command({
- 'prefix': 'config-key set',
- 'key': f'rgw/cert/{spec.service_name()}.key',
- 'val': key_data,
- })
-
# TODO: fail, if we don't have a spec
logger.info('Saving service %s spec with placement %s' % (
spec.service_name(), spec.placement.pretty_str()))
if spec.ssl:
args.append(f"ssl_port={daemon_spec.ports[0]}")
args.append(f"ssl_certificate=config://rgw/cert/{spec.service_name()}.crt")
- args.append(f"ssl_private_key=config://rgw/cert/{spec.service_name()}.key")
else:
args.append(f"port={daemon_spec.ports[0]}")
frontend = f'beast {" ".join(args)}'
rgw_zone: Optional[str] = None,
rgw_frontend_port: Optional[int] = None,
rgw_frontend_ssl_certificate: Optional[List[str]] = None,
- rgw_frontend_ssl_key: Optional[List[str]] = None,
unmanaged: bool = False,
ssl: bool = False,
preview_only: bool = False,
self.rgw_zone = rgw_zone
self.rgw_frontend_port = rgw_frontend_port
self.rgw_frontend_ssl_certificate = rgw_frontend_ssl_certificate
- self.rgw_frontend_ssl_key = rgw_frontend_ssl_key
self.ssl = ssl
def get_port_start(self) -> Optional[int]: