proxy

package
v0.48.3 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ProxyPhaseNew         = "new"
	ProxyPhaseWaitStart   = "wait start"
	ProxyPhaseStartErr    = "start error"
	ProxyPhaseRunning     = "running"
	ProxyPhaseCheckFailed = "check failed"
	ProxyPhaseClosed      = "closed"
)

Variables

This section is empty.

Functions

func HandleTCPWorkConnection added in v0.48.2 

func HandleTCPWorkConnection(ctx context.Context, localInfo *config.LocalSvrConf, proxyPlugin plugin.Plugin,
	baseInfo *config.BaseProxyConf, limiter *rate.Limiter, workConn net.Conn, encKey []byte, m *msg.StartWorkConn,
)

Common handler for tcp work connections.

Types

type BaseProxy 

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

type HTTPProxy added in v0.48.2 

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

HTTP

func (*HTTPProxy) Close added in v0.48.2 

func (pxy *HTTPProxy) Close()

func (*HTTPProxy) InWorkConn added in v0.48.2 

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

func (*HTTPProxy) Run added in v0.48.2 

func (pxy *HTTPProxy) Run() (err error)

type HTTPSProxy added in v0.48.2 

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

HTTPS

func (*HTTPSProxy) Close added in v0.48.2 

func (pxy *HTTPSProxy) Close()

func (*HTTPSProxy) InWorkConn added in v0.48.2 

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

func (*HTTPSProxy) Run added in v0.48.2 

func (pxy *HTTPSProxy) Run() (err error)

type Manager added in v0.48.2 

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

func NewManager added in v0.48.2 

func NewManager(ctx context.Context, msgSendCh chan (msg.Message), clientCfg config.ClientCommonConf, serverUDPPort int) *Manager

func (*Manager) Close added in v0.48.2 

func (pm *Manager) Close()

func (*Manager) GetAllProxyStatus added in v0.48.2 

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

func (*Manager) HandleEvent added in v0.48.2 

func (pm *Manager) HandleEvent(payload interface{}) error

func (*Manager) HandleWorkConn added in v0.48.2 

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

func (*Manager) Reload added in v0.48.2 

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

func (*Manager) StartProxy added in v0.48.2 

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

type Proxy 

type Proxy interface {
	Run() error

	// InWorkConn accept work connections registered to server.
	InWorkConn(net.Conn, *msg.StartWorkConn)

	Close()
}

Proxy defines how to handle work connections for different proxy type.

func NewProxy 

func NewProxy(ctx context.Context, pxyConf config.ProxyConf, clientCfg config.ClientCommonConf, serverUDPPort int) (pxy Proxy)

type STCPProxy added in v0.48.2 

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

STCP

func (*STCPProxy) Close added in v0.48.2 

func (pxy *STCPProxy) Close()

func (*STCPProxy) InWorkConn added in v0.48.2 

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

func (*STCPProxy) Run added in v0.48.2 

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

type SUDPProxy added in v0.48.2 

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

func (*SUDPProxy) Close added in v0.48.2 

func (pxy *SUDPProxy) Close()

func (*SUDPProxy) InWorkConn added in v0.48.2 

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

func (*SUDPProxy) Run added in v0.48.2 

func (pxy *SUDPProxy) Run() (err error)

type TCPMuxProxy added in v0.48.2 

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

TCP Multiplexer

func (*TCPMuxProxy) Close added in v0.48.2 

func (pxy *TCPMuxProxy) Close()

func (*TCPMuxProxy) InWorkConn added in v0.48.2 

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

func (*TCPMuxProxy) Run added in v0.48.2 

func (pxy *TCPMuxProxy) Run() (err error)

type TCPProxy added in v0.48.2 

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

TCP

func (*TCPProxy) Close added in v0.48.2 

func (pxy *TCPProxy) Close()

func (*TCPProxy) InWorkConn added in v0.48.2 

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

func (*TCPProxy) Run added in v0.48.2 

func (pxy *TCPProxy) Run() (err error)

type UDPProxy added in v0.48.2 

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

UDP

func (*UDPProxy) Close added in v0.48.2 

func (pxy *UDPProxy) Close()

func (*UDPProxy) InWorkConn added in v0.48.2 

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

func (*UDPProxy) Run added in v0.48.2 

func (pxy *UDPProxy) Run() (err error)

type WorkingStatus added in v0.48.2 

type WorkingStatus struct {
	Name  string           `json:"name"`
	Type  string           `json:"type"`
	Phase string           `json:"status"`
	Err   string           `json:"err"`
	Cfg   config.ProxyConf `json:"cfg"`

	// Got from server.
	RemoteAddr string `json:"remote_addr"`
}

type Wrapper added in v0.48.2 

type Wrapper struct {
	WorkingStatus
	// contains filtered or unexported fields
}

func NewWrapper added in v0.48.2 

func NewWrapper(ctx context.Context, cfg config.ProxyConf, clientCfg config.ClientCommonConf, eventHandler event.Handler, serverUDPPort int) *Wrapper

func (*Wrapper) GetStatus added in v0.48.2 

func (pw *Wrapper) GetStatus() *WorkingStatus

func (*Wrapper) InWorkConn added in v0.48.2 

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

func (*Wrapper) SetRunningStatus added in v0.48.2 

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

func (*Wrapper) Start added in v0.48.2 

func (pw *Wrapper) Start()

func (*Wrapper) Stop added in v0.48.2 

func (pw *Wrapper) Stop()

type XTCPProxy added in v0.48.2 

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

XTCP

func (*XTCPProxy) Close added in v0.48.2 

func (pxy *XTCPProxy) Close()

func (*XTCPProxy) InWorkConn added in v0.48.2 

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

func (*XTCPProxy) Run added in v0.48.2 

func (pxy *XTCPProxy) Run() (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.