mirror of
https://github.com/lucky-sideburn/kubeinvaders.git
synced 2026-05-19 23:26:51 +00:00
added node discovery
This commit is contained in:
47
main/mymodules/node.lua
Normal file
47
main/mymodules/node.lua
Normal file
@@ -0,0 +1,47 @@
|
||||
local M = {}
|
||||
|
||||
function M.node_metrics(pod_name)
|
||||
http.request(endpoint .. "/apis/metrics.k8s.io/v1beta1/nodes", "GET", M.http_node_metrics_result, headers)
|
||||
end
|
||||
|
||||
function M.http_node_metrics_result(self, _, response)
|
||||
print(response.response)
|
||||
end
|
||||
|
||||
function M.get_nodes()
|
||||
http.request(endpoint .. "/api/v1/nodes", "GET", M.http_get_nodes_result, headers)
|
||||
end
|
||||
|
||||
function M.http_get_nodes_result(self, _, response)
|
||||
kubernetes_nodes = {}
|
||||
print("Get nodes output")
|
||||
print('/api/v1/nodes response: ' .. response.status)
|
||||
nodes = json.decode(response.response)
|
||||
node_items = nodes["items"]
|
||||
node_items_size = table.getn(node_items)
|
||||
print("Node table size: " .. node_items_size)
|
||||
pos_x = 80
|
||||
pos_y = 500
|
||||
nodes_cnt = 1
|
||||
for k, v in pairs(node_items) do
|
||||
for k1, v2 in pairs(v) do
|
||||
if v2["name"] then
|
||||
print("Found k8s node: " .. v2["name"])
|
||||
pos = vmath.vector3(pos_x, pos_y, 0)
|
||||
new_node = factory.create("/k8s_node#k8s_node_factory", pos)
|
||||
table.insert(kubernetes_nodes,{ name = v2["name"], id = new_node})
|
||||
|
||||
if ((nodes_cnt % 15 ) == 0) then
|
||||
pos_y = pos_y + 100
|
||||
pos_x = 80
|
||||
else
|
||||
pos_x = pos_x + 80
|
||||
end
|
||||
|
||||
nodes_cnt = nodes_cnt + 1
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
return M
|
||||
Reference in New Issue
Block a user