Retrieve metrics from all nodes in the cluster

upmaru · Nov 1, 2024 · 64c91e1 · 64c91e1
1 parent 3cb097a
commit 64c91e1
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 3 deletions.
diff --git a/lib/uplink/clients/lxd/metric/manager.ex b/lib/uplink/clients/lxd/metric/manager.ex
@@ -1,9 +1,11 @@
 defmodule Uplink.Clients.LXD.Metric.Manager do
   alias Uplink.Clients.LXD
 
-  def list(_options \\ []) do
+  def list(options \\ []) do
+    target = Keyword.get(options, :target, nil)
+
     LXD.client()
-    |> Lexdee.list_metrics()
+    |> Lexdee.list_metrics(query: [target: target])
     |> case do
       {:ok, %{body: raw_metrics}} ->
         raw_metrics

diff --git a/lib/uplink/metrics/instance.ex b/lib/uplink/metrics/instance.ex
@@ -6,7 +6,14 @@ defmodule Uplink.Metrics.Instance do
 
   def metrics do
     instances = LXD.list_instances(recursion: 2)
-    metrics = LXD.list_metrics()
+
+    cluster_members = LXD.list_cluster_members()
+
+    metrics =
+      Enum.flat_map(cluster_members, fn cluster_member ->
+        LXD.list_metrics(target: cluster_member.server_name)
+      end)
+
     %{"organization" => %{"slug" => account_id}} = Instellar.get_self()
 
     metrics =