hosts

package
v0.4.4-rc1 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2021 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BinaryWriter added in v0.4.3 

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

func NewBinaryWriter added in v0.4.3 

func NewBinaryWriter(con *websocket.Conn) *BinaryWriter

func (*BinaryWriter) Write added in v0.4.3 

func (s *BinaryWriter) Write(p []byte) (int, error)

type Dialer 

type Dialer interface {
	SetIO(stdout, stderr io.Writer, stdin io.ReadCloser)
	SetWindowSize(height, weight int)
	ChangeWindowSize(win *WindowSize) error
	OpenTerminal() error
	Wait() error
	Write(b []byte) error
	Close() error
}

type DockerDialer added in v0.4.3 

type DockerDialer struct {
	Stdin  io.ReadCloser
	Stdout io.Writer
	Stderr io.Writer
	Writer io.Writer

	Height int
	Weight int
	// contains filtered or unexported fields
}

func NewDockerDialer added in v0.4.3 

func NewDockerDialer(n *types.Node) (*DockerDialer, error)

func (*DockerDialer) ChangeWindowSize added in v0.4.4 

func (d *DockerDialer) ChangeWindowSize(win *WindowSize) error

ChangeWindowSize change tty window size for websocket.

func (*DockerDialer) Close added in v0.4.3 

func (d *DockerDialer) Close() error

Close close the Docker connection.

func (*DockerDialer) ExecStart added in v0.4.3 

func (d *DockerDialer) ExecStart(needRestore bool) error

ExecStart handles setting up the IO and then begins streaming stdin/stdout to/from the hijacked connection, blocking until it is either done reading output, the user inputs the detach key sequence when in TTY mode, or when the given context is cancelled. Borrowed from https://github.com/docker/cli/blob/master/cli/command/container/hijack.go#L40.

func (*DockerDialer) MonitorTtySize added in v0.4.3 

func (d *DockerDialer) MonitorTtySize(ctx context.Context) error

MonitorTtySize monitor and change tty size. Borrowed from https://github.com/docker/cli/blob/master/cli/command/container/tty.go#L71.

func (*DockerDialer) OpenTerminal added in v0.4.4 

func (d *DockerDialer) OpenTerminal() error

WebSocketTerminal open docker websocket terminal.

func (*DockerDialer) ResizeTty added in v0.4.3 

func (d *DockerDialer) ResizeTty(ctx context.Context) error

ResizeTty changes to the current win size.

func (*DockerDialer) ResizeTtyTo added in v0.4.3 

func (d *DockerDialer) ResizeTtyTo(ctx context.Context, height, width uint) error

ResizeTtyTo changes the size of the tty for an exec process running inside a container.

func (*DockerDialer) SetIO added in v0.4.4 

func (d *DockerDialer) SetIO(stdout, stderr io.Writer, stdin io.ReadCloser)

SetIO set dialer's reader and writer.

func (*DockerDialer) SetStdio added in v0.4.3 

func (d *DockerDialer) SetStdio(stdout, stderr io.Writer, stdin io.ReadCloser) *DockerDialer

SetStdio set dialer's reader and writer.

func (*DockerDialer) SetWindowSize added in v0.4.4 

func (d *DockerDialer) SetWindowSize(height, weight int)

SetWindowSize set dialer's default win size.

func (*DockerDialer) SetWriter added in v0.4.3 

func (d *DockerDialer) SetWriter(w io.Writer) *DockerDialer

SetWriter set dialer's logs writer.

func (*DockerDialer) Terminal added in v0.4.3 

func (d *DockerDialer) Terminal() error

Terminal open docker exec terminal.

func (*DockerDialer) Wait added in v0.4.4 

func (d *DockerDialer) Wait() error

Borrowed from https://github.com/docker/cli/blob/master/cli/command/container/exec.go#L180.

func (*DockerDialer) Write added in v0.4.4 

func (d *DockerDialer) Write(b []byte) error

type PtyDialer added in v0.4.3 

type PtyDialer struct {
	Stdin  io.ReadCloser
	Stdout io.Writer
	Stderr io.Writer
	Writer io.Writer

	Height int
	Weight int
	// contains filtered or unexported fields
}

func NewPtyDialer added in v0.4.3 

func NewPtyDialer(cmd *exec.Cmd) (*PtyDialer, error)

func (*PtyDialer) ChangeWindowSize added in v0.4.4 

func (d *PtyDialer) ChangeWindowSize(win *WindowSize) error

ChangeWindowSize changes to the current window size.

func (*PtyDialer) Close added in v0.4.3 

func (d *PtyDialer) Close() error

Close close the pty connection.

func (*PtyDialer) OpenTerminal added in v0.4.4 

func (d *PtyDialer) OpenTerminal() error

OpenTerminal open pty websocket terminal.

func (*PtyDialer) SetIO added in v0.4.4 

func (d *PtyDialer) SetIO(stdout, stderr io.Writer, stdin io.ReadCloser)

SetIO set dialer's reader and writer.

func (*PtyDialer) SetWindowSize added in v0.4.4 

func (d *PtyDialer) SetWindowSize(height, weight int)

SetWindowSize set tty window size size.

func (*PtyDialer) Wait added in v0.4.4 

func (d *PtyDialer) Wait() error

Wait waits for the command to exit.

func (*PtyDialer) Write added in v0.4.4 

func (d *PtyDialer) Write(b []byte) error

type SSHDialer 

type SSHDialer struct {
	Stdin  io.ReadCloser
	Stdout io.Writer
	Stderr io.Writer
	Writer io.Writer

	Height int
	Weight int

	Term  string
	Modes ssh.TerminalModes
	// contains filtered or unexported fields
}

func NewSSHDialer added in v0.4.3 

func NewSSHDialer(n *types.Node, timeout bool) (*SSHDialer, error)

func (*SSHDialer) ChangeWindowSize added in v0.4.4 

func (d *SSHDialer) ChangeWindowSize(win *WindowSize) error

ChangeWindowSize change the window size for current session.

func (*SSHDialer) Close added in v0.4.3 

func (d *SSHDialer) Close() error

Close close the SSH connection.

func (*SSHDialer) Cmd added in v0.4.3 

func (d *SSHDialer) Cmd(cmd string) *SSHDialer

Cmd pass commands in dialer, support multiple calls, e.g. d.Cmd("ls").Cmd("id").

func (*SSHDialer) Dial added in v0.4.3 

func (d *SSHDialer) Dial(t bool) (*ssh.Client, error)

Dial handshake with ssh address.

func (*SSHDialer) NewSession added in v0.4.4 

func (d *SSHDialer) NewSession() error

func (*SSHDialer) OpenTerminal added in v0.4.4 

func (d *SSHDialer) OpenTerminal() error

OpenTerminal starts a login shell on the remote host.

func (*SSHDialer) Run added in v0.4.3 

func (d *SSHDialer) Run() error

Run commands in remote server via SSH tunnel.

func (*SSHDialer) SetIO added in v0.4.4 

func (d *SSHDialer) SetIO(stdout, stderr io.Writer, stdin io.ReadCloser)

SetStdio set dialer's reader and writer.

func (*SSHDialer) SetStdio added in v0.4.3 

func (d *SSHDialer) SetStdio(stdout, stderr io.Writer, stdin io.ReadCloser) *SSHDialer

SetStdio set dialer's reader and writer.

func (*SSHDialer) SetWindowSize added in v0.4.4 

func (d *SSHDialer) SetWindowSize(height, weight int)

SetDefaultSize set dialer's default window size.

func (*SSHDialer) SetWriter added in v0.4.3 

func (d *SSHDialer) SetWriter(w io.Writer) *SSHDialer

SetWriter set dialer's logs writer.

func (*SSHDialer) Terminal added in v0.4.3 

func (d *SSHDialer) Terminal() error

Terminal starts a login shell on the remote host for CLI.

func (*SSHDialer) Wait added in v0.4.4 

func (d *SSHDialer) Wait() error

Wait waits for the remote command to exit.

func (*SSHDialer) Write added in v0.4.4 

func (d *SSHDialer) Write(b []byte) error

type TerminalReader added in v0.4.3 

type TerminalReader struct {
	ClosedCh chan bool
	// contains filtered or unexported fields
}

func NewTerminalReader added in v0.4.3 

func NewTerminalReader(con *websocket.Conn) *TerminalReader

func (*TerminalReader) Close added in v0.4.3 

func (t *TerminalReader) Close() error

func (*TerminalReader) Read added in v0.4.3 

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

func (*TerminalReader) SetResizeFunction added in v0.4.3 

func (t *TerminalReader) SetResizeFunction(resizeFun func(size *WindowSize))

type WebSocketDialer added in v0.4.3 

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

func NewWebSocketDialer added in v0.4.3 

func NewWebSocketDialer(conn *websocket.Conn, dialer Dialer) *WebSocketDialer

func (*WebSocketDialer) ChangeWindowSize added in v0.4.3 

func (d *WebSocketDialer) ChangeWindowSize(win *WindowSize)

ChangeWindowSize change websocket win size.

func (*WebSocketDialer) Close added in v0.4.3 

func (d *WebSocketDialer) Close()

Close close the WebSocket connection.

func (*WebSocketDialer) ReadMessage added in v0.4.3 

func (d *WebSocketDialer) ReadMessage(ctx context.Context) error

ReadMessage read websocket message.

func (*WebSocketDialer) SetDefaultSize added in v0.4.3 

func (d *WebSocketDialer) SetDefaultSize(height, weight int)

SetDefaultSize set dialer's default window size.

func (*WebSocketDialer) Terminal added in v0.4.3 

func (d *WebSocketDialer) Terminal() error

Terminal open websocket terminal.

func (*WebSocketDialer) Write added in v0.4.3 

func (d *WebSocketDialer) Write(bytes []byte) error

Write write bytes to the websocket connection.

type WindowSize added in v0.4.3 

type WindowSize struct {
	Width  int
	Height int
}

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.