Commit b29cdb5b authored by Matthias Kaeppler's avatar Matthias Kaeppler

Change node memory query to use `max`

The metric name was changed in Omnibus to reflect
that we now take the max, not avg.

Also rename helper to indicate that we don't always take
the average anymore.
parent 3c6ee540
...@@ -51,7 +51,7 @@ module Gitlab ...@@ -51,7 +51,7 @@ module Gitlab
def topology_app_requests_per_hour(client) def topology_app_requests_per_hour(client)
result = query_safely('gitlab_usage_ping:ops:rate5m', 'app_requests', fallback: nil) do |query| result = query_safely('gitlab_usage_ping:ops:rate5m', 'app_requests', fallback: nil) do |query|
client.query(one_week_average(query)).first client.query(aggregate_one_week(query)).first
end end
return unless result return unless result
...@@ -84,14 +84,14 @@ module Gitlab ...@@ -84,14 +84,14 @@ module Gitlab
end end
def topology_node_memory(client) def topology_node_memory(client)
query_safely('gitlab_usage_ping:node_memory_total_bytes:avg', 'node_memory', fallback: {}) do |query| query_safely('gitlab_usage_ping:node_memory_total_bytes:max', 'node_memory', fallback: {}) do |query|
aggregate_by_instance(client, one_week_average(query)) aggregate_by_instance(client, aggregate_one_week(query, aggregation: :max))
end end
end end
def topology_node_cpus(client) def topology_node_cpus(client)
query_safely('gitlab_usage_ping:node_cpus:count', 'node_cpus', fallback: {}) do |query| query_safely('gitlab_usage_ping:node_cpus:count', 'node_cpus', fallback: {}) do |query|
aggregate_by_instance(client, one_week_average(query, aggregation: :max)) aggregate_by_instance(client, aggregate_one_week(query, aggregation: :max))
end end
end end
...@@ -114,25 +114,25 @@ module Gitlab ...@@ -114,25 +114,25 @@ module Gitlab
def topology_service_memory_rss(client) def topology_service_memory_rss(client)
query_safely( query_safely(
'gitlab_usage_ping:node_service_process_resident_memory_bytes:avg', 'service_rss', fallback: {} 'gitlab_usage_ping:node_service_process_resident_memory_bytes:avg', 'service_rss', fallback: {}
) { |query| aggregate_by_labels(client, one_week_average(query)) } ) { |query| aggregate_by_labels(client, aggregate_one_week(query)) }
end end
def topology_service_memory_uss(client) def topology_service_memory_uss(client)
query_safely( query_safely(
'gitlab_usage_ping:node_service_process_unique_memory_bytes:avg', 'service_uss', fallback: {} 'gitlab_usage_ping:node_service_process_unique_memory_bytes:avg', 'service_uss', fallback: {}
) { |query| aggregate_by_labels(client, one_week_average(query)) } ) { |query| aggregate_by_labels(client, aggregate_one_week(query)) }
end end
def topology_service_memory_pss(client) def topology_service_memory_pss(client)
query_safely( query_safely(
'gitlab_usage_ping:node_service_process_proportional_memory_bytes:avg', 'service_pss', fallback: {} 'gitlab_usage_ping:node_service_process_proportional_memory_bytes:avg', 'service_pss', fallback: {}
) { |query| aggregate_by_labels(client, one_week_average(query)) } ) { |query| aggregate_by_labels(client, aggregate_one_week(query)) }
end end
def topology_all_service_process_count(client) def topology_all_service_process_count(client)
query_safely( query_safely(
'gitlab_usage_ping:node_service_process:count', 'service_process_count', fallback: {} 'gitlab_usage_ping:node_service_process:count', 'service_process_count', fallback: {}
) { |query| aggregate_by_labels(client, one_week_average(query)) } ) { |query| aggregate_by_labels(client, aggregate_one_week(query)) }
end end
def topology_all_service_server_types(client) def topology_all_service_server_types(client)
...@@ -228,7 +228,7 @@ module Gitlab ...@@ -228,7 +228,7 @@ module Gitlab
end end
end end
def one_week_average(query, aggregation: :avg) def aggregate_one_week(query, aggregation: :avg)
"#{aggregation}_over_time (#{query}[1w])" "#{aggregation}_over_time (#{query}[1w])"
end end
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment