Skip to content

Commit

Permalink
use proxy for events, ns, nodes,secrets
Browse files Browse the repository at this point in the history
  • Loading branch information
Ramilito committed Jul 7, 2024
1 parent 2251847 commit 9def6e3
Show file tree
Hide file tree
Showing 4 changed files with 34 additions and 29 deletions.
23 changes: 12 additions & 11 deletions lua/kubectl/views/events/init.lua
Original file line number Diff line number Diff line change
Expand Up @@ -5,22 +5,23 @@ local definition = require("kubectl.views.events.definition")
local M = {}

function M.View(cancellationToken)
ResourceBuilder:new("events"):setCmd({ "get", "--raw", "/api/v1/{{NAMESPACE}}events" }):fetchAsync(function(self)
self:decodeJson():process(definition.processRow):sort():prettyPrint(definition.getHeaders)
ResourceBuilder:new("events")
:setCmd({ "{{BASE}}/api/v1/{{NAMESPACE}}events?pretty=false" }, "curl")
:fetchAsync(function(self)
self:decodeJson():process(definition.processRow):sort():prettyPrint(definition.getHeaders)

vim.schedule(function()
self
:addHints({
{ key = "<enter>", desc = "message" },
}, true, true)
:display("k8s_events", "Events", cancellationToken)
vim.schedule(function()
self
:addHints({
{ key = "<enter>", desc = "message" },
}, true, true)
:display("k8s_events", "Events", cancellationToken)
end)
end)
end)
end

function M.ShowMessage(event)
local msg = event
buffers.floating_buffer(vim.split(msg, "\n"), "event_msg", { title = "Message", syntax = "less" })
buffers.floating_buffer(vim.split(event, "\n"), {}, "event_msg", { title = "Message", syntax = "less" })
end

return M
16 changes: 9 additions & 7 deletions lua/kubectl/views/namespace/init.lua
Original file line number Diff line number Diff line change
Expand Up @@ -6,15 +6,17 @@ local state = require("kubectl.state")
local M = {}

function M.View()
ResourceBuilder:new("namespace"):setCmd({ "get", "--raw", "/api/v1/namespaces" }):fetchAsync(function(self)
self:decodeJson():process(definition.processRow):sort():prettyPrint(definition.getHeaders)
ResourceBuilder:new("namespace")
:setCmd({ "{{BASE}}/api/v1/namespaces?pretty=false" }, "curl")
:fetchAsync(function(self)
self:decodeJson():process(definition.processRow):sort():prettyPrint(definition.getHeaders)

vim.schedule(function()
self:displayFloat("k8s_namespace", "Namespace", "", true)
local win = vim.api.nvim_get_current_win()
vim.api.nvim_win_set_cursor(win, { 2, 0 })
vim.schedule(function()
self:displayFloat("k8s_namespace", "Namespace", "", true)
local win = vim.api.nvim_get_current_win()
vim.api.nvim_win_set_cursor(win, { 2, 0 })
end)
end)
end)
end
function M.changeNamespace(name)
local function handle_output(_)
Expand Down
2 changes: 1 addition & 1 deletion lua/kubectl/views/nodes/init.lua
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ local definition = require("kubectl.views.nodes.definition")
local M = {}

function M.View(cancellationToken)
ResourceBuilder:new("nodes"):setCmd({ "get", "--raw", "/api/v1/nodes" }):fetchAsync(function(self)
ResourceBuilder:new("nodes"):setCmd({ "{{BASE}}/api/v1/nodes?pretty=false" }, "curl"):fetchAsync(function(self)
self:decodeJson():process(definition.processRow):sort():prettyPrint(definition.getHeaders)
vim.schedule(function()
self
Expand Down
22 changes: 12 additions & 10 deletions lua/kubectl/views/secrets/init.lua
Original file line number Diff line number Diff line change
@@ -1,22 +1,24 @@
local ResourceBuilder = require("kubectl.resourcebuilder")
local buffers = require("kubectl.actions.buffers")
local commands = require("kubectl.actions.commands")
local definition = require("kubectl.views.secrets.definition")
local commands = require("kubectl.actions.commands")

local M = {}

function M.View(cancellationToken)
ResourceBuilder:new("secrets"):setCmd({ "get", "--raw", "/api/v1/{{NAMESPACE}}secrets" }):fetchAsync(function(self)
self:decodeJson():process(definition.processRow):sort():prettyPrint(definition.getHeaders)
ResourceBuilder:new("secrets")
:setCmd({ "{{BASE}}/api/v1/{{NAMESPACE}}secrets?pretty=false" }, "curl")
:fetchAsync(function(self)
self:decodeJson():process(definition.processRow):sort():prettyPrint(definition.getHeaders)

vim.schedule(function()
self
:addHints({
{ key = "<d>", desc = "describe" },
}, true, true)
:display("k8s_secrets", "Secrets", cancellationToken)
vim.schedule(function()
self
:addHints({
{ key = "<d>", desc = "describe" },
}, true, true)
:display("k8s_secrets", "Secrets", cancellationToken)
end)
end)
end)
end

function M.Edit(name, namespace)
Expand Down

0 comments on commit 9def6e3

Please sign in to comment.