[Feature] - Implement ability to tail logs

README.md

@@ -14,6 +14,7 @@ Note: This is still incomplete in that it doesn't handle all possible resources
 
 ## ⚡️ Dependencies
 - kubectl
+- plenary.nvim
 
 ## 📦 Installation
 
@@ -25,6 +26,7 @@ Install the plugin with your preferred package manager:
 return {
   {
     "ramilito/kubectl.nvim",
+    dependencies = { "nvim-lua/plenary.nvim" },
     keys = {
       {
         "<leader>k",

ftplugin/k8s_pod_logs.lua

@@ -0,0 +1,10 @@
+local pod_view = require("kubectl.views.pods")
+
+vim.api.nvim_buf_set_keymap(0, "n", "f", "", {
+  noremap = true,
+  silent = true,
+  desc = "Tail logs",
+  callback = function()
+    pod_view.TailLogs()
+  end,
+})

ftplugin/k8s_pods.lua

@@ -91,3 +91,4 @@ api.nvim_buf_set_keymap(0, "n", "R", "", {
     pod_view.Pods()
   end,
 })
+

lua/kubectl/actions/commands.lua

@@ -1,5 +1,24 @@
 local M = {}
 
+function M.shell_command(cmd, args, callback)
+  local loaded, Job = pcall(require, "plenary.job")
+  if not loaded then
+    vim.notify("plenary.nvim is not installed. Please install it to use this feature.", vim.log.levels.ERROR)
+    return
+  end
+
+  Job:new({
+    command = cmd,
+    args = args,
+    on_stdout = function(_, data)
+      callback(data)
+    end,
+    on_stderr = function(_, data)
+      callback(data)
+    end,
+  }):start()
+end
+
 -- Function to execute a shell command and return the output as a table of strings
 function M.execute_shell_command(cmd, args)
   local full_command = cmd .. " " .. table.concat(args, " ")

lua/kubectl/views/pods/init.lua

@@ -26,10 +26,36 @@ function M.PodTop()
   ResourceBuilder:new("top", { "top", "pods", "-A" }):fetch():splitData():displayFloat("k8s_top", "Top", "")
 end
 
+function M.TailLogs()
+  local buf = vim.api.nvim_get_current_buf()
+  vim.api.nvim_win_set_cursor(0, { vim.api.nvim_buf_line_count(buf), 0 })
+
+  local function handle_output(data)
+    vim.schedule(function()
+      if vim.api.nvim_buf_is_valid(buf) then
+        local line_count = vim.api.nvim_buf_line_count(buf)
+        vim.api.nvim_buf_set_lines(buf, line_count, line_count, false, { data })
+        vim.api.nvim_set_option_value("modified", false, { buf = buf })
+        vim.api.nvim_win_set_cursor(0, { line_count + 1, 0 })
+      end
+    end)
+  end
+
+  commands.shell_command(
+    "kubectl",
+    { "logs", "--follow", "--since=1s", selection.pod, "-n", selection.ns },
+    handle_output
+  )
+end
+
 function M.PodLogs(pod_name, namespace)
+  selection = { pod = pod_name, ns = namespace }
   ResourceBuilder:new("logs", { "logs", pod_name, "-n", namespace })
     :fetch()
     :splitData()
+    :addHints({
+      { key = "<f>", desc = "Follow" },
+    }, false, false)
     :displayFloat("k8s_pod_logs", pod_name, "less")
 end