Merge pull request #75 from shvbsle/userexp

feat: implement cluster namespace switching

Author: shvbsle

internal/k8s/client.go

@@ -233,6 +233,43 @@ func (c *Client) SwitchContext(contextName string) error {
 	return c.Reconnect()
 }
 
+// TODO: get claude/ai to write the doc string
+func (c *Client) GetAvailableNamespaces() ([]string, error) {
+	if !c.isConnected || c.clientset == nil {
+		return nil, fmt.Errorf("not connected to cluster")
+	}
+
+	ctx := context.Background()
+
+	namespaceList, err := c.clientset.CoreV1().Namespaces().List(ctx, metav1.ListOptions{})
+	if err != nil {
+		c.markDisconnected()
+		return nil, fmt.Errorf("failed to list namespaces: %w", err)
+	}
+
+	namespaces := make([]string, 0, len(namespaceList.Items))
+	for _, ns := range namespaceList.Items {
+		namespaces = append(namespaces, ns.Name)
+	}
+
+	return namespaces, nil
+}
+
+// TODO: get claude/ai to write the doc string
+func (c *Client) NamespaceExists(name string) (bool, error) {
+	if !c.isConnected || c.clientset == nil {
+		return false, fmt.Errorf("not connected to cluster")
+	}
+
+	ctx := context.Background()
+	_, err := c.clientset.CoreV1().Namespaces().Get(ctx, name, metav1.GetOptions{})
+	if err != nil {
+		return false, nil
+	}
+
+	return true, nil
+}
+
 // ListContainersForPod retrieves all containers (init and regular) for a specific pod.
 // Returns an error if the client is not connected or if the API request fails.
 func (c *Client) ListContainersForPod(podName, namespace string) ([]OrderedResourceFields, error) {

internal/tui/commands.go

@@ -63,6 +63,8 @@ func (m *Model) executeCommand(command string) tea.Cmd {
 		return m.executeCplogsCommand(args)
 	case "ctx":
 		return m.executeCtxCommand(args)
+	case "ns":
+		return m.executeNsCommand(args)
 	}
 
 	return m.showCommandError(fmt.Sprintf("did not recognize command `%s`", originalCommand))
@@ -563,3 +565,74 @@ func (m *Model) executeCtxCommand(args []string) tea.Cmd {
 		}
 	}
 }
+
+// executeNsCommand handles the ns command for listing and switching kubernetes namespaces.
+func (m *Model) executeNsCommand(args []string) tea.Cmd {
+	// if no args then show table with all namespaces
+	if len(args) == 0 {
+		return func() tea.Msg {
+			namespaces, err := m.k8sClient.GetAvailableNamespaces()
+			if err != nil {
+				log.G().Error("failed to get namespaces", "error", err)
+				return commandErrMsg{message: fmt.Sprintf("failed to get namespaces: %v", err)}
+			}
+
+			// Sort namespaces alphabetically
+			sort.Strings(namespaces)
+
+			// Create rows for table display, marking the current namespaces
+			rows := lo.Map(namespaces, func(ns string, _ int) k8s.OrderedResourceFields {
+				isCurrent := ""
+				if ns == m.currentNamespace {
+					isCurrent = "*"
+				}
+				return k8s.OrderedResourceFields{
+					ns,
+					isCurrent,
+				}
+			})
+
+			return namespaceLoadedMsg{
+				namespaces: rows,
+			}
+		}
+	}
+
+	// handle "all" argument
+	namespaceName := args[0]
+	if namespaceName == "all" {
+		return func() tea.Msg {
+			log.G().Info("switching to all namespaces")
+			return namespaceSwitchedMsg{
+				namespace: metav1.NamespaceAll,
+				success:   true,
+			}
+		}
+	}
+
+	// case where namespace arg is provided
+	// also gotta confirm that the namespace exists
+
+	return func() tea.Msg {
+		log.G().Info("switching namespace", "namespace", namespaceName)
+
+		exists, err := m.k8sClient.NamespaceExists(namespaceName)
+		if err != nil {
+			log.G().Warn("failed to check namespace", "error", err)
+			return commandErrMsg{message: fmt.Sprintf("failed to check namespace: %v", err)}
+		}
+
+		if !exists {
+			log.G().Warn("namespace not found", "namespace", namespaceName)
+			return commandErrMsg{message: fmt.Sprintf("namespace '%s' not found", namespaceName)}
+		}
+
+		log.G().Info("namespace switched successfully", "namespace", namespaceName)
+
+		return namespaceSwitchedMsg{
+			namespace: namespaceName,
+			success:   true,
+		}
+	}
+
+}

internal/tui/model.go

@@ -135,6 +135,15 @@ type contextSwitchedMsg struct {
 	success     bool
 }
 
+type namespaceLoadedMsg struct {
+	namespaces []k8s.OrderedResourceFields
+}
+
+type namespaceSwitchedMsg struct {
+	namespace string
+	success   bool
+}
+
 // New creates a new TUI model with the provided configuration and Kubernetes client.
 // The client may be nil or disconnected - the TUI will handle this gracefully and
 // display appropriate status messages.
@@ -211,6 +220,14 @@ func New(cfg *config.Config, client *k8s.Client, registry *plugins.Registry) *Mo
 		return k8s.FormatGVR(gvr)
 	})
 
+	//fetch available namespaces to generate suggestions
+	availableNamespaces := []string{"all"}
+	if client != nil && client.IsConnected() {
+		if namespaces, err := client.GetAvailableNamespaces(); err == nil {
+			availableNamespaces = append(availableNamespaces, namespaces...)
+		}
+	}
+
 	return &Model{
 		config:           cfg,
 		k8sClient:        client,
@@ -235,6 +252,7 @@ func New(cfg *config.Config, client *k8s.Client, registry *plugins.Registry) *Mo
 					"cp":        struct{}{},
 					"cplogs":    struct{}{},
 					"ctx":       struct{}{},
+					"ns":        availableNamespaces,
 				},
 				// kubernetes resources
 				map[string]any{
@@ -253,7 +271,7 @@ func New(cfg *config.Config, client *k8s.Client, registry *plugins.Registry) *Mo
 		describeView:      NewDescribeViewState(),
 		pluginRegistry:    registry,
 		helpModal:         NewHelpModal(),
-		describeViewport:      NewDescribeViewport(),
+		describeViewport:  NewDescribeViewport(),
 	}
 }
 
@@ -523,6 +541,40 @@ func (m *Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 		}
 		return m, nil
 
+	case namespaceLoadedMsg:
+		m.resources = msg.namespaces
+		m.logLines = nil
+		m.currentGVR = schema.GroupVersionResource{Resource: "namespaces"}
+
+		m.updateKeysForResourceType()
+		m.updateColumns(m.viewWidth)
+		m.updateTableData()
+		m.table.SetCursor(0)
+
+		return m, nil
+
+	case namespaceSwitchedMsg:
+		if msg.success {
+			m.currentNamespace = msg.namespace
+			displayName := msg.namespace
+			if msg.namespace == metav1.NamespaceAll {
+				displayName = "all namespaces"
+			}
+			m.commandSuccess = fmt.Sprintf("Switched to namespace: %s", displayName)
+
+			return m, tea.Batch(
+				tea.Tick(5*time.Second, func(t time.Time) tea.Msg {
+					return clearCommandSuccessMsg{}
+				}),
+				m.loadResourcesWithNamespace(
+					schema.GroupVersionResource{Group: "", Version: "v1", Resource: "pods"},
+					m.currentNamespace,
+					metav1.ListOptions{},
+				),
+			)
+		}
+		return m, nil
+
 	case tea.KeyMsg:
 		// Handle help modal input first if visible
 		if m.helpModal.IsVisible() {
@@ -650,6 +702,24 @@ func (m *Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 					return m, nil
 				}
 
+				// Special handling for namespaces view
+				if m.currentGVR.Resource == "namespaces" {
+					if len(m.resources) == 0 {
+						return m, nil
+					}
+					actualIdx := m.paginator.Page*m.paginator.PerPage + m.table.Cursor()
+					if actualIdx >= len(m.resources) {
+						return m, nil
+					}
+					selectedResource := m.resources[actualIdx]
+					// The namespaces name is in the first column
+					if len(selectedResource) > 0 {
+						namespaceName := selectedResource[0]
+						return m, m.executeNsCommand([]string{namespaceName})
+					}
+					return m, nil
+				}
+
 				if m.currentGVR.Resource == k8s.ResourceLogs {
 					return m, nil
 				}

internal/tui/resources/resource_views.go

@@ -40,6 +40,13 @@ func GetColumns(totalWidth int, resource k8s.ResourceType) []table.Column {
 		}
 	}
 
+	if resource == "namespaces" {
+		return []table.Column{
+			{Title: "Namespace", Width: int(float32(totalWidth) * 0.8)},
+			{Title: "Current", Width: int(float32(totalWidth) * 0.2)},
+		}
+	}
+
 	var columns []table.Column
 	for _, field := range GetResourceView(resource).Fields {
 		columns = append(columns, table.Column{

roadmap.md

@@ -10,6 +10,8 @@
 - [ ] **SSH into containers** ([#65](https://github.com/shvbsle/k10s/issues/65)) - Triggered by `s` keybinding when cursor is on any resource. Equivalent to `kubectl exec -it <pod> -- /bin/sh`
 - [ ] **Logs shortcut** ([#66](https://github.com/shvbsle/k10s/issues/66)) - Triggered by `l` keybinding to display logs for selected pod/container
 - [ ] **Real-time logs** ([#67](https://github.com/shvbsle/k10s/issues/67)) - Stream logs in real-time with auto-scroll and filtering
+- [x] **Switch namespaces** ([]()) - Use `:ns` command to switch between namespaces
+
 
 ## Developer Experience