680ed02e12
Previously, we printed similar logs for each VM host, but they were hard
to digest.
Aggregated utilization by location, architecture, and allocation state
is more useful for us.
For utilization grouped by architecture, I log the utilization of
accepting VM hosts; we don't need to consider draining VM hosts.
Example logs
```json
{
"location_utilization": {
"allocation_state": "accepting",
"location": "hetzner-fsn1",
"arch": "x64",
"host_count": 1,
"used_cores": 1,
"total_cores": 32,
"core_utilization": 3.13,
"used_hugepages_1g": 2,
"total_hugepages_1g": 249,
"hugepage_utilization": 0.8
},
"message": "location utilization",
"time": "2024-12-10 19:47:31 +0000",
"thread": "st10g0vmh0st0vt111zat10nzz"
}
{
"arch_utilization": {
"host_count": 1,
"used_cores": 1,
"total_cores": 32,
"used_hugepages_1g": 2,
"total_hugepages_1g": 249,
"arch": "x64",
"core_utilization": 3.13,
"hugepage_utilization": 0.8
},
"message": "arch utilization",
"time": "2024-12-10 19:47:31 +0000",
"thread": "st10g0vmh0st0vt111zat10nzz"
}
```
47 lines
2.0 KiB
Ruby
47 lines
2.0 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require_relative "../model/spec_helper"
|
|
|
|
RSpec.describe Prog::LogVmHostUtilizations do
|
|
subject(:lvmhu) { described_class.new(Strand.new(prog: "LogVmHostUtilizations")) }
|
|
|
|
describe "#wait" do
|
|
it "logs vm host utilizations every minute" do
|
|
[
|
|
["1.1.1.1", "hetzner-fsn1", "x64", "accepting", 3, 10, 20, 80],
|
|
["2.2.2.2", "hetzner-fsn1", "x64", "draining", 5, 20, 50, 150],
|
|
["3.3.3.3", "hetzner-fsn1", "arm64", "accepting", 10, 80, 30, 200],
|
|
["4.4.4.4", "hetzner-hel1", "x64", "accepting", 2, 10, 20, 100],
|
|
["5.5.5.5", "hetzner-hel1", "x64", "accepting", 0, nil, 0, 0]
|
|
].each do |host, location, arch, allocation_state, used_cores, total_cores, used_hugepages_1g, total_hugepages_1g|
|
|
sshable = Sshable.create_with_id(host:)
|
|
VmHost.create(location:, arch:, allocation_state:, used_cores:, total_cores:, used_hugepages_1g:, total_hugepages_1g:) { _1.id = sshable.id }
|
|
end
|
|
|
|
expect(Clog).to receive(:emit).with("location utilization") do |&blk|
|
|
dat = blk.call[:location_utilization]
|
|
if dat[:location] == "hetzner-fsn1" && dat[:arch] == "x64" && dat[:allocation_state] == "accepting"
|
|
expect(dat[:core_utilization]).to eq(30.0)
|
|
expect(dat[:hugepage_utilization]).to eq(25.0)
|
|
elsif dat[:location] == "hetzner-fsn1" && dat[:arch] == "x64" && dat[:allocation_state] == "draining"
|
|
expect(dat[:core_utilization]).to eq(25.0)
|
|
expect(dat[:hugepage_utilization]).to eq(33.33)
|
|
end
|
|
end.at_least(:once)
|
|
|
|
expect(Clog).to receive(:emit).with("arch utilization") do |&blk|
|
|
dat = blk.call[:arch_utilization]
|
|
if dat[:arch] == "x64"
|
|
expect(dat[:core_utilization]).to eq(25.0)
|
|
expect(dat[:hugepage_utilization]).to eq(22.22)
|
|
elsif dat[:arch] == "arm64"
|
|
expect(dat[:core_utilization]).to eq(12.5)
|
|
expect(dat[:hugepage_utilization]).to eq(15.0)
|
|
end
|
|
end.at_least(:once)
|
|
|
|
expect { lvmhu.wait }.to nap(60)
|
|
end
|
|
end
|
|
end
|