Versions in this module Expand all Collapse all v0 v0.42.0 May 14, 2022 Changes in this version + var ErrGroupAuthFailed = errors.New("group auth failed") + var ErrGroupDifferentPort = errors.New("group should have same remote port") + var ErrGroupParamsInvalid = errors.New("group params invalid") + var ErrListenerClosed = errors.New("group listener closed") + 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)