Documentation
¶
Index ¶
Constants ¶
View Source
const ( // StateStarting is the default/start state. Attaching will block until the // reconnecting pty becomes ready. StateStarting = iota // StateReady means the reconnecting pty is ready to be attached. StateReady // StateClosing means the reconnecting pty has begun closing. The underlying // process may still be exiting. Attaching will result in an error. StateClosing // StateDone means the reconnecting pty has completely shut down and the // process has exited. Attaching will result in an error. StateDone )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
// Timeout describes how long to keep the pty alive without any connections.
// Once elapsed the pty will be killed.
Timeout time.Duration
// Metrics tracks various error counters.
Metrics *prometheus.CounterVec
}
Options allows configuring the reconnecting pty.
type ReconnectingPTY ¶
type ReconnectingPTY interface {
// Attach pipes the connection and pty, spawning it if necessary, replays
// history, then blocks until EOF, an error, or the context's end. The
// connection is expected to send JSON-encoded messages and accept raw output
// from the ptty. If the context ends or the process dies the connection will
// be detached.
Attach(ctx context.Context, connID string, conn net.Conn, height, width uint16, logger slog.Logger) error
// Wait waits for the reconnecting pty to close. The underlying process might
// still be exiting.
Wait()
// Close kills the reconnecting pty process.
Close(err error)
}
ReconnectingPTY is a pty that can be reconnected within a timeout and to simultaneous connections. The reconnecting pty can be backed by screen if installed or a (buggy) buffer replay fallback.
func New ¶
New sets up a new reconnecting pty that wraps the provided command. Any errors with starting are returned on Attach(). The reconnecting pty will close itself (and all connections to it) if nothing is attached for the duration of the timeout, if the context ends, or the process exits (buffered backend only).
Source Files
Click to show internal directories.
Click to hide internal directories.