pod

package
v0.26.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 10, 2026 License: MIT Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var WebsocketMessageType = map[int]string{
	websocket.BinaryMessage: "binary",
	websocket.TextMessage:   "text",
	websocket.CloseMessage:  "close",
	websocket.PingMessage:   "ping",
	websocket.PongMessage:   "pong",
}

Functions

func BindPodLogOptions 

func BindPodLogOptions(c *response.Context, containerName string) (*v1.PodLogOptions, error)

func RegisterLabelRoutes added in v0.0.145 

func RegisterLabelRoutes(api chi.Router)

func RegisterLogRoutes added in v0.0.145 

func RegisterLogRoutes(api chi.Router)

func RegisterPodFileRoutes added in v0.0.145 

func RegisterPodFileRoutes(api chi.Router)

func RegisterPortRoutes added in v0.0.145 

func RegisterPortRoutes(api chi.Router)

func RegisterResourceRoutes added in v0.0.145 

func RegisterResourceRoutes(api chi.Router)

func RegisterXtermRoutes added in v0.0.145 

func RegisterXtermRoutes(api chi.Router)

Types

type FileController added in v0.0.145 

type FileController struct{}

func (*FileController) Delete added in v0.0.145 

func (fc *FileController) Delete(c *response.Context)

@Summary 删除文件 @Security BearerAuth @Param cluster query string true "集群名称" @Param body body info true "文件信息" @Success 200 {object} string @Router /k8s/cluster/{cluster}/file/delete [post]

func (*FileController) Download added in v0.0.145 

func (fc *FileController) Download(c *response.Context)

@Summary 下载文件 @Security BearerAuth @Param cluster query string true "集群名称" @Param podName query string true "Pod名称" @Param path query string true "文件路径" @Param containerName query string true "容器名称" @Param namespace query string true "命名空间" @Success 200 {object} string @Router /k8s/cluster/{cluster}/file/download [get]

func (*FileController) List added in v0.0.145 

func (fc *FileController) List(c *response.Context)

List 处理获取文件列表的 HTTP 请求 @Summary 获取文件列表 @Security BearerAuth @Param cluster query string true "集群名称" @Param body body info true "文件信息" @Success 200 {object} string @Router /k8s/cluster/{cluster}/file/list [post]

func (*FileController) Save added in v0.0.145 

func (fc *FileController) Save(c *response.Context)

@Summary 保存文件 @Security BearerAuth @Param cluster query string true "集群名称" @Param body body info true "文件信息" @Success 200 {object} string @Router /k8s/cluster/{cluster}/file/save [post]

func (*FileController) Show added in v0.0.145 

func (fc *FileController) Show(c *response.Context)

Show 处理下载文件的 HTTP 请求 @Summary 查看文件内容 @Security BearerAuth @Param cluster query string true "集群名称" @Param body body info true "文件信息" @Success 200 {object} string @Router /k8s/cluster/{cluster}/file/show [post]

func (*FileController) Upload added in v0.0.145 

func (fc *FileController) Upload(c *response.Context)

Upload 处理上传文件的 HTTP 请求 @Summary 上传文件 @Security BearerAuth @Param cluster query string true "集群名称" @Param containerName formData string true "容器名称" @Param namespace formData string true "命名空间" @Param podName formData string true "Pod名称" @Param path formData string true "文件路径" @Param fileName formData string true "文件名" @Param file formData file true "上传文件" @Success 200 {object} string @Router /k8s/cluster/{cluster}/file/upload [post]

type LabelController added in v0.0.145 

type LabelController struct{}

func (*LabelController) UniqueLabels added in v0.0.145 

func (lc *LabelController) UniqueLabels(c *response.Context)

@Summary 获取Pod唯一标签键列表 @Security BearerAuth @Param cluster query string true "集群名称" @Success 200 {object} string @Router /k8s/cluster/{cluster}/pod/labels/unique_labels [get] UniqueLabels 返回当前集群中所有唯一的 Pod 标签键列表，格式化为前端可用的选项数组。

type LogController added in v0.0.145 

type LogController struct{}

func (*LogController) DownloadLogs added in v0.0.145 

func (lc *LogController) DownloadLogs(c *response.Context)

DownloadLogs 下载Pod日志 @Summary 下载Pod日志 @Security BearerAuth @Param cluster path string true "集群名称" @Param ns path string true "命名空间" @Param pod_name path string true "Pod名称" @Param container_name path string true "容器名称" @Success 200 {file} file "日志文件" @Router /k8s/cluster/{cluster}/pod/logs/download/ns/{ns}/pod_name/{pod_name}/container/{container_name} [get]

func (*LogController) PodNameOptionList added in v0.0.161 

func (lc *LogController) PodNameOptionList(c *response.Context)

PodNameOptionList 返回指定命名空间下的 Pod 名称选项 @Summary 获取Pod名称选项列表 @Security BearerAuth @Param cluster query string true "集群名称" @Param ns query string false "命名空间，为空则返回所有命名空间的Pod" @Success 200 {object} string @Router /k8s/cluster/{cluster}/pod/name/option_list [get]

func (*LogController) StreamLogs added in v0.0.145 

func (lc *LogController) StreamLogs(c *response.Context)

StreamLogs 通过SSE流式传输Pod日志 @Summary 流式获取Pod日志 @Security BearerAuth @Param cluster path string true "集群名称" @Param ns path string true "命名空间" @Param pod_name path string true "Pod名称" @Param container_name path string true "容器名称" @Success 200 {string} string "日志流" @Router /k8s/cluster/{cluster}/pod/logs/sse/ns/{ns}/pod_name/{pod_name}/container/{container_name} [get]

type LogQueryParams 

type LogQueryParams struct {
	Follow       bool   `form:"follow"`
	Previous     bool   `form:"previous"`
	SinceSeconds *int64 `form:"sinceSeconds"`
	SinceTime    string `form:"sinceTime"` // RFC3339 格式时间字符串
	Timestamps   bool   `form:"timestamps"`
	TailLines    *int64 `form:"tailLines"`
}

type PortController added in v0.0.145 

type PortController struct{}

func (*PortController) PortForwardList added in v0.0.145 

func (pc *PortController) PortForwardList(c *response.Context)

@Summary 列出端口转发信息 @Security BearerAuth @Param cluster query string true "集群名称" @Param ns path string true "命名空间" @Param name path string true "Pod名称" @Success 200 {object} string @Router /k8s/cluster/{cluster}/pod/port_forward/ns/{ns}/name/{name}/port/list [get]

func (*PortController) StartPortForward added in v0.0.145 

func (pc *PortController) StartPortForward(c *response.Context)

@Summary 开始端口转发 @Security BearerAuth @Param cluster query string true "集群名称" @Param ns path string true "命名空间" @Param name path string true "Pod名称" @Param container_name path string true "容器名称" @Param pod_port path string true "Pod端口" @Param local_port path string true "本地端口" @Success 200 {object} string @Router /k8s/cluster/{cluster}/pod/port_forward/ns/{ns}/name/{name}/container/{container_name}/pod_port/{pod_port}/local_port/{local_port}/start [post]

func (*PortController) StopPortForward added in v0.0.145 

func (pc *PortController) StopPortForward(c *response.Context)

@Summary 停止端口转发 @Security BearerAuth @Param cluster query string true "集群名称" @Param ns path string true "命名空间" @Param name path string true "Pod名称" @Param container_name path string true "容器名称" @Param pod_port path string true "Pod端口" @Success 200 {object} string @Router /k8s/cluster/{cluster}/pod/port_forward/ns/{ns}/name/{name}/container/{container_name}/pod_port/{pod_port}/stop [post]

type PortInfo added in v0.0.106 

type PortInfo struct {
	Cluster       string        `json:"cluster"`
	Namespace     string        `json:"namespace"` // Pod 命名空间
	Name          string        `json:"name"`      // pod名称
	ContainerName string        `json:"container_name"`
	PortName      string        `json:"port_name"`  // 端口名称
	Protocol      string        `json:"protocol"`   // TCP/UDP/STCP
	LocalPort     string        `json:"local_port"` // 本地端口，转发端口
	PodPort       string        `json:"pod_port"`   // pod 端口
	Status        string        `json:"status"`     // running/failed/stopped
	StopCh        chan struct{} `json:"-"`
}

PortInfo 结构体用于描述端口转发信息 包含容器名、端口名、协议、端口号、本地端口、转发状态等

type ResourceController added in v0.0.145 

type ResourceController struct{}

func (*ResourceController) TopList added in v0.0.145 

func (rc *ResourceController) TopList(c *response.Context)

@Summary 获取Pod资源使用情况列表 @Security BearerAuth @Param cluster query string true "集群名称" @Param ns path string true "命名空间，多个用逗号分隔" @Success 200 {object} string @Router /k8s/cluster/{cluster}/pod/top/ns/{ns}/list [get] TopList 返回指定命名空间下所有 Pod 的资源使用情况（CPU、内存等），支持多命名空间查询，并以便于前端排序的格式输出。

func (*ResourceController) Usage added in v0.0.145 

func (rc *ResourceController) Usage(c *response.Context)

@Summary 获取Pod资源使用情况 @Security BearerAuth @Param cluster query string true "集群名称" @Param ns path string true "命名空间" @Param name path string true "Pod名称" @Success 200 {object} string @Router /k8s/cluster/{cluster}/pod/usage/ns/{ns}/name/{name} [get]

type TTYSize added in v0.0.36 

type TTYSize struct {
	Cols uint16 `json:"cols"`
	Rows uint16 `json:"rows"`
	X    uint16 `json:"x"`
	Y    uint16 `json:"y"`
}

type TerminalSizeQueue added in v0.0.36 

type TerminalSizeQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

TerminalSizeQueue 维护 TTY 终端大小

func (*TerminalSizeQueue) Next added in v0.0.36 

func (t *TerminalSizeQueue) Next() *remotecommand.TerminalSize

func (*TerminalSizeQueue) Push added in v0.0.36 

func (t *TerminalSizeQueue) Push(cols, rows uint16)

type XtermController added in v0.0.145 

type XtermController struct{}

func (*XtermController) Xterm added in v0.0.145 

func (xc *XtermController) Xterm(c *response.Context)

@Summary 提供Pod容器的交互式终端会话 @Security BearerAuth @Param cluster query string true "集群名称" @Param ns path string true "命名空间" @Param pod_name path string true "Pod名称" @Param container_name query string false "容器名称，默认为第一个容器" @Param remove query bool false "会话结束后是否删除Pod" @Success 101 {string} string "WebSocket连接成功" @Router /k8s/cluster/{cluster}/pod/xterm/ns/{ns}/pod_name/{pod_name} [get] Xterm 通过 WebSocket 提供与 Kubernetes Pod 容器的交互式终端会话。 支持 xterm.js 前端，处理终端输入输出、窗口大小调整、命令日志记录和连接保活。 会话结束后可根据参数选择性删除目标 Pod。

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.