server

Documentation

Index

• func CreateAttachHandler(path string) http.Handler
• func WaitForTerminal(k8sClient kubernetes.Interface, cfg *rest.Config, request *restful.Request, ...)
• type App
  • func (a *App) AppRoute() *mux.Router
  • func (a *App) InitilizeService()
  • func (a *App) LoadConfig(configPath string) *App
  • func (a *App) Start(host, port string) error
• type PtyHandler
• type TerminalMessage
• type TerminalResponse
• 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) Toast(p string) error
  • func (t TerminalSession) Write(p []byte) (int, error)

Functions

func CreateAttachHandler

func CreateAttachHandler(path string) http.Handler

CreateAttachHandler is called from main for /v1/sockjs

func WaitForTerminal

func WaitForTerminal(k8sClient kubernetes.Interface, cfg *rest.Config, request *restful.Request, sessionId string)

WaitForTerminal is called from apihandler.handleAttach as a goroutine Waits for the SockJS connection to be opened by the client the session to be bound in handleTerminalSession

Types

type App

type App struct {
	Config          config.Config
	ServiceProvider *serviceprovider.Container
}

App is the structure to set config & service provider of APP

func (*App) AppRoute

func (a *App) AppRoute() *mux.Router

AppRoute will add router

func (*App) InitilizeService

func (a *App) InitilizeService()

InitilizeService weavering services with global variables inside server package

func (*App) LoadConfig

func (a *App) LoadConfig(configPath string) *App

LoadConfig consumes a string of path to the json config file and read config file into Config.

func (*App) Start

func (a *App) Start(host, port string) error

Start consumes two strings, host and port, invoke service initilization and serve on desired host:port

type PtyHandler

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

PtyHandler is what remotecommand expects from a pty

type TerminalMessage

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

TerminalMessage is the messaging protocol between ShellController and TerminalSession.

OP DIRECTION FIELD(S) USED DESCRIPTION --------------------------------------------------------------------- bind fe->be SessionID Id sent back from TerminalResponse stdin fe->be Data Keystrokes/paste buffer resize fe->be Rows, Cols New terminal size stdout be->fe Data Output from the process toast be->fe Data OOB message to be shown to the user

type TerminalResponse

type TerminalResponse struct {
	Id string `json:"id"`
}

TerminalResponse is sent by handleExecShell. The Id is a random session id that binds the original REST request and the SockJS connection. Any clientapi in possession of this Id can hijack the terminal session.

type TerminalSession

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

TerminalSession implements PtyHandler (using a SockJS connection)

func (TerminalSession) Close

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

Close shuts down the SockJS connection and sends the status code and reason to the client Can happen if the process exits or if there is an error starting up the process For now the status code is unused and reason is shown to the user (unless "")

func (TerminalSession) Next

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

TerminalSize handles pty->process resize events Called in a loop from remotecommand as long as the process is running

func (TerminalSession) Read

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

Read handles pty->process messages (stdin, resize) Called in a loop from remotecommand as long as the process is running

func (TerminalSession) Toast

func (t TerminalSession) Toast(p string) error

Toast can be used to send the user any OOB messages hterm puts these in the center of the terminal

func (TerminalSession) Write

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

Write handles process->pty stdout Called from remotecommand whenever there is any output