k8s

Documentation

Index

• func GetK8sClientSet() (*kubernetes.Clientset, *rest.Config, error)
• func GetK8sConfig() (config *rest.Config, err error)
• func NewWebsocketTerminal(namespaceName, podName, containerName, command string, ...) error
• type Namespace
  • func (n *Namespace) ListNamespaces() ([]v1.Namespace, error)
• type Pod
  • func (p *Pod) GetPodDetail(namespaceName, podName string) (*v1.Pod, error)
  • func (p *Pod) ListPods(namespaceName string) ([]v1.Pod, error)
• type WebsocketMsg
• type WebsocketProxy
  • func CreateWebsocketProxy(respWriter http.ResponseWriter, req *http.Request) (p *WebsocketProxy, err error)
  • func (p *WebsocketProxy) Close()
  • func (p *WebsocketProxy) Read() (msg *WebsocketMsg, err error)
  • func (p *WebsocketProxy) ReadLoop()
  • func (p *WebsocketProxy) Write(msg WebsocketMsg) (err error)
  • func (p *WebsocketProxy) WriteLoop()
• type WebsocketStream
  • func (stream *WebsocketStream) Next() (size *remotecommand.TerminalSize)
  • func (stream *WebsocketStream) Read(bs []byte) (size int, err error)
  • func (stream *WebsocketStream) Write(bs []byte) (size int, err error)
• type XtermMessage

Functions

func GetK8sClientSet

func GetK8sClientSet() (*kubernetes.Clientset, *rest.Config, error)

func GetK8sConfig

func GetK8sConfig() (config *rest.Config, err error)

func NewWebsocketTerminal

func NewWebsocketTerminal(namespaceName, podName, containerName, command string, respWrite http.ResponseWriter, req *http.Request) error

Types

type Namespace

type Namespace struct{}

func (*Namespace) ListNamespaces

func (n *Namespace) ListNamespaces() ([]v1.Namespace, error)

type Pod

type Pod struct{}

func (*Pod) GetPodDetail

func (p *Pod) GetPodDetail(namespaceName, podName string) (*v1.Pod, error)

func (*Pod) ListPods

func (p *Pod) ListPods(namespaceName string) ([]v1.Pod, error)

type WebsocketMsg

type WebsocketMsg struct {
	MsgType int
	Data    []byte
}

type WebsocketProxy

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

func CreateWebsocketProxy

func CreateWebsocketProxy(respWriter http.ResponseWriter, req *http.Request) (p *WebsocketProxy, err error)

func (*WebsocketProxy) Close

func (p *WebsocketProxy) Close()

func (*WebsocketProxy) Read

func (p *WebsocketProxy) Read() (msg *WebsocketMsg, err error)

func (*WebsocketProxy) ReadLoop

func (p *WebsocketProxy) ReadLoop()

func (*WebsocketProxy) Write

func (p *WebsocketProxy) Write(msg WebsocketMsg) (err error)

func (*WebsocketProxy) WriteLoop

func (p *WebsocketProxy) WriteLoop()

type WebsocketStream

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

func (*WebsocketStream) Next

func (stream *WebsocketStream) Next() (size *remotecommand.TerminalSize)

func (*WebsocketStream) Read

func (stream *WebsocketStream) Read(bs []byte) (size int, err error)

func (*WebsocketStream) Write

func (stream *WebsocketStream) Write(bs []byte) (size int, err error)

type XtermMessage

type XtermMessage struct {
	MsgType string `json:"type"`
	Input   string `json:"input"`
	Rows    uint16 `json:"rows"`
	Cols    uint16 `json:"cols"`
}