hub

Documentation

Index

• type SignalRServer
  • func NewSignalRServer(ctx context.Context, hub signalr.HubInterface, ...) (*SignalRServer, error)
  • func (s *SignalRServer) Handler(path string) app.HandlerFunc
  • func (s *SignalRServer) HubClients() signalr.HubClients
• type SimpleHub
  • func NewSimpleHub(nodeRepository *repository.NodeRepository, nodeManager *node.NodeManager) *SimpleHub
  • func (h *SimpleHub) OnConnected(connectionID string)
  • func (h *SimpleHub) OnDisconnected(connectionID string)
  • func (h *SimpleHub) ResizeDockerExec(cols int, rows int)
  • func (h *SimpleHub) ResizeSshSession(cols int, rows int)
  • func (h *SimpleHub) SendChatMessage(message string)
  • func (h *SimpleHub) SendDockerExecInput(data string)
  • func (h *SimpleHub) SendSshInput(data string)
  • func (h *SimpleHub) StartDockerExec(nodeID int64, containerID string, cols int, rows int, shell string) error
  • func (h *SimpleHub) StartSshSession(nodeID int64, cols int, rows int) error
  • func (h *SimpleHub) StopDockerExec()
  • func (h *SimpleHub) StopSshSession()

Types

type SignalRServer

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

func NewSignalRServer

func NewSignalRServer(ctx context.Context, hub signalr.HubInterface, opts ...func(signalr.Party) error) (*SignalRServer, error)

func (*SignalRServer) Handler

func (s *SignalRServer) Handler(path string) app.HandlerFunc

func (*SignalRServer) HubClients

func (s *SignalRServer) HubClients() signalr.HubClients

type SimpleHub

type SimpleHub struct {
	signalr.Hub
	// contains filtered or unexported fields
}

func NewSimpleHub

func NewSimpleHub(nodeRepository *repository.NodeRepository,
	nodeManager *node.NodeManager) *SimpleHub

func (*SimpleHub) OnConnected

func (h *SimpleHub) OnConnected(connectionID string)

func (*SimpleHub) OnDisconnected

func (h *SimpleHub) OnDisconnected(connectionID string)

func (*SimpleHub) ResizeDockerExec

func (h *SimpleHub) ResizeDockerExec(cols int, rows int)

func (*SimpleHub) ResizeSshSession

func (h *SimpleHub) ResizeSshSession(cols int, rows int)

ResizeSshSession resizes the remote PTY when the terminal window changes.

func (*SimpleHub) SendChatMessage

func (h *SimpleHub) SendChatMessage(message string)

func (*SimpleHub) SendDockerExecInput

func (h *SimpleHub) SendDockerExecInput(data string)

func (*SimpleHub) SendSshInput

func (h *SimpleHub) SendSshInput(data string)

SendSshInput writes user input from the client to the remote SSH session.

func (*SimpleHub) StartDockerExec

func (h *SimpleHub) StartDockerExec(nodeID int64, containerID string, cols int, rows int, shell string) error

func (*SimpleHub) StartSshSession

func (h *SimpleHub) StartSshSession(nodeID int64, cols int, rows int) error

StartSshSession establishes an interactive SSH session for the current SignalR connection. nodeID identifies the target node, cols/rows configure the PTY size.

func (*SimpleHub) StopDockerExec

func (h *SimpleHub) StopDockerExec()

func (*SimpleHub) StopSshSession

func (h *SimpleHub) StopSshSession()

StopSshSession terminates the SSH session associated with the current connection.