proxy

Jul 19, 2023

Changes in this version

+ func RegisterProxyFactory(proxyConfType reflect.Type, factory func(*BaseProxy, config.ProxyConf) Proxy)

type BaseProxy

+ func (pxy *BaseProxy) Close()

+ func (pxy *BaseProxy) HandleTCPWorkConnection(workConn net.Conn, m *msg.StartWorkConn, encKey []byte)

+ func (pxy *BaseProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn)

+ func (pxy *BaseProxy) Run() error

+ type GeneralTCPProxy struct

type Proxy

+ func NewGeneralTCPProxy(baseProxy *BaseProxy, cfg config.ProxyConf) Proxy

+ func NewSUDPProxy(baseProxy *BaseProxy, cfg config.ProxyConf) Proxy

+ func NewUDPProxy(baseProxy *BaseProxy, cfg config.ProxyConf) Proxy

+ func NewXTCPProxy(baseProxy *BaseProxy, cfg config.ProxyConf) Proxy

Nov 4, 2021

Changes in this version

+ const ProxyPhaseCheckFailed

+ const ProxyPhaseClosed

+ const ProxyPhaseNew

+ const ProxyPhaseRunning

+ const ProxyPhaseStartErr

+ const ProxyPhaseWaitStart

+ func HandleTCPWorkConnection(ctx context.Context, localInfo *config.LocalSvrConf, proxyPlugin plugin.Plugin, ...)

+ 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 Manager struct

+ func NewManager(ctx context.Context, msgSendCh chan (msg.Message), ...) *Manager

+ func (pm *Manager) Close()

+ func (pm *Manager) GetAllProxyStatus() []*WorkingStatus

+ func (pm *Manager) HandleEvent(evType event.Type, payload interface{}) error

+ func (pm *Manager) HandleWorkConn(name string, workConn net.Conn, m *msg.StartWorkConn)

+ func (pm *Manager) Reload(pxyCfgs map[string]config.ProxyConf)

+ func (pm *Manager) StartProxy(name string, remoteAddr string, serverRespErr string) error

+ type STCPProxy struct

+ func (pxy *STCPProxy) Close()

+ func (pxy *STCPProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn)

+ func (pxy *STCPProxy) Run() (err error)

+ type SUDPProxy struct

+ func (pxy *SUDPProxy) Close()

+ func (pxy *SUDPProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn)

+ func (pxy *SUDPProxy) 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 WorkingStatus struct

+ Cfg config.ProxyConf

+ Err string

+ Name string

+ Phase string

+ RemoteAddr string

+ Type string

+ type Wrapper struct

+ func NewWrapper(ctx context.Context, cfg config.ProxyConf, clientCfg config.ClientCommonConf, ...) *Wrapper

+ func (pw *Wrapper) GetStatus() *WorkingStatus

+ func (pw *Wrapper) InWorkConn(workConn net.Conn, m *msg.StartWorkConn)

+ func (pw *Wrapper) SetRunningStatus(remoteAddr string, respErr string) error

+ func (pw *Wrapper) Start()

+ func (pw *Wrapper) Stop()

+ type XTCPProxy struct

+ func (pxy *XTCPProxy) Close()

+ func (pxy *XTCPProxy) InWorkConn(conn net.Conn, m *msg.StartWorkConn)

+ func (pxy *XTCPProxy) Run() (err error)

Dec 9, 2018

Changes in this version

+ const ProxyStatusCheckFailed

+ const ProxyStatusClosed

+ const ProxyStatusNew

+ const ProxyStatusRunning

+ const ProxyStatusStartErr

+ const ProxyStatusWaitStart

+ func HandleTcpWorkConnection(localInfo *config.LocalSvrConf, proxyPlugin plugin.Plugin, ...)

+ type BaseProxy struct

+ type HttpProxy struct

+ func (pxy *HttpProxy) Close()

+ func (pxy *HttpProxy) InWorkConn(conn frpNet.Conn)

+ func (pxy *HttpProxy) Run() (err error)

+ type HttpsProxy struct

+ func (pxy *HttpsProxy) Close()

+ func (pxy *HttpsProxy) InWorkConn(conn frpNet.Conn)

+ func (pxy *HttpsProxy) Run() (err error)

+ type Proxy interface

+ Close func()

+ InWorkConn func(conn frpNet.Conn)

+ Run func() error

+ func NewProxy(pxyConf config.ProxyConf) (pxy Proxy)

+ type ProxyManager struct

+ func NewProxyManager(msgSendCh chan (msg.Message), logPrefix string) *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 frpNet.Conn)

+ 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(cfg config.ProxyConf, eventHandler event.EventHandler, logPrefix string) *ProxyWrapper

+ func (pw *ProxyWrapper) GetStatus() *ProxyStatus

+ func (pw *ProxyWrapper) InWorkConn(workConn frpNet.Conn)

+ 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 frpNet.Conn)

+ func (pxy *StcpProxy) Run() (err error)

+ type TcpProxy struct

+ func (pxy *TcpProxy) Close()

+ func (pxy *TcpProxy) InWorkConn(conn frpNet.Conn)

+ func (pxy *TcpProxy) Run() (err error)

+ type UdpProxy struct

+ func (pxy *UdpProxy) Close()

+ func (pxy *UdpProxy) InWorkConn(conn frpNet.Conn)

+ func (pxy *UdpProxy) Run() (err error)

+ type XtcpProxy struct

+ func (pxy *XtcpProxy) Close()

+ func (pxy *XtcpProxy) InWorkConn(conn frpNet.Conn)

+ func (pxy *XtcpProxy) Run() (err error)