proxy

package
v0.52.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 8, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterProxyFactory added in v0.52.4 

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

Types

type BaseProxy 

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

func (*BaseProxy) Close 

func (pxy *BaseProxy) Close()

func (*BaseProxy) Context added in v0.52.4 

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

func (*BaseProxy) GetConfigurer added in v0.52.4 

func (pxy *BaseProxy) GetConfigurer() v1.ProxyConfigurer

func (*BaseProxy) GetLimiter added in v0.52.4 

func (pxy *BaseProxy) GetLimiter() *rate.Limiter

func (*BaseProxy) GetLoginMsg added in v0.52.4 

func (pxy *BaseProxy) GetLoginMsg() *msg.Login

func (*BaseProxy) GetName 

func (pxy *BaseProxy) GetName() string

func (*BaseProxy) GetResourceController added in v0.52.4 

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

func (*BaseProxy) GetUsedPortsNum 

func (pxy *BaseProxy) GetUsedPortsNum() int

func (*BaseProxy) GetUserInfo added in v0.52.4 

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 added in v0.52.4 

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

func (*HTTPProxy) Close added in v0.52.4 

func (pxy *HTTPProxy) Close()

func (*HTTPProxy) GetRealConn added in v0.52.4 

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

func (*HTTPProxy) Run added in v0.52.4 

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

type HTTPSProxy added in v0.52.4 

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

func (*HTTPSProxy) Close added in v0.52.4 

func (pxy *HTTPSProxy) Close()

func (*HTTPSProxy) Run added in v0.52.4 

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

type Manager added in v0.52.4 

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

func NewManager added in v0.52.4 

func NewManager() *Manager

func (*Manager) Add added in v0.52.4 

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

func (*Manager) Del added in v0.52.4 

func (pm *Manager) Del(name string)

func (*Manager) Exist added in v0.52.4 

func (pm *Manager) Exist(name string) bool

func (*Manager) GetByName added in v0.52.4 

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

type Options added in v0.52.4 

type Options struct {
	UserInfo           plugin.UserInfo
	LoginMsg           *msg.Login
	PoolCount          int
	ResourceController *controller.ResourceController
	GetWorkConnFn      GetWorkConnFn
	Configurer         v1.ProxyConfigurer
	ServerCfg          *v1.ServerConfig
}

type Proxy 

type Proxy interface {
	Context() context.Context
	Run() (remoteAddr string, err error)
	GetName() string
	GetConfigurer() v1.ProxyConfigurer
	GetWorkConnFromPool(src, dst net.Addr) (workConn net.Conn, err error)
	GetUsedPortsNum() int
	GetResourceController() *controller.ResourceController
	GetUserInfo() plugin.UserInfo
	GetLimiter() *rate.Limiter
	GetLoginMsg() *msg.Login
	Close()
}

func NewHTTPProxy added in v0.52.4 

func NewHTTPProxy(baseProxy *BaseProxy) Proxy

func NewHTTPSProxy added in v0.52.4 

func NewHTTPSProxy(baseProxy *BaseProxy) Proxy

func NewProxy 

func NewProxy(ctx context.Context, options *Options) (pxy Proxy, err error)

func NewSTCPProxy added in v0.52.4 

func NewSTCPProxy(baseProxy *BaseProxy) Proxy

func NewSUDPProxy added in v0.52.4 

func NewSUDPProxy(baseProxy *BaseProxy) Proxy

func NewTCPMuxProxy added in v0.52.4 

func NewTCPMuxProxy(baseProxy *BaseProxy) Proxy

func NewTCPProxy added in v0.52.4 

func NewTCPProxy(baseProxy *BaseProxy) Proxy

func NewUDPProxy added in v0.52.4 

func NewUDPProxy(baseProxy *BaseProxy) Proxy

func NewXTCPProxy added in v0.52.4 

func NewXTCPProxy(baseProxy *BaseProxy) Proxy

type STCPProxy added in v0.52.4 

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

func (*STCPProxy) Close added in v0.52.4 

func (pxy *STCPProxy) Close()

func (*STCPProxy) Run added in v0.52.4 

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

type SUDPProxy added in v0.52.4 

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

func (*SUDPProxy) Close added in v0.52.4 

func (pxy *SUDPProxy) Close()

func (*SUDPProxy) Run added in v0.52.4 

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

type TCPMuxProxy added in v0.52.4 

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

func (*TCPMuxProxy) Close added in v0.52.4 

func (pxy *TCPMuxProxy) Close()

func (*TCPMuxProxy) Run added in v0.52.4 

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

type TCPProxy added in v0.52.4 

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

func (*TCPProxy) Close added in v0.52.4 

func (pxy *TCPProxy) Close()

func (*TCPProxy) Run added in v0.52.4 

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

type UDPProxy added in v0.52.4 

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

func (*UDPProxy) Close added in v0.52.4 

func (pxy *UDPProxy) Close()

func (*UDPProxy) Run added in v0.52.4 

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

type XTCPProxy added in v0.52.4 

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

func (*XTCPProxy) Close added in v0.52.4 

func (pxy *XTCPProxy) Close()

func (*XTCPProxy) Run added in v0.52.4 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.