@@ -199,6 +199,15 @@ def _wait_for_group_id(self):
199
199
self .logger .info ("The MonitorGroup gRPC server stopped..." )
200
200
self .monitor_server = None
201
201
202
+ def start_prometheus (self ):
203
+ ###Starts the prometheus endpoint if enabled by the config.###
204
+
205
+ if self .config .getboolean_with_default ("gateway" , "enable_prometheus_exporter" , True ):
206
+ self .logger .info ("Prometheus endpoint is enabled" )
207
+ start_exporter (self .spdk_rpc_client , self .config , self .gateway_rpc , self .logger )
208
+ else :
209
+ self .logger .info (f"Prometheus endpoint is disabled. To enable, set the config option 'enable_prometheus_exporter = True'" )
210
+
202
211
def serve (self ):
203
212
"""Starts gateway server."""
204
213
self .logger .info (f"Starting serve, monitor client version: { self ._monitor_client_version ()} " )
@@ -238,13 +247,6 @@ def serve(self):
238
247
# Start server
239
248
self .server .start ()
240
249
241
- # Start the prometheus endpoint if enabled by the config
242
- if self .config .getboolean_with_default ("gateway" , "enable_prometheus_exporter" , True ):
243
- self .logger .info ("Prometheus endpoint is enabled" )
244
- start_exporter (self .spdk_rpc_client , self .config , self .gateway_rpc , self .logger )
245
- else :
246
- self .logger .info (f"Prometheus endpoint is disabled. To enable, set the config option 'enable_prometheus_exporter = True'" )
247
-
248
250
# Set SPDK log level
249
251
log_level_args = {}
250
252
log_level = self .config .get_with_default ("spdk" , "log_level" , None )
@@ -255,6 +257,9 @@ def serve(self):
255
257
256
258
self ._register_service_map ()
257
259
260
+ # This should be at the end of the function, after the server is up
261
+ self .start_prometheus ()
262
+
258
263
def _register_service_map (self ):
259
264
# show gateway in "ceph status" output
260
265
conn = self .omap_state .conn
0 commit comments