Method: OpenC3::MetricModel.redis_metrics

Defined in:
lib/openc3/models/metric_model.rb

.redis_metricsObject



81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
# File 'lib/openc3/models/metric_model.rb', line 81

def self.redis_metrics
  result = {}

  metrics = OpenC3::Store.info("all")
  result['redis_connected_clients_total'] = metrics['connected_clients']
  result['redis_used_memory_rss_total'] = metrics['used_memory_rss']
  result['redis_commands_processed_total'] = metrics['total_commands_processed']
  result['redis_iops'] = metrics['instantaneous_ops_per_sec']
  result['redis_instantaneous_input_kbps'] = metrics['instantaneous_input_kbps']
  result['redis_instantaneous_output_kbps'] = metrics['instantaneous_output_kbps']
  result['redis_hget_p50_seconds'], result['redis_hget_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_hget'])
  result['redis_hgetall_p50_seconds'], result['redis_hgetall_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_hgetall'])
  result['redis_hset_p50_seconds'], result['redis_hset_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_hset'])
  result['redis_xadd_p50_seconds'], result['redis_xadd_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_xadd'])
  result['redis_xread_p50_seconds'], result['redis_xread_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_xread'])
  result['redis_xrevrange_p50_seconds'], result['redis_xrevrange_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_xrevrange'])
  result['redis_xtrim_p50_seconds'], result['redis_xtrim_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_xtrim'])

  metrics = OpenC3::EphemeralStore.info("all")
  result['redis_ephemeral_connected_clients_total'] = metrics['connected_clients']
  result['redis_ephemeral_used_memory_rss_total'] = metrics['used_memory_rss']
  result['redis_ephemeral_commands_processed_total'] = metrics['total_commands_processed']
  result['redis_ephemeral_iops'] = metrics['instantaneous_ops_per_sec']
  result['redis_ephemeral_instantaneous_input_kbps'] = metrics['instantaneous_input_kbps']
  result['redis_ephemeral_instantaneous_output_kbps'] = metrics['instantaneous_output_kbps']
  result['redis_ephemeral_hget_p50_seconds'], result['redis_ephemeral_hget_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_hget'])
  result['redis_ephemeral_hgetall_p50_seconds'], result['redis_ephemeral_hgetall_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_hgetall'])
  result['redis_ephemeral_hset_p50_seconds'], result['redis_ephemeral_hset_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_hset'])
  result['redis_ephemeral_xadd_p50_seconds'], result['redis_ephemeral_xadd_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_xadd'])
  result['redis_ephemeral_xread_p50_seconds'], result['redis_ephemeral_xread_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_xread'])
  result['redis_ephemeral_xrevrange_p50_seconds'], result['redis_ephemeral_xrevrange_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_xrevrange'])
  result['redis_ephemeral_xtrim_p50_seconds'], result['redis_ephemeral_xtrim_p99_seconds'] = redis_extract_p50_and_p99_seconds(metrics['latency_percentiles_usec_xtrim'])

  return result
end