wsremotecommand

Documentation

Index

• type Executor
  • func NewWebSocketExecutor(config *rest.Config, url *url.URL, protocols []string) (*Executor, error)
  • func (e *Executor) Close() error
  • func (e *Executor) Stream(options StreamOptions) error
• type StreamOptions
• type WebSocketUpgrader
  • func RoundTripperFor(config *rest.Config) (*WebSocketUpgrader, http.RoundTripper, error)
  • func (w *WebSocketUpgrader) RoundTrip(r *http.Request) (*http.Response, error)

Types

type Executor

type Executor struct {
	Upgrader *WebSocketUpgrader
	// contains filtered or unexported fields
}

func NewWebSocketExecutor

func NewWebSocketExecutor(config *rest.Config, url *url.URL, protocols []string) (*Executor, error)

func (*Executor) Close

func (e *Executor) Close() error

Close send the 'exit\r\n' command to k8s if recevied the kill or exit signal, cleanup the tty process in container.

func (*Executor) Stream

func (e *Executor) Stream(options StreamOptions) error

type StreamOptions

type StreamOptions struct {
	Stdin *websocket.Conn
}

StreamOptions holds information pertaining to the current streaming session: input/output streams

type WebSocketUpgrader

type WebSocketUpgrader struct {

	// Dialer is the dialer used to connect.  Used if non-nil.
	Dialer *websocket.Dialer

	Conn *websocket.Conn

	Header http.Header
	// contains filtered or unexported fields
}

WebSocketUpgrade knows how to upgrade an HTTP request to one that supports multiplexed streams. After RoundTrip() is invoked, Conn will be set and usable.

func RoundTripperFor

func RoundTripperFor(config *rest.Config) (*WebSocketUpgrader, http.RoundTripper, error)

RoundTripperFor returns a http header with the rest config.

func (*WebSocketUpgrader) RoundTrip

func (w *WebSocketUpgrader) RoundTrip(r *http.Request) (*http.Response, error)