node

Documentation

Index

• func CreateAttachHandler(path string) http.Handler
• func WaitForTerminal(k8sClient *kubernetes.Clientset, cfg *rest.Config, ts TerminalSession, ...)
• type KubeNodeController
  • func (c *KubeNodeController) AddLabel()
  • func (c *KubeNodeController) AddLabels()
  • func (c *KubeNodeController) Delete()
  • func (c *KubeNodeController) DeleteLabel()
  • func (c *KubeNodeController) DeleteLabels()
  • func (c *KubeNodeController) DeleteTaint()
  • func (c *KubeNodeController) Get()
  • func (c *KubeNodeController) GetLabels()
  • func (c *KubeNodeController) List()
  • func (c *KubeNodeController) NodeStatistics()
  • func (c *KubeNodeController) Prepare()
  • func (c *KubeNodeController) SetTaint()
  • func (c *KubeNodeController) Terminal()
  • func (c *KubeNodeController) URLMapping()
  • func (c *KubeNodeController) Update()
• type Label
• type LabelSet
• type PtyHandler
• type TerminalMessage
• type TerminalResult
• type TerminalSession
  • func (t TerminalSession) Close(status uint32, reason string)
  • func (t TerminalSession) Next() *remotecommand.TerminalSize
  • func (t TerminalSession) Read(p []byte) (int, error)
  • func (t TerminalSession) Write(p []byte) (int, error)

Functions

func CreateAttachHandler

func CreateAttachHandler(path string) http.Handler

func WaitForTerminal

func WaitForTerminal(k8sClient *kubernetes.Clientset, cfg *rest.Config, ts TerminalSession, namespace, pod, container, cmd string)

Types

type KubeNodeController

type KubeNodeController struct {
	base.APIController
}

func (*KubeNodeController) AddLabel

func (c *KubeNodeController) AddLabel()

@Title add label @Description add a label for a node @router /:name/clusters/:cluster/label [post]

func (*KubeNodeController) AddLabels

func (c *KubeNodeController) AddLabels()

@Title add labels @Description Add labels in bulk for node @router /:name/clusters/:cluster/labels [post]

func (*KubeNodeController) Delete

func (c *KubeNodeController) Delete()

@Title Delete @Description delete the Node @Success 200 {string} delete success! @router /:name/clusters/:cluster [delete]

func (*KubeNodeController) DeleteLabel

func (c *KubeNodeController) DeleteLabel()

@Title delete label @Description delete a label of the node @router /:name/clusters/:cluster/label [delete]

func (*KubeNodeController) DeleteLabels

func (c *KubeNodeController) DeleteLabels()

@Title delete labels @Description Delete node labels in batches @router /:name/clusters/:cluster/labels [delete]

func (*KubeNodeController) DeleteTaint

func (c *KubeNodeController) DeleteTaint()

@Title delete taint @Description delete a taint from node @router /:name/clusters/:cluster/taint [delete]

func (*KubeNodeController) Get

func (c *KubeNodeController) Get()

@Title get node @Description find node by cluster @router /:name/clusters/:cluster [get]

func (*KubeNodeController) GetLabels

func (c *KubeNodeController) GetLabels()

@Title list node labels @Description get labels of a node @router /:name/clusters/:cluster/labels [get]

func (*KubeNodeController) List

func (c *KubeNodeController) List()

@Title List node @Description list nodes @router /clusters/:cluster [get]

func (*KubeNodeController) NodeStatistics

func (c *KubeNodeController) NodeStatistics()

@Title kubernetes node statistics @Description kubernetes statistics @Param cluster query string false "the cluster " @Success 200 {object} node.NodeStatistics success @router /statistics [get]

func (*KubeNodeController) Prepare

func (c *KubeNodeController) Prepare()

func (*KubeNodeController) SetTaint

func (c *KubeNodeController) SetTaint()

@Title add taint @Description set taint for a node @router /:name/clusters/:cluster/taint [post]

func (*KubeNodeController) Terminal

func (c *KubeNodeController) Terminal()

@Title Create terminal @Param cmd query string true "the cmd you want to exec." @Param container query string true "the container name." @Description create container terminal @router /:pod/terminal/namespaces/:namespace/clusters/:cluster [post]

func (*KubeNodeController) URLMapping

func (c *KubeNodeController) URLMapping()

func (*KubeNodeController) Update

func (c *KubeNodeController) Update()

@Title Update @Description update the Node @router /:name/clusters/:cluster [put]

type Label

type Label struct {
	Key   string `json:"key,omitempty"`
	Value string `json:"value,omitempty"`
}

type LabelSet

type LabelSet struct {
	Labels []Label
}

type PtyHandler

type PtyHandler interface {
	io.Reader
	io.Writer
	remotecommand.TerminalSizeQueue
}

type TerminalMessage

type TerminalMessage struct {
	Op, Data, SessionID string
	Rows, Cols          uint16
}

type TerminalResult

type TerminalResult struct {
	SessionId string `json:"sessionId,omitempty"`
	Token     string `json:"token,omitempty"`
	Cluster   string `json:"cluster,omitempty"`
	Namespace string `json:"namespace,omitempty"`
	Pod       string `json:"pod,omitempty"`
	Container string `json:"container,omitempty"`
	Cmd       string `json:"cmd,omitempty"`
}

type TerminalSession

type TerminalSession struct {
	// contains filtered or unexported fields
}

func (TerminalSession) Close

func (t TerminalSession) Close(status uint32, reason string)

func (TerminalSession) Next

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

func (TerminalSession) Read

func (t TerminalSession) Read(p []byte) (int, error)

func (TerminalSession) Write

func (t TerminalSession) Write(p []byte) (int, error)