+
- <.link navigate={~p"/"} class="text-sm text-zinc-500 hover:text-zinc-900">← Back
-
{@host.name}
-
- {sys_line(@slow)} · Uptime {uptime(@fast)} · Last seen {last_seen(@host.last_seen_at)}
-
-
-
status_class(@host.status)}>
- {@host.status}
-
-
-
-
- Host metrics
- <.metric_row label="Load (1/5/15)" value={host_load(@fast)} />
- <.metric_row label="Memory" value={host_mem(@fast)} />
-
-
-
- ZFS pools
- No data.
-
-
- {pool["name"]}
- {pool["health"]}
-
-
- Capacity {pool["capacity_percent"]}% · Fragmentation {pool["fragmentation_percent"] || 0}% · Errors {pool[
- "error_count"
- ] || 0} · vdevs {pool["vdev_count"] || 0} (degraded {pool["degraded_vdev_count"] || 0}) · Last scrub {pool[
- "last_scrub_end"
- ] || "never"}
+
{@host.name}
+
+ {sys_line(@slow)} · uptime {uptime(@fast)} · last seen {last_seen(@host.last_seen_at)}
-
+
{@host.status}
+
Snapshots
-
-
-
- | Dataset |
- Count |
- Oldest |
- Newest |
-
-
-
-
- | {ds["name"]} |
- {ds["snapshot_count"]} |
- {unix_to_date(ds["oldest_snapshot_unix"])} |
- {unix_to_date(ds["newest_snapshot_unix"])} |
-
-
-
- No data.
-
+
+
+
+
+ - load (1/5/15)
- {host_load(@fast)}
+ - memory
- {host_mem(@fast)}
+ - agent
- {@host.agent_version || "—"}
+
+
+
Storage
-
-
-
- | Name |
- Type |
- Usage |
-
-
-
-
- | {s["name"]} |
- {s["type"]} |
- {storage_usage(s)} |
-
-
-
- No data.
-
+
+
ZFS pools{length(pools(@fast))}
+
+
No data.
+
+
+
+ {pool["name"]}
+
+
{pool["health"]}
+
+ cap {pool["capacity_percent"]}% ·
+ frag {pool["fragmentation_percent"] || 0}% ·
+ err {pool["error_count"] || 0} ·
+ vdevs {pool["vdev_count"] || 0} (deg {pool["degraded_vdev_count"] || 0})
+
+
+
+ scrub
{pool["last_scrub_end"] || "never"}
+
+
+
+
VMs / LXCs
-
-
-
- | VMID |
- Name |
- Type |
- Status |
-
-
-
-
- | {vm["vmid"]} |
- {vm["name"]} |
- {vm["type"]} |
- {vm["status"]} |
-
-
-
- No data.
-
+
+
Snapshots{length(datasets(@medium))}
+
+
+
+ | Dataset | Count | Oldest | Newest |
|---|
+
+
+
+ | {ds["name"]} |
+ {ds["snapshot_count"]} |
+ {unix_to_date(ds["oldest_snapshot_unix"])} |
+ {unix_to_date(ds["newest_snapshot_unix"])} |
+
+
+
+
No data.
+
+
+
Storage{length(storages(@fast))}
+
+
+
+ | Name | Type | Usage |
|---|
+
+
+
+ | {s["name"]} |
+ {s["type"]} |
+ {storage_usage(s)} |
+
+
+
+
No data.
+
+
+
VMs / LXCs{length(vms(@fast))}
+
+
+
+ | VMID | Name | Type | Status |
|---|
+
+
+
+ | {vm["vmid"]} |
+ {vm["name"]} |
+ {vm["type"]} |
+ {vm["status"]} |
+
+
+
+
No data.
+
+
"""
end
- attr :label, :string, required: true
- attr :value, :string, required: true
+ defp vm_status(%{"status" => "running"}), do: "ok"
+ defp vm_status(%{"status" => "stopped"}), do: "offline"
+ defp vm_status(_), do: "warning"
- def metric_row(assigns) do
- ~H"""
-
- {@label}
- {@value}
-
- """
- end
-
- defp status_class("online"), do: "text-green-600"
- defp status_class("offline"), do: "text-zinc-500"
- defp status_class(_), do: "text-zinc-500"
-
- defp pool_class("ONLINE"), do: "text-green-600 font-mono"
- defp pool_class(_), do: "text-red-600 font-mono"
+ defp pool_badge_style("ONLINE"), do: "color: var(--ok);"
+ defp pool_badge_style(_), do: "color: var(--crit);"
defp sys_line(nil), do: "—"
-
defp sys_line(%{payload: p}) do
get_in(p, ["system_info", "pve_version"]) || "—"
end
defp uptime(nil), do: "—"
-
defp uptime(%{payload: p}) do
case get_in(p, ["host", "uptime_seconds"]) do
nil -> "—"
@@ -182,10 +170,8 @@ defmodule ServerWeb.HostDetailLive do
end
defp last_seen(nil), do: "never"
-
defp last_seen(%DateTime{} = dt) do
secs = DateTime.diff(DateTime.utc_now(), dt, :second)
-
cond do
secs < 60 -> "#{secs}s ago"
secs < 3600 -> "#{div(secs, 60)}m ago"
@@ -194,7 +180,6 @@ defmodule ServerWeb.HostDetailLive do
end
defp host_load(nil), do: "—"
-
defp host_load(%{payload: p}) do
l1 = get_in(p, ["host", "load1"]) || "—"
l5 = get_in(p, ["host", "load5"]) || "—"
@@ -203,7 +188,6 @@ defmodule ServerWeb.HostDetailLive do
end
defp host_mem(nil), do: "—"
-
defp host_mem(%{payload: p}) do
used = get_in(p, ["host", "mem_used_bytes"])
total = get_in(p, ["host", "mem_total_bytes"])
@@ -211,9 +195,7 @@ defmodule ServerWeb.HostDetailLive do
case {used, total} do
{u, t} when is_integer(u) and is_integer(t) and t > 0 ->
"#{Float.round(u / t * 100, 1)}% (#{format_bytes(u)} / #{format_bytes(t)})"
-
- _ ->
- "—"
+ _ -> "—"
end
end
@@ -237,7 +219,6 @@ defmodule ServerWeb.HostDetailLive do
defp storage_usage(_), do: "—"
defp unix_to_date(nil), do: "—"
-
defp unix_to_date(unix) when is_integer(unix) do
case DateTime.from_unix(unix) do
{:ok, dt} -> Calendar.strftime(dt, "%Y-%m-%d")
diff --git a/server/lib/server_web/live/overview_live.ex b/server/lib/server_web/live/overview_live.ex
index 1732f82..5397dc3 100644
--- a/server/lib/server_web/live/overview_live.ex
+++ b/server/lib/server_web/live/overview_live.ex
@@ -6,7 +6,7 @@ defmodule ServerWeb.OverviewLive do
@impl true
def mount(_params, _session, socket) do
if connected?(socket), do: Phoenix.PubSub.subscribe(Server.PubSub, "metrics")
- {:ok, assign(socket, :hosts, load_hosts())}
+ {:ok, assign(socket, hosts: load_hosts(), page_title: "Overview")}
end
@impl true
@@ -25,70 +25,59 @@ defmodule ServerWeb.OverviewLive do
@impl true
def render(assigns) do
~H"""
-
-
+
-
-
border_class(entry.status)}
- >
- <.link navigate={~p"/hosts/#{entry.host.name}"} class="block space-y-2">
-
- {entry.host.name}
- text_class(entry.status)}>
- {entry.status}
-
-
-
- Last seen: {last_seen(entry.host.last_seen_at)}
-
-
-
Load: {format_load(entry.sample.payload)}
-
RAM used: {format_mem(entry.sample.payload)}
-
Pools: {pool_summary(entry.sample.payload)}
-
VMs: {vm_count(entry.sample.payload)}
-
-
- No samples yet
-
-
+
+
+
Hosts
+ {summary_line(@hosts)}
+
+
+
+
+ No hosts registered. Add one at
+ <.link navigate={~p"/admin/hosts"}>/admin/hosts.
-
- No hosts registered yet. Add one via /admin/hosts.
-
+
+ <.link :for={entry <- @hosts} navigate={~p"/hosts/#{entry.host.name}"} class="card"
+ data-status={Atom.to_string(entry.status)} data-role="host-card">
+
+ {entry.host.name}
+
+ {entry.status}
+
+
+
last seen {last_seen(entry.host.last_seen_at)}
+ <%= if entry.sample do %>
+
load{load(entry.sample.payload)}
+
ram{mem(entry.sample.payload)}
+
pools{pool_summary(entry.sample.payload)}
+
vms{vm_count(entry.sample.payload)}
+ <% else %>
+
no samples yet
+ <% end %>
+
+
"""
end
- defp border_class(:ok), do: "border-green-500"
- defp border_class(:warning), do: "border-yellow-500"
- defp border_class(:critical), do: "border-red-500"
- defp border_class(:offline), do: "border-zinc-400"
-
- defp text_class(:ok), do: "text-green-600"
- defp text_class(:warning), do: "text-yellow-600"
- defp text_class(:critical), do: "text-red-600"
- defp text_class(:offline), do: "text-zinc-500"
+ defp summary_line([]), do: "0 hosts"
+ defp summary_line(hosts) do
+ n = length(hosts)
+ by = Enum.frequencies_by(hosts, & &1.status)
+ parts =
+ [:ok, :warning, :critical, :offline]
+ |> Enum.filter(&Map.has_key?(by, &1))
+ |> Enum.map(fn s -> "#{by[s]} #{s}" end)
+ "#{n} host#{if n == 1, do: "", else: "s"} · " <> Enum.join(parts, " · ")
+ end
defp last_seen(nil), do: "never"
-
defp last_seen(%DateTime{} = dt) do
secs = DateTime.diff(DateTime.utc_now(), dt, :second)
-
cond do
secs < 60 -> "#{secs}s ago"
secs < 3600 -> "#{div(secs, 60)}m ago"
@@ -96,23 +85,20 @@ defmodule ServerWeb.OverviewLive do
end
end
- defp format_load(payload) do
+ defp load(payload) do
case get_in(payload, ["host", "load1"]) do
nil -> "—"
l -> :io_lib.format("~.2f", [l]) |> to_string()
end
end
- defp format_mem(payload) do
+ defp mem(payload) do
used = get_in(payload, ["host", "mem_used_bytes"])
total = get_in(payload, ["host", "mem_total_bytes"])
-
case {used, total} do
{u, t} when is_integer(u) and is_integer(t) and t > 0 ->
"#{Float.round(u / t * 100, 1)}%"
-
- _ ->
- "—"
+ _ -> "—"
end
end
@@ -120,11 +106,11 @@ defmodule ServerWeb.OverviewLive do
pools = get_in(payload, ["zfs_pools", "pools"]) || []
total = length(pools)
bad = Enum.count(pools, &(&1["health"] != "ONLINE"))
- if total == 0, do: "—", else: "#{total - bad}/#{total} ok"
+ if total == 0, do: "—", else: "#{total - bad}/#{total}"
end
defp vm_count(payload) do
vms = get_in(payload, ["vms_runtime", "vms"]) || []
- length(vms)
+ length(vms) |> to_string()
end
end
diff --git a/server/lib/server_web/live/vm_search_live.ex b/server/lib/server_web/live/vm_search_live.ex
index 5c9f51c..ec36262 100644
--- a/server/lib/server_web/live/vm_search_live.ex
+++ b/server/lib/server_web/live/vm_search_live.ex
@@ -6,7 +6,7 @@ defmodule ServerWeb.VmSearchLive do
@impl true
def mount(_params, _session, socket) do
if connected?(socket), do: Phoenix.PubSub.subscribe(Server.PubSub, "metrics")
- {:ok, socket |> assign(:q, "") |> assign(:vms, load_vms())}
+ {:ok, socket |> assign(q: "", vms: load_vms(), page_title: "VM Search")}
end
@impl true
@@ -54,51 +54,57 @@ defmodule ServerWeb.VmSearchLive do
@impl true
def render(assigns) do
~H"""
-
- <.link navigate={~p"/"} class="text-sm text-zinc-500 hover:text-zinc-900">← Back
-
VM Search
+
+
+
+
+
VM Search
+ {length(filter(@vms, @q))} / {length(@vms)} shown
+
-
-
-
- | Name |
- Host |
- Type |
- Status |
- IPs |
-
-
-
-
- | {vm.name} |
-
- <.link
- navigate={~p"/hosts/#{vm.host_name}"}
- class="text-zinc-700 hover:text-zinc-900 underline"
- >
- {vm.host_name}
-
- |
- {vm.type} |
- {vm.status} |
- {Enum.join(vm.ips, ", ")} |
-
-
- | No matches. |
-
-
-
+
+
+
+
+
+ | VMID |
+ Name |
+ Host |
+ Type |
+ Status |
+ IPs |
+
+
+
+
+ | {vm.vmid} |
+ {vm.name} |
+ <.link navigate={~p"/hosts/#{vm.host_name}"}>{vm.host_name} |
+ {vm.type} |
+ {vm.status} |
+ {Enum.join(vm.ips, ", ")} |
+
+
+
+
No matches.
+
+
"""
end
+
+ defp vm_status(%{status: "running"}), do: "ok"
+ defp vm_status(%{status: "stopped"}), do: "offline"
+ defp vm_status(_), do: "warning"
end
![]({~p"/images/logo.svg"})
-
-