defmodule Observer.Web.Components.Metrics.VmMemory do
@moduledoc false
use Observer.Web, :html
use Phoenix.Component
attr :title, :string, required: true
attr :service, :string, required: true
attr :metric, :string, required: true
attr :metrics, :list, required: true
attr :cols, :integer, default: 2
def content(assigns) do
~H"""
<% id = String.replace("#{@service}-#{@metric}", ["@", ".", "/"], "-") %>
<% metrics = Enum.map(@metrics.inserts, fn {_id, _index, data, _} -> data end) %>
<% normalized_metrics = normalize(metrics) %>
<% echart_config = config(normalized_metrics) %>
"""
end
defp normalize(metrics) do
empty_series_data = %{
atom: [],
atom_used: [],
binary: [],
code: [],
ets: [],
processes: [],
processes_used: [],
system: [],
total: []
}
{series_data, categories_data} =
Enum.reduce(metrics, {empty_series_data, []}, fn metric, {series_data, categories_data} ->
timestamp =
metric.timestamp
|> trunc()
|> DateTime.from_unix!(:millisecond)
|> DateTime.to_string()
{%{
atom: series_data.atom ++ [metric.measurements.atom],
atom_used: series_data.atom_used ++ [metric.measurements.atom_used],
binary: series_data.binary ++ [metric.measurements.binary],
code: series_data.code ++ [metric.measurements.code],
ets: series_data.ets ++ [metric.measurements.ets],
processes: series_data.processes ++ [metric.measurements.processes],
processes_used: series_data.processes_used ++ [metric.measurements.processes_used],
system: series_data.system ++ [metric.measurements.system],
total: series_data.total ++ [metric.measurements.total]
}, categories_data ++ [timestamp]}
end)
datasets =
[
%{
name: "Atom",
type: "line",
data: series_data.atom
},
%{
name: "Atom Used",
type: "line",
data: series_data.atom_used
},
%{
name: "Binary",
type: "line",
data: series_data.binary
},
%{
name: "Code",
type: "line",
data: series_data.code
},
%{
name: "Ets",
type: "line",
data: series_data.ets
},
%{
name: "Processes",
type: "line",
data: series_data.processes
},
%{
name: "Processes Used",
type: "line",
data: series_data.processes_used
},
%{
name: "System",
type: "line",
data: series_data.system
},
%{
name: "Total",
type: "line",
data: series_data.total
}
]
%{
datasets: datasets,
categories: categories_data
}
end
defp config(%{datasets: datasets, categories: categories}) do
%{
tooltip: %{
trigger: "axis"
},
legend: %{
data: [
"Atom",
"Atom Used",
"Binary",
"Code",
"Ets",
"Processes",
"Processes Used",
"System",
"Total"
],
right: "25%"
},
grid: %{
left: "3%",
right: "4%",
bottom: "3%",
top: "30%",
containLabel: true
},
toolbox: %{
feature: %{
dataZoom: %{},
dataView: %{},
saveAsImage: %{}
}
},
yAxis: %{
type: "value",
axisLabel: %{
formatter: "{value} bytes"
}
},
series: datasets,
xAxis: %{
type: "category",
boundaryGap: false,
data: categories
}
}
end
end