proxy

Documentation

Index

• func HandleUserTCPConnection(pxy Proxy, userConn net.Conn, serverCfg config.ServerCommonConf)
• type BaseProxy
  • func (pxy *BaseProxy) Close()
  • func (pxy *BaseProxy) Context() context.Context
  • func (pxy *BaseProxy) GetName() string
  • func (pxy *BaseProxy) GetResourceController() *controller.ResourceController
  • func (pxy *BaseProxy) GetUsedPortsNum() int
  • func (pxy *BaseProxy) GetUserInfo() plugin.UserInfo
  • func (pxy *BaseProxy) GetWorkConnFromPool(src, dst net.Addr) (workConn net.Conn, err error)
• type GetWorkConnFn
• type HTTPProxy
  • func (pxy *HTTPProxy) Close()
  • func (pxy *HTTPProxy) GetConf() config.ProxyConf
  • func (pxy *HTTPProxy) GetRealConn(remoteAddr string) (workConn net.Conn, err error)
  • func (pxy *HTTPProxy) Run() (remoteAddr string, err error)
• type HTTPSProxy
  • func (pxy *HTTPSProxy) Close()
  • func (pxy *HTTPSProxy) GetConf() config.ProxyConf
  • func (pxy *HTTPSProxy) Run() (remoteAddr string, err error)
• type Manager
  • func NewManager() *Manager
  • func (pm *Manager) Add(name string, pxy Proxy) error
  • func (pm *Manager) Del(name string)
  • func (pm *Manager) GetByName(name string) (pxy Proxy, ok bool)
• type Proxy
  • func NewProxy(ctx context.Context, userInfo plugin.UserInfo, ...) (pxy Proxy, err error)
• type STCPProxy
  • func (pxy *STCPProxy) Close()
  • func (pxy *STCPProxy) GetConf() config.ProxyConf
  • func (pxy *STCPProxy) Run() (remoteAddr string, err error)
• type SUDPProxy
  • func (pxy *SUDPProxy) Close()
  • func (pxy *SUDPProxy) GetConf() config.ProxyConf
  • func (pxy *SUDPProxy) Run() (remoteAddr string, err error)
• type TCPMuxProxy
  • func (pxy *TCPMuxProxy) Close()
  • func (pxy *TCPMuxProxy) GetConf() config.ProxyConf
  • func (pxy *TCPMuxProxy) Run() (remoteAddr string, err error)
• type TCPProxy
  • func (pxy *TCPProxy) Close()
  • func (pxy *TCPProxy) GetConf() config.ProxyConf
  • func (pxy *TCPProxy) Run() (remoteAddr string, err error)
• type UDPProxy
  • func (pxy *UDPProxy) Close()
  • func (pxy *UDPProxy) GetConf() config.ProxyConf
  • func (pxy *UDPProxy) Run() (remoteAddr string, err error)
• type XTCPProxy
  • func (pxy *XTCPProxy) Close()
  • func (pxy *XTCPProxy) GetConf() config.ProxyConf
  • func (pxy *XTCPProxy) Run() (remoteAddr string, err error)

Functions

func HandleUserTCPConnection

func HandleUserTCPConnection(pxy Proxy, userConn net.Conn, serverCfg config.ServerCommonConf)

HandleUserTCPConnection is used for incoming user TCP connections. It can be used for tcp, http, https type.

Types

type BaseProxy

type BaseProxy struct {
	// contains filtered or unexported fields
}

func (*BaseProxy) Close

func (pxy *BaseProxy) Close()

func (*BaseProxy) Context

func (pxy *BaseProxy) Context() context.Context

func (*BaseProxy) GetName

func (pxy *BaseProxy) GetName() string

func (*BaseProxy) GetResourceController

func (pxy *BaseProxy) GetResourceController() *controller.ResourceController

func (*BaseProxy) GetUsedPortsNum

func (pxy *BaseProxy) GetUsedPortsNum() int

func (*BaseProxy) GetUserInfo

func (pxy *BaseProxy) GetUserInfo() plugin.UserInfo

func (*BaseProxy) GetWorkConnFromPool

func (pxy *BaseProxy) GetWorkConnFromPool(src, dst net.Addr) (workConn net.Conn, err error)

GetWorkConnFromPool try to get a new work connections from pool for quickly response, we immediately send the StartWorkConn message to frpc after take out one from pool

type GetWorkConnFn

type GetWorkConnFn func() (net.Conn, error)

type HTTPProxy

type HTTPProxy struct {
	*BaseProxy
	// contains filtered or unexported fields
}

func (*HTTPProxy) Close

func (pxy *HTTPProxy) Close()

func (*HTTPProxy) GetConf

func (pxy *HTTPProxy) GetConf() config.ProxyConf

func (*HTTPProxy) GetRealConn

func (pxy *HTTPProxy) GetRealConn(remoteAddr string) (workConn net.Conn, err error)

func (*HTTPProxy) Run

func (pxy *HTTPProxy) Run() (remoteAddr string, err error)

type HTTPSProxy

type HTTPSProxy struct {
	*BaseProxy
	// contains filtered or unexported fields
}

func (*HTTPSProxy) Close

func (pxy *HTTPSProxy) Close()

func (*HTTPSProxy) GetConf

func (pxy *HTTPSProxy) GetConf() config.ProxyConf

func (*HTTPSProxy) Run

func (pxy *HTTPSProxy) Run() (remoteAddr string, err error)

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager() *Manager

func (*Manager) Add

func (pm *Manager) Add(name string, pxy Proxy) error

func (*Manager) Del

func (pm *Manager) Del(name string)

func (*Manager) GetByName

func (pm *Manager) GetByName(name string) (pxy Proxy, ok bool)

type Proxy

type Proxy interface {
	Context() context.Context
	Run() (remoteAddr string, err error)
	GetName() string
	GetConf() config.ProxyConf
	GetWorkConnFromPool(src, dst net.Addr) (workConn net.Conn, err error)
	GetUsedPortsNum() int
	GetResourceController() *controller.ResourceController
	GetUserInfo() plugin.UserInfo
	Close()
}

func NewProxy

func NewProxy(ctx context.Context, userInfo plugin.UserInfo, rc *controller.ResourceController, poolCount int,
	getWorkConnFn GetWorkConnFn, pxyConf config.ProxyConf, serverCfg config.ServerCommonConf) (pxy Proxy, err error)

type STCPProxy

type STCPProxy struct {
	*BaseProxy
	// contains filtered or unexported fields
}

func (*STCPProxy) Close

func (pxy *STCPProxy) Close()

func (*STCPProxy) GetConf

func (pxy *STCPProxy) GetConf() config.ProxyConf

func (*STCPProxy) Run

func (pxy *STCPProxy) Run() (remoteAddr string, err error)

type SUDPProxy

type SUDPProxy struct {
	*BaseProxy
	// contains filtered or unexported fields
}

func (*SUDPProxy) Close

func (pxy *SUDPProxy) Close()

func (*SUDPProxy) GetConf

func (pxy *SUDPProxy) GetConf() config.ProxyConf

func (*SUDPProxy) Run

func (pxy *SUDPProxy) Run() (remoteAddr string, err error)

type TCPMuxProxy

type TCPMuxProxy struct {
	*BaseProxy
	// contains filtered or unexported fields
}

func (*TCPMuxProxy) Close

func (pxy *TCPMuxProxy) Close()

func (*TCPMuxProxy) GetConf

func (pxy *TCPMuxProxy) GetConf() config.ProxyConf

func (*TCPMuxProxy) Run

func (pxy *TCPMuxProxy) Run() (remoteAddr string, err error)

type TCPProxy

type TCPProxy struct {
	*BaseProxy
	// contains filtered or unexported fields
}

func (*TCPProxy) Close

func (pxy *TCPProxy) Close()

func (*TCPProxy) GetConf

func (pxy *TCPProxy) GetConf() config.ProxyConf

func (*TCPProxy) Run

func (pxy *TCPProxy) Run() (remoteAddr string, err error)

type UDPProxy

type UDPProxy struct {
	*BaseProxy
	// contains filtered or unexported fields
}

func (*UDPProxy) Close

func (pxy *UDPProxy) Close()

func (*UDPProxy) GetConf

func (pxy *UDPProxy) GetConf() config.ProxyConf

func (*UDPProxy) Run

func (pxy *UDPProxy) Run() (remoteAddr string, err error)

type XTCPProxy

type XTCPProxy struct {
	*BaseProxy
	// contains filtered or unexported fields
}

func (*XTCPProxy) Close

func (pxy *XTCPProxy) Close()

func (*XTCPProxy) GetConf

func (pxy *XTCPProxy) GetConf() config.ProxyConf

func (*XTCPProxy) Run

func (pxy *XTCPProxy) Run() (remoteAddr string, err error)