@@ -518,6 +518,11 @@ defmodule DeployexWeb.ObserverLive do
trigger: "item",
triggerOn: "mousemove"
},
+ toolbox: %{
+ feature: %{
+ saveAsImage: %{}
+ }
+ },
notMerge: true,
legend: [
%{
diff --git a/lib/deployex_web/router.ex b/lib/deployex_web/router.ex
index 1ca47ec..c115179 100644
--- a/lib/deployex_web/router.ex
+++ b/lib/deployex_web/router.ex
@@ -53,6 +53,7 @@ defmodule DeployexWeb.Router do
live "/applications/:instance/terminal", ApplicationsLive, :terminal
live "/applications/:instance/versions", ApplicationsLive, :versions
live "/applications/:instance/restart", ApplicationsLive, :restart
+ live "/metrics", MetricsLive, :index
end
end
diff --git a/lib/deployex_web/telemetry.ex b/lib/deployex_web/telemetry.ex
index cfe2a66..27aa970 100644
--- a/lib/deployex_web/telemetry.ex
+++ b/lib/deployex_web/telemetry.ex
@@ -11,9 +11,9 @@ defmodule DeployexWeb.Telemetry do
children = [
# Telemetry poller will execute the given period measurements
# every 10_000ms. Learn more here: https://hexdocs.pm/telemetry_metrics
- {:telemetry_poller, measurements: periodic_measurements(), period: 10_000}
+ {:telemetry_poller, measurements: periodic_measurements(), period: 10_000},
# Add reporters as children of your supervision tree.
- # {Telemetry.Metrics.ConsoleReporter, metrics: metrics()}
+ {TelemetryDeployex, metrics: metrics()}
]
Supervisor.init(children, strategy: :one_for_one)
diff --git a/mix.exs b/mix.exs
index 1af855b..0ac5a0f 100644
--- a/mix.exs
+++ b/mix.exs
@@ -4,7 +4,7 @@ defmodule Deployex.MixProject do
def project do
[
app: :deployex,
- version: "0.3.0",
+ version: "0.4.0-metric",
elixir: "~> 1.15",
name: "DeployEx",
source_url: "https://github.com/thiagoesteves/deployex",
@@ -134,6 +134,8 @@ defmodule Deployex.MixProject do
{:ex_aws, "~> 2.1"},
{:ex_aws_s3, "~> 2.0"},
{:hackney, "~> 1.9"},
+ {:goth, "~> 1.4"},
+ {:telemetry_deployex, "~> 0.1.0-rc4"},
{:credo, "~> 1.7", only: [:dev, :test], runtime: false},
{:mix_audit, "~> 2.1", only: [:dev, :test], runtime: false},
{:sobelow, "~> 0.13", only: [:dev, :test], runtime: false},
@@ -141,8 +143,7 @@ defmodule Deployex.MixProject do
{:ex_doc, "~> 0.34", only: [:dev, :test], runtime: false},
{:mox, "~> 1.0", only: :test},
{:excoveralls, "~> 0.18", only: :test},
- {:mock, "~> 0.3.0", only: :test},
- {:goth, "~> 1.4"}
+ {:mock, "~> 0.3.0", only: :test}
]
end
diff --git a/mix.lock b/mix.lock
index 370dbd9..2868c73 100644
--- a/mix.lock
+++ b/mix.lock
@@ -61,7 +61,8 @@
"swoosh": {:hex, :swoosh, "1.17.3", "5cda7bff6bc1121cc5b58db8ed90ef33261b373425ae3e32dd599688037a0482", [:mix], [{:bandit, ">= 1.0.0", [hex: :bandit, repo: "hexpm", optional: true]}, {:cowboy, "~> 1.1 or ~> 2.4", [hex: :cowboy, repo: "hexpm", optional: true]}, {:ex_aws, "~> 2.1", [hex: :ex_aws, repo: "hexpm", optional: true]}, {:finch, "~> 0.6", [hex: :finch, repo: "hexpm", optional: true]}, {:gen_smtp, "~> 0.13 or ~> 1.0", [hex: :gen_smtp, repo: "hexpm", optional: true]}, {:hackney, "~> 1.9", [hex: :hackney, repo: "hexpm", optional: true]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}, {:mail, "~> 0.2", [hex: :mail, repo: "hexpm", optional: true]}, {:mime, "~> 1.1 or ~> 2.0", [hex: :mime, repo: "hexpm", optional: false]}, {:mua, "~> 0.2.3", [hex: :mua, repo: "hexpm", optional: true]}, {:multipart, "~> 0.4", [hex: :multipart, repo: "hexpm", optional: true]}, {:plug, "~> 1.9", [hex: :plug, repo: "hexpm", optional: true]}, {:plug_cowboy, ">= 1.0.0", [hex: :plug_cowboy, repo: "hexpm", optional: true]}, {:req, "~> 0.5 or ~> 1.0", [hex: :req, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4.2 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "14ad57cfbb70af57323e17f569f5840a33c01f8ebc531dd3846beef3c9c95e55"},
"tailwind": {:hex, :tailwind, "0.2.4", "5706ec47182d4e7045901302bf3a333e80f3d1af65c442ba9a9eed152fb26c2e", [:mix], [{:castore, ">= 0.0.0", [hex: :castore, repo: "hexpm", optional: false]}], "hexpm", "c6e4a82b8727bab593700c998a4d98cf3d8025678bfde059aed71d0000c3e463"},
"telemetry": {:hex, :telemetry, "1.3.0", "fedebbae410d715cf8e7062c96a1ef32ec22e764197f70cda73d82778d61e7a2", [:rebar3], [], "hexpm", "7015fc8919dbe63764f4b4b87a95b7c0996bd539e0d499be6ec9d7f3875b79e6"},
- "telemetry_metrics": {:hex, :telemetry_metrics, "1.0.0", "29f5f84991ca98b8eb02fc208b2e6de7c95f8bb2294ef244a176675adc7775df", [:mix], [{:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "f23713b3847286a534e005126d4c959ebcca68ae9582118ce436b521d1d47d5d"},
+ "telemetry_deployex": {:hex, :telemetry_deployex, "0.1.0-rc4", "27910a94778999e8af3cdc8719e102f4da573df702fb562b94adff045d641abf", [:mix], [{:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}, {:telemetry_metrics, "~> 0.6 or ~> 1.0", [hex: :telemetry_metrics, repo: "hexpm", optional: false]}], "hexpm", "e5d5a8a7ba1e345034e414c2274fbc3e2be17d4b76b1e6f283807147669ed65f"},
+ "telemetry_metrics": {:hex, :telemetry_metrics, "1.1.0", "5bd5f3b5637e0abea0426b947e3ce5dd304f8b3bc6617039e2b5a008adc02f8f", [:mix], [{:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "e7b79e8ddfde70adb6db8a6623d1778ec66401f366e9a8f5dd0955c56bc8ce67"},
"telemetry_poller": {:hex, :telemetry_poller, "1.1.0", "58fa7c216257291caaf8d05678c8d01bd45f4bdbc1286838a28c4bb62ef32999", [:rebar3], [{:telemetry, "~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "9eb9d9cbfd81cbd7cdd24682f8711b6e2b691289a0de6826e58452f28c103c8f"},
"thousand_island": {:hex, :thousand_island, "1.3.7", "1da7598c0f4f5f50562c097a3f8af308ded48cd35139f0e6f17d9443e4d0c9c5", [:mix], [{:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "0139335079953de41d381a6134d8b618d53d084f558c734f2662d1a72818dd12"},
"unicode_util_compat": {:hex, :unicode_util_compat, "0.7.0", "bc84380c9ab48177092f43ac89e4dfa2c6d62b40b8bd132b1059ecc7232f9a78", [:rebar3], [], "hexpm", "25eee6d67df61960cf6a794239566599b09e17e668d3700247bc498638152521"},
diff --git a/test/deployex/telemetry_test.exs b/test/deployex/telemetry_test.exs
new file mode 100644
index 0000000..6d2c9a5
--- /dev/null
+++ b/test/deployex/telemetry_test.exs
@@ -0,0 +1,182 @@
+defmodule Deployex.TelemetryTest do
+ use ExUnit.Case, async: false
+
+ import Mock
+
+ alias Deployex.Telemetry.Server, as: TelemetryServer
+ alias Deployex.TelemetryFixtures
+
+ setup do
+ {:ok, hostname} = :inet.gethostname()
+ app_name = "testapp"
+ instance = 1
+
+ assert {:ok, pid} = TelemetryServer.start_link([])
+
+ %{node: :"#{app_name}-#{instance}@#{hostname}", pid: pid}
+ end
+
+ test "[un]subscribe_for_new_keys/0", %{node: node} do
+ TelemetryServer.subscribe_for_new_keys()
+
+ node
+ |> TelemetryFixtures.build_reporter_vm_memory_total()
+ |> TelemetryServer.push_data()
+
+ assert_receive {:metrics_new_keys, ^node, ["vm.memory.total"]}, 1_000
+ end
+
+ test "[un]subscribe_for_new_data/0", %{node: node} do
+ TelemetryServer.subscribe_for_new_data(node, "vm.memory.total")
+
+ node
+ |> TelemetryFixtures.build_reporter_vm_memory_total()
+ |> TelemetryServer.push_data()
+
+ assert_receive {:metrics_new_data, ^node, "vm.memory.total",
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: _, measurements: _}},
+ 1_000
+
+ # Validate by inspection
+ TelemetryServer.unsubscribe_for_new_data(node, "vm.memory.total")
+ end
+
+ test "get_keys_by_instance/1 valid instance", %{node: node} do
+ TelemetryServer.subscribe_for_new_data(node, "vm.memory.total")
+
+ node
+ |> TelemetryFixtures.build_reporter_vm_memory_total()
+ |> TelemetryServer.push_data()
+
+ assert_receive {:metrics_new_data, ^node, "vm.memory.total",
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: _, measurements: _}},
+ 1_000
+
+ assert ["vm.memory.total"] == TelemetryServer.get_keys_by_instance(1)
+ end
+
+ test "get_keys_by_instance/1 invalid instance" do
+ assert [] == TelemetryServer.get_keys_by_instance(1000)
+ end
+
+ test "list_data_by_instance/3", %{node: node} do
+ key_name = "test.phoenix"
+
+ TelemetryServer.subscribe_for_new_data(node, key_name)
+
+ Enum.each(1..5, &TelemetryServer.push_data(build_metric(node, key_name, &1)))
+
+ assert_receive {:metrics_new_data, ^node, ^key_name, %{timestamp: _, unit: _, value: 5}},
+ 1_000
+
+ assert [
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 1, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 2, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 3, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 4, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 5, tags: _}
+ ] = TelemetryServer.list_data_by_instance_key(1, key_name, order: :asc)
+
+ assert [
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 5, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 4, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 3, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 2, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 1, tags: _}
+ ] = TelemetryServer.list_data_by_instance_key(1, key_name, order: :desc)
+ end
+
+ test "list_data_by_instance/1", %{node: node} do
+ key_name = "test.phoenix"
+
+ TelemetryServer.subscribe_for_new_data(node, key_name)
+
+ Enum.each(1..5, &TelemetryServer.push_data(build_metric(node, key_name, &1)))
+
+ assert_receive {:metrics_new_data, ^node, ^key_name, %{timestamp: _, unit: _, value: 5}},
+ 1_000
+
+ assert [_ | _] = TelemetryServer.list_data_by_instance(1)
+ end
+
+ test "list_data_by_node_key/3", %{node: node} do
+ key_name = "test.phoenix"
+
+ TelemetryServer.subscribe_for_new_data(node, key_name)
+
+ Enum.each(1..5, &TelemetryServer.push_data(build_metric(node, key_name, &1)))
+
+ assert_receive {:metrics_new_data, ^node, ^key_name, %{timestamp: _, unit: _, value: 5}},
+ 1_000
+
+ assert [
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 1, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 2, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 3, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 4, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 5, tags: _}
+ ] = TelemetryServer.list_data_by_node_key(node |> to_string(), key_name, order: :asc)
+
+ assert [
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 5, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 4, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 3, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 2, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 1, tags: _}
+ ] = TelemetryServer.list_data_by_node_key(node |> to_string(), key_name, order: :desc)
+
+ assert [
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 1, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 2, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 3, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 4, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 5, tags: _}
+ ] = TelemetryServer.list_data_by_node_key(node |> to_string(), key_name)
+ end
+
+ test "Pruning expiring entries", %{node: node, pid: pid} do
+ key_name = "test.phoenix"
+
+ now = System.os_time(:millisecond)
+
+ TelemetryServer.subscribe_for_new_data(node, key_name)
+
+ with_mock System, os_time: fn _ -> now - 120_000 end do
+ Enum.each(1..5, &TelemetryServer.push_data(build_metric(node, key_name, &1)))
+
+ assert_receive {:metrics_new_data, ^node, ^key_name, %{timestamp: _, unit: _, value: 5}},
+ 1_000
+ end
+
+ assert [
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 1, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 2, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 3, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 4, tags: _},
+ %Deployex.Telemetry.Data{timestamp: _, unit: _, value: 5, tags: _}
+ ] = TelemetryServer.list_data_by_node_key(node |> to_string(), key_name, order: :asc)
+
+ send(pid, :prune_expired_entries)
+ :timer.sleep(100)
+
+ assert [] = TelemetryServer.list_data_by_node_key(node |> to_string(), key_name, order: :asc)
+ end
+
+ defp build_metric(node, name, value) do
+ %{
+ metrics: [
+ %TelemetryDeployex.Metrics{
+ name: name,
+ version: "0.1.0-rc2",
+ value: value,
+ unit: " millisecond",
+ info: "",
+ tags: %{status: 200, method: "GET"},
+ type: "summary"
+ }
+ ],
+ reporter: node,
+ measurements: %{duration: 1_311_711}
+ }
+ end
+end
diff --git a/test/deployex_web/live/metrics/index_test.exs b/test/deployex_web/live/metrics/index_test.exs
new file mode 100644
index 0000000..be93722
--- /dev/null
+++ b/test/deployex_web/live/metrics/index_test.exs
@@ -0,0 +1,159 @@
+defmodule DeployexWeb.Metrics.IndexTest do
+ use DeployexWeb.ConnCase, async: false
+
+ import Phoenix.LiveViewTest
+ import Mox
+
+ alias Deployex.Fixture.Monitoring
+ alias Deployex.Fixture.Status, as: FixtureStatus
+ alias Deployex.TelemetryFixtures
+
+ setup [
+ :set_mox_global,
+ :verify_on_exit!,
+ :log_in_default_user,
+ :node_list
+ ]
+
+ test "GET /applications check buttom", %{conn: conn} do
+ Deployex.StatusMock
+ |> expect(:monitoring, fn -> {:ok, Monitoring.list()} end)
+ |> expect(:subscribe, fn -> :ok end)
+ |> stub(:monitored_app_name, fn -> "testapp" end)
+ |> stub(:monitored_app_lang, fn -> "elixir" end)
+ |> stub(:history_version_list, fn -> FixtureStatus.versions() end)
+
+ {:ok, index_live, _html} = live(conn, ~p"/applications")
+
+ assert index_live
+ |> element("a", "Live Metrics")
+ |> render_click()
+ end
+
+ test "GET /metrics", %{conn: conn, node_list: node_list} do
+ test_pid_process = self()
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> stub(:node_by_instance, fn instance ->
+ if instance == 3, do: send(test_pid_process, {:liveview_pid, self()})
+ node_list[instance]
+ end)
+ |> stub(:get_keys_by_instance, fn _ -> [] end)
+
+ {:ok, _index_live, html} = live(conn, ~p"/metrics")
+
+ assert_receive {:liveview_pid, _liveview_pid}, 1_000
+
+ assert html =~ "Live Metrics"
+ end
+
+ test "GET /metrics + new key", %{conn: conn, node_list: node_list} do
+ test_pid_process = self()
+
+ metric = "fake.phoenix.metric"
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> stub(:node_by_instance, fn instance ->
+ if instance == 3, do: send(test_pid_process, {:liveview_pid, self()})
+ node_list[instance]
+ end)
+ |> stub(:get_keys_by_instance, fn _instance ->
+ # 0, 1, 2, 3: return []
+ # > 3: return [metric]
+ called = Process.get("get_keys_by_instance", 0)
+ Process.put("get_keys_by_instance", called + 1)
+
+ if called > 3 do
+ send(test_pid_process, :added_metric)
+ [metric]
+ else
+ []
+ end
+ end)
+
+ {:ok, liveview, html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ assert_receive {:liveview_pid, liveview_pid}, 1_000
+
+ refute html =~ "#{metric}"
+
+ send(liveview_pid, {:metrics_new_keys, nil, nil})
+
+ assert_receive :added_metric, 1_000
+
+ html = render(liveview)
+
+ assert html =~ "#{metric}"
+ end
+
+ test "GET /metrics + update form", %{conn: conn, node_list: node_list} do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = "vm.memory.total"
+ metric_id = String.replace(metric, ".", "-")
+
+ test_pid_process = self()
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> stub(:list_data_by_node_key, fn ^node, ^metric, _ ->
+ [
+ TelemetryFixtures.build_telemetry_data_vm_total_memory(),
+ TelemetryFixtures.build_telemetry_data_vm_total_memory(),
+ TelemetryFixtures.build_telemetry_data_vm_total_memory()
+ ]
+ end)
+ |> stub(:node_by_instance, fn instance ->
+ if instance == 3, do: send(test_pid_process, {:liveview_pid, self()})
+ node_list[instance]
+ end)
+ |> stub(:get_keys_by_instance, fn _instance -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ assert_receive {:liveview_pid, _liveview_pid}, 1_000
+
+ time = "1 minute"
+
+ liveview
+ |> element("#metrics-update-form")
+ |> render_change(%{num_cols: 1, start_time: time}) =~ time
+
+ time = "5 minutes"
+
+ liveview
+ |> element("#metrics-update-form")
+ |> render_change(%{num_cols: 2, start_time: time}) =~ time
+
+ time = "15 minutes"
+
+ liveview
+ |> element("#metrics-update-form")
+ |> render_change(%{num_cols: 3, start_time: time}) =~ time
+
+ time = "30 minutes"
+
+ liveview
+ |> element("#metrics-update-form")
+ |> render_change(%{num_cols: 4, start_time: time}) =~ time
+ end
+end
diff --git a/test/deployex_web/live/metrics/phoenix_test.exs b/test/deployex_web/live/metrics/phoenix_test.exs
new file mode 100644
index 0000000..9c0c724
--- /dev/null
+++ b/test/deployex_web/live/metrics/phoenix_test.exs
@@ -0,0 +1,282 @@
+defmodule DeployexWeb.Metrics.PhoenixTest do
+ use DeployexWeb.ConnCase, async: false
+
+ import Phoenix.LiveViewTest
+ import Mox
+
+ alias Deployex.TelemetryFixtures
+
+ setup [
+ :set_mox_global,
+ :verify_on_exit!,
+ :log_in_default_user,
+ :node_list
+ ]
+
+ %{
+ 1 => %{metric: "phoenix.endpoint.start.system_time"},
+ 2 => %{metric: "phoenix.endpoint.stop.duration"},
+ 3 => %{metric: "phoenix.router_dispatch.start.system_time"},
+ 4 => %{metric: "phoenix.router_dispatch.exception.duration"},
+ 5 => %{metric: "phoenix.router_dispatch.stop.duration"},
+ 6 => %{metric: "phoenix.socket_connected.duration"},
+ 7 => %{metric: "phoenix.channel_joined.duration"},
+ 8 => %{metric: "phoenix.channel_handled_in.duration"}
+ }
+ |> Enum.each(fn {element, %{metric: metric}} ->
+ test "#{element} - Add/Remove Service + #{metric}", %{conn: conn, node_list: node_list} do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = unquote(metric)
+ metric_id = String.replace(metric, ".", "-")
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:unsubscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ -> [] end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+ end
+ end)
+
+ %{
+ 1 => %{metric: "phoenix.endpoint.start.system_time"},
+ 2 => %{metric: "phoenix.endpoint.start.system_time"},
+ 3 => %{metric: "phoenix.endpoint.stop.duration"},
+ 4 => %{metric: "phoenix.router_dispatch.start.system_time"},
+ 5 => %{metric: "phoenix.router_dispatch.stop.duration"},
+ 6 => %{metric: "phoenix.socket_connected.duration"},
+ 7 => %{metric: "phoenix.channel_joined.duration"}
+ }
+ |> Enum.each(fn {element, %{metric: metric}} ->
+ test "#{element} - #{metric} + Service", %{conn: conn, node_list: node_list} do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = unquote(metric)
+ metric_id = String.replace(metric, ".", "-")
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:unsubscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ -> [] end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-remove-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+ end
+ end)
+
+ %{
+ 1 => %{
+ metric: "phoenix.endpoint.start.system_time",
+ init: 1_737_982_400_400,
+ update: 1_737_982_400_600
+ },
+ 2 => %{
+ metric: "phoenix.router_dispatch.start.system_time",
+ init: 1_737_982_400_400,
+ update: 1_737_982_400_600
+ }
+ }
+ |> Enum.each(fn {element, %{metric: metric, init: init, update: update}} ->
+ test "#{element} - Phoenix Start - Init and Push #{metric}", %{
+ conn: conn,
+ node_list: node_list
+ } do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = unquote(metric)
+ metric_id = String.replace(metric, ".", "-")
+
+ init = unquote(init)
+ update = unquote(update)
+
+ test_pid_process = self()
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric ->
+ send(test_pid_process, {:liveview_pid, self()})
+ :ok
+ end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ ->
+ [
+ TelemetryFixtures.build_telemetry_data(1_737_982_400_500, init)
+ ]
+ end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ assert_receive {:liveview_pid, liveview_pid}, 1_000
+
+ # assert initial data
+ assert html =~ "2025-01-27 12:53:20.500"
+ assert html =~ "2025-01-27 12:53:20.400"
+
+ send(
+ liveview_pid,
+ {:metrics_new_data, node, metric,
+ TelemetryFixtures.build_telemetry_data(1_737_982_400_700, update)}
+ )
+
+ # assert live updated data
+ html = render(liveview)
+ assert html =~ "2025-01-27 12:53:20.700Z"
+ assert html =~ "2025-01-27 12:53:20.600Z"
+ end
+ end)
+
+ %{
+ 1 => %{metric: "phoenix.endpoint.stop.duration", init: 50.0, update: 60.0},
+ 2 => %{metric: "phoenix.router_dispatch.stop.duration", init: 70.0, update: 80.0},
+ 3 => %{metric: "phoenix.router_dispatch.exception.duration", init: 90.0, update: 100.0},
+ 4 => %{metric: "phoenix.socket_connected.duration", init: 110.0, update: 120.0},
+ 5 => %{metric: "phoenix.channel_joined.duration", init: 130.0, update: 140.0},
+ 6 => %{metric: "phoenix.channel_handled_in.duration", init: 150.0, update: 160.0}
+ }
+ |> Enum.each(fn {element, %{metric: metric, init: init, update: update}} ->
+ test "#{element} - Phoenix Duration - Init and Push #{metric}", %{
+ conn: conn,
+ node_list: node_list
+ } do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = unquote(metric)
+ metric_id = String.replace(metric, ".", "-")
+
+ init = unquote(init)
+ update = unquote(update)
+
+ test_pid_process = self()
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric ->
+ send(test_pid_process, {:liveview_pid, self()})
+ :ok
+ end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ ->
+ [
+ TelemetryFixtures.build_telemetry_data(1_737_982_400_666.0, init, " millisecond")
+ ]
+ end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ assert_receive {:liveview_pid, liveview_pid}, 1_000
+
+ # assert initial data
+ assert html =~ "2025-01-27 12:53:20.666"
+ assert html =~ "#{init}"
+
+ send(
+ liveview_pid,
+ {:metrics_new_data, node, metric,
+ TelemetryFixtures.build_telemetry_data(1_737_982_379_777, update)}
+ )
+
+ # assert live updated data
+ html = render(liveview)
+ assert html =~ "2025-01-27 12:52:59.777Z"
+ assert html =~ "#{update}"
+ end
+ end)
+end
diff --git a/test/deployex_web/live/metrics/system_test.exs b/test/deployex_web/live/metrics/system_test.exs
new file mode 100644
index 0000000..541c279
--- /dev/null
+++ b/test/deployex_web/live/metrics/system_test.exs
@@ -0,0 +1,61 @@
+defmodule DeployexWeb.Metrics.SystemTest do
+ use DeployexWeb.ConnCase, async: false
+
+ import Phoenix.LiveViewTest
+ import Mox
+
+ setup [
+ :set_mox_global,
+ :verify_on_exit!,
+ :log_in_default_user,
+ :node_list
+ ]
+
+ test "GET /metrics with system info", %{conn: conn, node_list: node_list} do
+ service = String.replace(node_list[0] |> to_string, "@", "-")
+
+ test_pid_process = self()
+ host = "macOS"
+ description = "15.1.1"
+ total_memory = "64.00"
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> stub(:node_by_instance, fn instance ->
+ if instance == 3, do: send(test_pid_process, {:liveview_pid, self()})
+ node_list[instance]
+ end)
+ |> stub(:get_keys_by_instance, fn _ -> [] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-services-#{service}-add-item")
+ |> render_click()
+
+ assert_receive {:liveview_pid, liveview_pid}, 1_000
+
+ send(
+ liveview_pid,
+ {:update_system_info,
+ %Deployex.System{
+ host: host,
+ description: description,
+ memory_free: 17_201_512_448,
+ memory_total: 68_719_476_736,
+ cpu: 211,
+ cpus: 5
+ }}
+ )
+
+ html = render(liveview)
+
+ assert html =~ host
+ assert html =~ description
+ assert html =~ total_memory
+ end
+end
diff --git a/test/deployex_web/live/metrics/vm_memory_test.exs b/test/deployex_web/live/metrics/vm_memory_test.exs
new file mode 100644
index 0000000..98ae23b
--- /dev/null
+++ b/test/deployex_web/live/metrics/vm_memory_test.exs
@@ -0,0 +1,168 @@
+defmodule DeployexWeb.Metrics.VmMemoryTest do
+ use DeployexWeb.ConnCase, async: false
+
+ import Phoenix.LiveViewTest
+ import Mox
+
+ alias Deployex.TelemetryFixtures
+
+ setup [
+ :set_mox_global,
+ :verify_on_exit!,
+ :log_in_default_user,
+ :node_list
+ ]
+
+ test "Add/Remove Service + vm.memory.total", %{conn: conn, node_list: node_list} do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = "vm.memory.total"
+ metric_id = String.replace(metric, ".", "-")
+ telemetry_data = TelemetryFixtures.build_telemetry_data_vm_total_memory()
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:unsubscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ -> [telemetry_data] end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+ end
+
+ test "Add/Remove vm.memory.total + Service", %{conn: conn, node_list: node_list} do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = "vm.memory.total"
+ metric_id = String.replace(metric, ".", "-")
+ telemetry_data = TelemetryFixtures.build_telemetry_data_vm_total_memory()
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:unsubscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ -> [telemetry_data] end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-remove-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+ end
+
+ test "Init and Push vm.memory.total data", %{conn: conn, node_list: node_list} do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = "vm.memory.total"
+ metric_id = String.replace(metric, ".", "-")
+
+ test_pid_process = self()
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric ->
+ send(test_pid_process, {:liveview_pid, self()})
+ :ok
+ end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ ->
+ [
+ TelemetryFixtures.build_telemetry_data_vm_total_memory(1_737_982_379_123)
+ ]
+ end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ assert_receive {:liveview_pid, liveview_pid}, 1_000
+
+ # assert initial data
+ assert html =~ "2025-01-27 12:52:59.123Z"
+
+ send(
+ liveview_pid,
+ {:metrics_new_data, node, metric,
+ TelemetryFixtures.build_telemetry_data_vm_total_memory(1_737_982_379_456)}
+ )
+
+ # assert live updated data
+ html = render(liveview)
+ assert html =~ "2025-01-27 12:52:59.456Z"
+ end
+end
diff --git a/test/deployex_web/live/metrics/vm_run_queue_test.exs b/test/deployex_web/live/metrics/vm_run_queue_test.exs
new file mode 100644
index 0000000..575a297
--- /dev/null
+++ b/test/deployex_web/live/metrics/vm_run_queue_test.exs
@@ -0,0 +1,195 @@
+defmodule DeployexWeb.Metrics.VmRunQueueTest do
+ use DeployexWeb.ConnCase, async: false
+
+ import Phoenix.LiveViewTest
+ import Mox
+
+ alias Deployex.TelemetryFixtures
+
+ setup [
+ :set_mox_global,
+ :verify_on_exit!,
+ :log_in_default_user,
+ :node_list
+ ]
+
+ %{
+ 1 => %{metric: "vm.total_run_queue_lengths.total"},
+ 2 => %{metric: "vm.total_run_queue_lengths.cpu"},
+ 3 => %{metric: "vm.total_run_queue_lengths.io"}
+ }
+ |> Enum.each(fn {element, %{metric: metric}} ->
+ test "#{element} - Add/Remove Service + #{metric}", %{conn: conn, node_list: node_list} do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = unquote(metric)
+ metric_id = String.replace(metric, ".", "-")
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:unsubscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ -> [] end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+ end
+ end)
+
+ %{
+ 1 => %{metric: "vm.total_run_queue_lengths.total"},
+ 2 => %{metric: "vm.total_run_queue_lengths.cpu"},
+ 3 => %{metric: "vm.total_run_queue_lengths.io"}
+ }
+ |> Enum.each(fn {element, %{metric: metric}} ->
+ test "#{element} - #{metric} + Service", %{conn: conn, node_list: node_list} do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = unquote(metric)
+ metric_id = String.replace(metric, ".", "-")
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:unsubscribe_for_new_data, fn ^node, ^metric -> :ok end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ -> [] end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ assert html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-remove-item")
+ |> render_click()
+
+ assert html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-remove-item")
+ |> render_click()
+
+ refute html =~ "services:#{node}"
+ refute html =~ "metrics:#{metric}"
+ end
+ end)
+
+ %{
+ 1 => %{metric: "vm.total_run_queue_lengths.total", init: 123, update: 456},
+ 2 => %{metric: "vm.total_run_queue_lengths.cpu", init: 789, update: 10_123},
+ 3 => %{metric: "vm.total_run_queue_lengths.io", init: 10_456, update: 10_789}
+ }
+ |> Enum.each(fn {element, %{metric: metric, init: init, update: update}} ->
+ test "#{element} - Phoenix Duration - Init and Push #{metric}", %{
+ conn: conn,
+ node_list: node_list
+ } do
+ node = node_list[1] |> to_string
+ service_id = String.replace(node, "@", "-")
+ metric = unquote(metric)
+ metric_id = String.replace(metric, ".", "-")
+
+ init = unquote(init)
+ update = unquote(update)
+
+ test_pid_process = self()
+
+ Deployex.TelemetryMock
+ |> expect(:subscribe_for_new_keys, fn -> :ok end)
+ |> expect(:subscribe_for_new_data, fn ^node, ^metric ->
+ send(test_pid_process, {:liveview_pid, self()})
+ :ok
+ end)
+ |> expect(:list_data_by_node_key, fn ^node, ^metric, _ ->
+ [
+ TelemetryFixtures.build_telemetry_data(1_737_982_400_666.0, init)
+ ]
+ end)
+ |> stub(:node_by_instance, fn instance -> node_list[instance] end)
+ |> stub(:get_keys_by_instance, fn _ -> [metric] end)
+
+ {:ok, liveview, _html} = live(conn, ~p"/metrics")
+
+ liveview
+ |> element("#metrics-multi-select-toggle-options")
+ |> render_click()
+
+ liveview
+ |> element("#metrics-multi-select-metrics-#{metric_id}-add-item")
+ |> render_click()
+
+ html =
+ liveview
+ |> element("#metrics-multi-select-services-#{service_id}-add-item")
+ |> render_click()
+
+ assert_receive {:liveview_pid, liveview_pid}, 1_000
+
+ # assert initial data
+ assert html =~ "2025-01-27 12:53:20.666"
+ assert html =~ "#{init}"
+
+ send(
+ liveview_pid,
+ {:metrics_new_data, node, metric,
+ TelemetryFixtures.build_telemetry_data(1_737_982_379_777, update)}
+ )
+
+ # assert live updated data
+ html = render(liveview)
+ assert html =~ "2025-01-27 12:52:59.777Z"
+ assert html =~ "#{update}"
+ end
+ end)
+end
diff --git a/test/support/conn_case.ex b/test/support/conn_case.ex
index dc3ce16..29d8715 100644
--- a/test/support/conn_case.ex
+++ b/test/support/conn_case.ex
@@ -49,6 +49,22 @@ defmodule DeployexWeb.ConnCase do
%{conn: log_in_user(conn, user), user: user}
end
+ @doc """
+ Setup helper that sets the node for a monitored application
+
+ setup :node_list
+ """
+ def node_list(params) do
+ {:ok, hostname} = :inet.gethostname()
+
+ Map.put(params, :node_list, %{
+ 0 => Node.self(),
+ 1 => :"testapp-1@#{hostname}",
+ 2 => :"testapp-2@#{hostname}",
+ 3 => :"testapp-3@#{hostname}"
+ })
+ end
+
@doc """
Logs the given `user` into the `conn`.
diff --git a/test/support/fixtures/telemetry.ex b/test/support/fixtures/telemetry.ex
new file mode 100644
index 0000000..bb97846
--- /dev/null
+++ b/test/support/fixtures/telemetry.ex
@@ -0,0 +1,70 @@
+defmodule Deployex.TelemetryFixtures do
+ @moduledoc """
+ This module will handle the telemetry fixture
+ """
+
+ def build_reporter_vm_memory_total(node, value \\ 70_000.0) do
+ %{
+ metrics: [
+ %TelemetryDeployex.Metrics{
+ name: "vm.memory.total",
+ version: "0.1.0-rc3",
+ value: value,
+ unit: " kilobyte",
+ info: "",
+ tags: %{},
+ type: "summary"
+ }
+ ],
+ reporter: node,
+ measurements: %{
+ atom: 999_681,
+ atom_used: 991_582,
+ binary: 1_675_976,
+ code: 17_108_729,
+ ets: 1_733_464,
+ processes: 31_075_760,
+ processes_used: 31_051_664,
+ system: 36_266_035,
+ total: 67_341_795
+ }
+ }
+ end
+
+ def build_telemetry_data_vm_total_memory(
+ timestamp \\ :rand.uniform(2_000_000_000_000),
+ value \\ 70_973.064
+ ) do
+ %Deployex.Telemetry.Data{
+ timestamp: timestamp,
+ value: value,
+ unit: " kilobyte",
+ tags: %{},
+ measurements: %{
+ atom: 1_294_641,
+ atom_used: 1_287_912,
+ binary: 1_059_128,
+ code: 31_784_038,
+ ets: 2_973_664,
+ processes: 14_523_720,
+ processes_used: 14_439_392,
+ system: 56_449_344,
+ total: 70_973_064
+ }
+ }
+ end
+
+ def build_telemetry_data(
+ timestamp \\ :rand.uniform(2_000_000_000_000),
+ value \\ 70_973.064,
+ unit \\ ""
+ ) do
+ %Deployex.Telemetry.Data{
+ timestamp: timestamp,
+ value: value,
+ unit: unit,
+ tags: %{},
+ measurements: %{}
+ }
+ end
+end
diff --git a/test/support/mocks.ex b/test/support/mocks.ex
index 6ba7734..7c8dda6 100644
--- a/test/support/mocks.ex
+++ b/test/support/mocks.ex
@@ -4,4 +4,5 @@ Mox.defmock(Deployex.ReleaseMock, for: Deployex.Release.Adapter)
Mox.defmock(Deployex.UpgradeMock, for: Deployex.Upgrade.Adapter)
Mox.defmock(Deployex.OpSysMock, for: Deployex.OpSys.Adapter)
Mox.defmock(Deployex.RpcMock, for: Deployex.Rpc.Adapter)
+Mox.defmock(Deployex.TelemetryMock, for: Deployex.Telemetry.Adapter)
Mox.defmock(Deployex.ConfigProvider.SecretsMock, for: Deployex.ConfigProvider.Secrets.Adapter)