Log prometheus queries (#1417)

pluralsh · Sep 26, 2024 · f676ad2 · f676ad2
1 parent eb8d62d
commit f676ad2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/lib/console/deployments/observability.ex b/lib/console/deployments/observability.ex
@@ -76,9 +76,9 @@ defmodule Console.Deployments.Observability do
   end
 
   defp component_args(%ServiceComponent{group: "apps", version: "v1", kind: "Deployment", name: name, namespace: ns} = comp),
-    do: {:ok, %{name: name, namespace: ns, cluster: comp.service.cluster.handle, regex: "-[a-z0-9]+-[a-z0-9]+"}}
+    do: {:ok, [namespace: ns, name: name, cluster: comp.service.cluster.handle, regex: "-[a-z0-9]+-[a-z0-9]+"]}
   defp component_args(%ServiceComponent{group: "apps", version: "v1", kind: "StatefulSet", name: name, namespace: ns} = comp),
-    do: {:ok, %{name: name, namespace: ns, cluster: comp.service.cluster.handle, regex: "-[0-9]+"}}
+    do: {:ok, [namespace: ns, name: name, cluster: comp.service.cluster.handle, regex: "-[0-9]+"]}
   defp component_args(%ServiceComponent{group: g, kind: k}), do: {:error, "unsupported component kind #{g}/#{k}"}
 
   defp bulk_query(queries, ctx, start, stop, step) do

diff --git a/lib/prometheus/client.ex b/lib/prometheus/client.ex
@@ -1,6 +1,7 @@
 defmodule Prometheus.Client do
   alias Console.Schema.DeploymentSettings.Connection
   alias Prometheus.{Response, Data, Result}
+  require Logger
   @headers [{"content-type", "application/x-www-form-urlencoded"}]
 
   defstruct [:host, :user, :password]
@@ -17,6 +18,7 @@ defmodule Prometheus.Client do
 
   def query(client \\ nil, query, start, end_t, step, variables) do
     query = variable_subst(query, variables)
+    Logger.info "Issuing prometheus query: #{query}"
     HTTPoison.post(
       Path.join(host(client), "/api/v1/query_range"),
       {:form, [