Function runStorageList

internal/cli/storage.go:92–156

(cmd *cobra.Command, _ []string)

}

func runStorageList(cmd *cobra.Command, _ []string) error {
	ctx := context.Background()

	session, err := initCLISession(cmd)
	if err != nil {
		return printError(err)
	}

	if session == nil {
		return nil
	}

	nodeName, _ := cmd.Flags().GetString("node")

	var rows []storageListRow

	if nodeName != "" {
		client, err := session.clientForNode(ctx, nodeName)
		if err != nil {
			return printError(err)
		}

		rows, err = fetchStorageRows(client, nodeName)
		if err != nil {
			return printError(err)
		}
	} else {
		nodes, err := session.getNodes(ctx)
		if err != nil {
			return printError(fmt.Errorf("failed to fetch nodes: %w", err))
		}

		for _, node := range nodes {
			if node == nil {
				continue
			}

			client, err := session.clientForNode(ctx, node.Name)
			if err != nil {
				continue
			}

			nodeRows, err := fetchStorageRows(client, node.Name)
			if err != nil {
				continue
			}

			rows = append(rows, nodeRows...)
		}
	}

	format := getOutputFormat(cmd)
	if format == outputTable {
		headers := []string{"NAME", "NODE", "TYPE", "USED/TOTAL", "CONTENT"}
		tableRows := make([][]string, 0, len(rows))
		for _, r := range rows {
			usedTotal := fmt.Sprintf("%s/%s", formatBytes(r.Used), formatBytes(r.Total))
			tableRows = append(tableRows, []string{r.Name, r.Node, r.Type, usedTotal, r.Content})