utils

Oct 24, 2020

Changes in this version

type SSHConnection

+ SetupLock *sync.Mutex

Jun 16, 2020

Changes in this version

+ func LoadProxyProtoConfig(l *proxyproto.Listener)

May 30, 2020

Changes in this version

+ var Filter *ipfilter.IPFilter

+ func CheckPort(port uint32, portRanges string) (uint32, error)

+ func CommaSplitFields(c rune) bool

+ func CopyBoth(writer net.Conn, reader io.ReadWriteCloser)

+ func GetRandomPortInRange(portRange string) uint32

+ func GetSSHConfig() *ssh.ServerConfig

+ func RandStringBytesMaskImprSrc(n int) string

+ func Setup(logWriter io.Writer)

+ func WatchCerts()

+ type AliasHolder struct

+ AliasHost string

+ Balancer *roundrobin.RoundRobin

+ SSHConnections *sync.Map

+ func GetOpenAlias(addr string, port string, state *State, sshConn *SSHConnection) (string, *AliasHolder)

+ type HTTPHolder struct

+ Balancer *roundrobin.RoundRobin

+ Forward *forward.Forwarder

+ HTTPHost string

+ SSHConnections *sync.Map

+ Scheme string

+ func GetOpenHost(addr string, state *State, sshConn *SSHConnection) (string, *HTTPHolder)

+ type IdleTimeoutConn struct

+ Conn net.Conn

+ func (i IdleTimeoutConn) Read(buf []byte) (int, error)

+ func (i IdleTimeoutConn) Write(buf []byte) (int, error)

+ type ListenerHolder struct

+ ListenAddr string

+ SSHConn *SSHConnection

+ Type ListenerType

+ type ListenerType int

+ const AliasListener

+ const HTTPListener

+ const ProcessListener

+ const TCPListener

+ type LogWriter struct

+ MultiWriter io.Writer

+ TimeFmt string

+ func (w LogWriter) Write(bytes []byte) (int, error)

+ type SSHConnection struct

+ CleanupHandler bool

+ Close chan bool

+ Closed *sync.Once

+ Listeners *sync.Map

+ Messages chan string

+ ProxyProto byte

+ SSHConn *ssh.ServerConn

+ Session chan bool

+ func (s *SSHConnection) CleanUp(state *State)

+ func (s *SSHConnection) SendMessage(message string, block bool)

+ type State struct

+ AliasListeners *sync.Map

+ Console *WebConsole

+ HTTPListeners *sync.Map

+ IPFilter *ipfilter.IPFilter

+ Listeners *sync.Map

+ LogWriter io.Writer

+ SSHConnections *sync.Map

+ TCPListeners *sync.Map

+ func NewState() *State

+ type TCPHolder struct

+ Balancer *roundrobin.RoundRobin

+ Listener net.Listener

+ SSHConnections *sync.Map

+ TCPHost string

+ func GetOpenPort(addr string, port uint32, state *State, sshConn *SSHConnection) (string, uint32, *TCPHolder)

+ func (tH *TCPHolder) Handle(state *State)

+ type WebClient struct

+ Conn *websocket.Conn

+ Console *WebConsole

+ Route string

+ Send chan []byte

+ func (c *WebClient) Handle()

+ type WebConsole struct

+ Clients *sync.Map

+ RouteTokens *sync.Map

+ State *State

+ func NewWebConsole() *WebConsole

+ func (c *WebConsole) AddClient(route string, w *WebClient)

+ func (c *WebConsole) AddRoute(route string, token string)

+ func (c *WebConsole) BroadcastRoute(route string, message []byte)

+ func (c *WebConsole) HandleClients(hostname string, g *gin.Context)

+ func (c *WebConsole) HandleDisconnectClient(hostname string, g *gin.Context)

+ func (c *WebConsole) HandleDisconnectRoute(hostname string, g *gin.Context)

+ func (c *WebConsole) HandleRequest(hostname string, hostIsRoot bool, g *gin.Context)

+ func (c *WebConsole) HandleTemplate(hostname string, hostIsRoot bool, userIsAdmin bool, g *gin.Context)

+ func (c *WebConsole) HandleWebSocket(hostname string, g *gin.Context)

+ func (c *WebConsole) RemoveClient(route string, w *WebClient)

+ func (c *WebConsole) RemoveRoute(route string)

+ func (c *WebConsole) RouteExists(route string) bool

+ func (c *WebConsole) RouteToken(route string) (string, bool)