group

Nov 4, 2021

Changes in this version

+ var ErrProxyRepeated = errors.New("group proxy repeated")

+ type HTTPGroup struct

+ func NewHTTPGroup(ctl *HTTPGroupController) *HTTPGroup

+ func (g *HTTPGroup) Register(proxyName, group, groupKey string, routeConfig vhost.RouteConfig) (err error)

+ func (g *HTTPGroup) UnRegister(proxyName string) (isEmpty bool)

+ type HTTPGroupController struct

+ func NewHTTPGroupController(vhostRouter *vhost.Routers) *HTTPGroupController

+ func (ctl *HTTPGroupController) Register(proxyName, group, groupKey string, routeConfig vhost.RouteConfig) (err error)

+ func (ctl *HTTPGroupController) UnRegister(proxyName, group, domain, location string)

+ type TCPGroup struct

+ func NewTCPGroup(ctl *TCPGroupCtl) *TCPGroup

+ func (tg *TCPGroup) Accept() <-chan net.Conn

+ func (tg *TCPGroup) CloseListener(ln *TCPGroupListener)

+ func (tg *TCPGroup) Listen(proxyName string, group string, groupKey string, addr string, port int) (ln *TCPGroupListener, realPort int, err error)

+ type TCPGroupCtl struct

+ func NewTCPGroupCtl(portManager *ports.Manager) *TCPGroupCtl

+ func (tgc *TCPGroupCtl) Listen(proxyName string, group string, groupKey string, addr string, port int) (l net.Listener, realPort int, err error)

+ func (tgc *TCPGroupCtl) RemoveGroup(group string)

+ type TCPGroupListener struct

+ func (ln *TCPGroupListener) Accept() (c net.Conn, err error)

+ func (ln *TCPGroupListener) Addr() net.Addr

+ func (ln *TCPGroupListener) Close() (err error)

+ type TCPMuxGroup struct

+ func NewTCPMuxGroup(ctl *TCPMuxGroupCtl) *TCPMuxGroup

+ func (tmg *TCPMuxGroup) Accept() <-chan net.Conn

+ func (tmg *TCPMuxGroup) CloseListener(ln *TCPMuxGroupListener)

+ func (tmg *TCPMuxGroup) HTTPConnectListen(ctx context.Context, group string, groupKey string, domain string) (ln *TCPMuxGroupListener, err error)

+ type TCPMuxGroupCtl struct

+ func NewTCPMuxGroupCtl(tcpMuxHTTPConnectMuxer *tcpmux.HTTPConnectTCPMuxer) *TCPMuxGroupCtl

+ func (tmgc *TCPMuxGroupCtl) Listen(ctx context.Context, multiplexer string, group string, groupKey string, ...) (l net.Listener, err error)

+ func (tmgc *TCPMuxGroupCtl) RemoveGroup(group string)

+ type TCPMuxGroupListener struct

+ func (ln *TCPMuxGroupListener) Accept() (c net.Conn, err error)

+ func (ln *TCPMuxGroupListener) Addr() net.Addr

+ func (ln *TCPMuxGroupListener) Close() (err error)

Dec 9, 2018

Changes in this version

+ var ErrGroupDifferentPort = errors.New("group should have same remote port")

May 31, 2018

Changes in this version

+ var ErrGroupAuthFailed = errors.New("group auth failed")

+ var ErrGroupParamsInvalid = errors.New("group params invalid")

+ var ErrListenerClosed = errors.New("group listener closed")

+ type TcpGroup struct

+ func NewTcpGroup(ctl *TcpGroupCtl) *TcpGroup

+ func (tg *TcpGroup) Accept() <-chan net.Conn

+ func (tg *TcpGroup) CloseListener(ln *TcpGroupListener)

+ func (tg *TcpGroup) Listen(proxyName string, group string, groupKey string, addr string, port int) (ln *TcpGroupListener, realPort int, err error)

+ type TcpGroupCtl struct

+ func NewTcpGroupCtl(portManager *ports.PortManager) *TcpGroupCtl

+ func (tgc *TcpGroupCtl) Listen(proxyNanme string, group string, groupKey string, addr string, port int) (l net.Listener, realPort int, err error)

+ func (tgc *TcpGroupCtl) RemoveGroup(group string)

+ type TcpGroupListener struct

+ func (ln *TcpGroupListener) Accept() (c net.Conn, err error)

+ func (ln *TcpGroupListener) Addr() net.Addr

+ func (ln *TcpGroupListener) Close() (err error)