redis_ipc_metrics_saving_client.MetricsSavingApp Class Reference

Public Member Functions
	__init__ (self)
None	graceful_shutdown (self)
None	handle_redis_pubsub (self, MetricsCollectorConfig config)
None	handle_logs (self)
None	handle_redis_command_queue (self, MetricsCollectorConfig config)
None	keyboard_monitor (self)
int	run (self)

Public Attributes
	physiology_client = None
MetricsCollector	collector = None
bool	recording = False
bool	continue_running = True
list	tasks = []
int	message_count = 0

Detailed Description

Application that collects metrics from Redis and controls the physiology server.

Member Function Documentation

graceful_shutdown()

None redis_ipc_metrics_saving_client.MetricsSavingApp.graceful_shutdown

(

self

)

Clean shutdown of all resources.

handle_logs()

None redis_ipc_metrics_saving_client.MetricsSavingApp.handle_logs

(

self

)

Handle log streaming via gRPC.

handle_redis_command_queue()

None redis_ipc_metrics_saving_client.MetricsSavingApp.handle_redis_command_queue	(		self,
		MetricsCollectorConfig	config )

Monitor Redis command queue for UI commands (async).

handle_redis_pubsub()

None redis_ipc_metrics_saving_client.MetricsSavingApp.handle_redis_pubsub	(		self,
		MetricsCollectorConfig	config )

Handle Redis pub/sub messages and feed them to the collector.

keyboard_monitor()

None redis_ipc_metrics_saving_client.MetricsSavingApp.keyboard_monitor

(

self

)

Monitor for keyboard input.

run()

int redis_ipc_metrics_saving_client.MetricsSavingApp.run

(

self

)

Main entry point.

---

The documentation for this class was generated from the following file:

• on_prem/samples/redis_ipc_metrics_saving_client.py