Versions in this module Expand all Collapse all v0 v0.32.3 Nov 7, 2020 v0.32.2 Nov 6, 2020 Changes in this version + const ProxyStatusCheckFailed + const ProxyStatusClosed + const ProxyStatusNew + const ProxyStatusRunning + const ProxyStatusStartErr + const ProxyStatusWaitStart + func HandleTcpWorkConnection(ctx context.Context, localInfo *config.LocalSvrConf, proxyPlugin plugin.Plugin, ...) + type BaseProxy struct + type HttpProxy struct + func (pxy *HttpProxy) Close() + func (pxy *HttpProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn) + func (pxy *HttpProxy) Run() (err error) + type HttpsProxy struct + func (pxy *HttpsProxy) Close() + func (pxy *HttpsProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn) + func (pxy *HttpsProxy) Run() (err error) + type Proxy interface + Close func() + InWorkConn func(net.Conn, *msg.StartWorkConn) + Run func() error + func NewProxy(ctx context.Context, pxyConf config.ProxyConf, ...) (pxy Proxy) + type ProxyManager struct + func NewProxyManager(ctx context.Context, msgSendCh chan (msg.Message), ...) *ProxyManager + func (pm *ProxyManager) Close() + func (pm *ProxyManager) GetAllProxyStatus() []*ProxyStatus + func (pm *ProxyManager) HandleEvent(evType event.EventType, payload interface{}) error + func (pm *ProxyManager) HandleWorkConn(name string, workConn net.Conn, m *msg.StartWorkConn) + func (pm *ProxyManager) Reload(pxyCfgs map[string]config.ProxyConf) + func (pm *ProxyManager) StartProxy(name string, remoteAddr string, serverRespErr string) error + type ProxyStatus struct + Cfg config.ProxyConf + Err string + Name string + RemoteAddr string + Status string + Type string + type ProxyWrapper struct + func NewProxyWrapper(ctx context.Context, cfg config.ProxyConf, clientCfg config.ClientCommonConf, ...) *ProxyWrapper + func (pw *ProxyWrapper) GetStatus() *ProxyStatus + func (pw *ProxyWrapper) InWorkConn(workConn net.Conn, m *msg.StartWorkConn) + func (pw *ProxyWrapper) SetRunningStatus(remoteAddr string, respErr string) error + func (pw *ProxyWrapper) Start() + func (pw *ProxyWrapper) Stop() + type StcpProxy struct + func (pxy *StcpProxy) Close() + func (pxy *StcpProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn) + func (pxy *StcpProxy) Run() (err error) + type TcpMuxProxy struct + func (pxy *TcpMuxProxy) Close() + func (pxy *TcpMuxProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn) + func (pxy *TcpMuxProxy) Run() (err error) + type TcpProxy struct + func (pxy *TcpProxy) Close() + func (pxy *TcpProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn) + func (pxy *TcpProxy) Run() (err error) + type UdpProxy struct + func (pxy *UdpProxy) Close() + func (pxy *UdpProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn) + func (pxy *UdpProxy) Run() (err error) + type XtcpProxy struct + func (pxy *XtcpProxy) Close() + func (pxy *XtcpProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn) + func (pxy *XtcpProxy) Run() (err error)
Go to main page