Documentation
¶
Index ¶
- type LocalPTYSession
- type RemoteInstaller
- type SSHClient
- type SSHSession
- type Session
- type SessionEntry
- type SessionHandler
- type SessionWrapper
- type Sessions
- func (sm *Sessions) ActiveSessionCount() int
- func (sm *Sessions) GetScreenshotPort(sessionID string) (int, bool)
- func (sm *Sessions) RegisterSession(sessionID string, session Session)
- func (sm *Sessions) RemoveSession(sessionID string)
- func (sm *Sessions) SetScreenshotPort(sessionID string, port int)
- func (sm *Sessions) Shutdown()
- func (sm *Sessions) UpdateActivity(sessionID string)
- func (sm *Sessions) WrapSession(sessionID string, session Session) *SessionWrapper
- type WebTerminalServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LocalPTYSession ¶
type LocalPTYSession struct {
// contains filtered or unexported fields
}
LocalPTYSession represents a single local terminal session
func NewLocalPTYSession ¶
func NewLocalPTYSession(cfg *config.Config) *LocalPTYSession
func (*LocalPTYSession) Close ¶
func (s *LocalPTYSession) Close() error
Close terminates the PTY session
func (*LocalPTYSession) HandleConnection ¶
func (s *LocalPTYSession) HandleConnection(conn *websocket.Conn) error
func (*LocalPTYSession) Resize ¶
func (s *LocalPTYSession) Resize(cols, rows int) error
Resize changes the PTY window size
func (*LocalPTYSession) Start ¶
func (s *LocalPTYSession) Start(cols, rows int) error
type RemoteInstaller ¶
type RemoteInstaller struct {
// contains filtered or unexported fields
}
RemoteInstaller handles auto-installation of infer binary on remote servers
func NewRemoteInstaller ¶
func NewRemoteInstaller(client *SSHClient, cfg *config.WebSSHConfig, server *config.SSHServerConfig, gatewayURL string, progressCh chan<- string) *RemoteInstaller
NewRemoteInstaller creates a new remote installer
func (*RemoteInstaller) EnsureBinary ¶
func (i *RemoteInstaller) EnsureBinary() error
EnsureBinary checks if infer exists on remote server, installs if missing
type SSHClient ¶
type SSHClient struct {
// contains filtered or unexported fields
}
SSHClient manages SSH connections to remote servers
func NewSSHClient ¶
func NewSSHClient(cfg *config.WebSSHConfig, server *config.SSHServerConfig) (*SSHClient, error)
NewSSHClient creates an SSH client for the specified server
type SSHSession ¶
type SSHSession struct {
// contains filtered or unexported fields
}
SSHSession wraps an SSH session with PTY for remote terminal access
func NewSSHSession ¶
func NewSSHSession(client *SSHClient, server *config.SSHServerConfig, gatewayURL string, sessionID string, sessionManager *Sessions) (*SSHSession, error)
NewSSHSession creates a new SSH session with PTY
func (*SSHSession) HandleConnection ¶
func (s *SSHSession) HandleConnection(conn *websocket.Conn) error
HandleConnection bridges WebSocket and SSH session I/O
func (*SSHSession) Resize ¶
func (s *SSHSession) Resize(cols, rows int) error
Resize changes the PTY window size
func (*SSHSession) SetupPortForwarding ¶
func (s *SSHSession) SetupPortForwarding(remotePort int) (int, error)
SetupPortForwarding sets up SSH port forwarding from local to remote port
func (*SSHSession) Start ¶
func (s *SSHSession) Start(cols, rows int) error
Start executes "infer chat" on the remote server with PTY
type SessionEntry ¶
type SessionEntry struct {
// contains filtered or unexported fields
}
SessionEntry tracks a session and its activity
type SessionHandler ¶
type SessionHandler interface {
Start(cols, rows int) error
Resize(cols, rows int) error
HandleConnection(conn *websocket.Conn) error
Close() error
}
SessionHandler interface for both local PTY and remote SSH sessions
func CreateSessionHandler ¶
func CreateSessionHandler(webCfg *config.WebConfig, serverCfg *config.SSHServerConfig, cfg *config.Config, sessionID string, sessionManager *Sessions, progressCh chan<- string) (SessionHandler, error)
CreateSessionHandler creates either a local PTY session or remote SSH session
type SessionWrapper ¶
type SessionWrapper struct {
// contains filtered or unexported fields
}
SessionWrapper wraps a session to track activity
func (*SessionWrapper) HandleConnection ¶
func (sh *SessionWrapper) HandleConnection(conn *websocket.Conn) error
type Sessions ¶ added in v0.207.0
type Sessions struct {
// contains filtered or unexported fields
}
Sessions tracks and manages all active sessions
func NewSessions ¶ added in v0.207.0
func (*Sessions) ActiveSessionCount ¶ added in v0.207.0
ActiveSessionCount returns the number of currently active sessions
func (*Sessions) GetScreenshotPort ¶ added in v0.207.0
GetScreenshotPort retrieves the local screenshot port for a session
func (*Sessions) RegisterSession ¶ added in v0.207.0
RegisterSession registers an existing session with the manager
func (*Sessions) RemoveSession ¶ added in v0.207.0
RemoveSession removes and stops a session
func (*Sessions) SetScreenshotPort ¶ added in v0.207.0
SetScreenshotPort sets the local screenshot port for a session
func (*Sessions) Shutdown ¶ added in v0.207.0
func (sm *Sessions) Shutdown()
Shutdown stops all sessions and the cleanup goroutine. Call exactly once: a second call panics on close of the done channel.
func (*Sessions) UpdateActivity ¶ added in v0.207.0
UpdateActivity updates the last activity time for a session
func (*Sessions) WrapSession ¶ added in v0.207.0
func (sm *Sessions) WrapSession(sessionID string, session Session) *SessionWrapper
type WebTerminalServer ¶
type WebTerminalServer struct {
// contains filtered or unexported fields
}
func NewWebTerminalServer ¶
func NewWebTerminalServer(cfg *config.Config) *WebTerminalServer
func (*WebTerminalServer) Start ¶
func (s *WebTerminalServer) Start() error
Source Files