Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proxy

package

Go to main page

Versions in this module

v0

v0.100.1

Jun 23, 2024

v0.100.0

Jun 23, 2024

Changes in this version

+ const ProxyPhaseCheckFailed

+ const ProxyPhaseClosed

+ const ProxyPhaseNew

+ const ProxyPhaseRunning

+ const ProxyPhaseStartErr

+ const ProxyPhaseWaitStart

+ func RegisterProxyFactory(proxyConfType reflect.Type, factory func(*BaseProxy, v1.ProxyConfigurer) 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

+ func (pxy *BaseProxy) SetInWorkConnCallback(cb func(*v1.ProxyBaseConfig, net.Conn, *msg.StartWorkConn) bool)

+ type GeneralTCPProxy struct

+ type Manager struct

+ func NewManager(ctx context.Context, clientCfg *v1.ClientCommonConfig, ...) *Manager

+ func (pm *Manager) Close()

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

+ func (pm *Manager) GetProxyStatus(name string) (*WorkingStatus, bool)

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

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

+ func (pm *Manager) SetInWorkConnCallback(cb func(*v1.ProxyBaseConfig, net.Conn, *msg.StartWorkConn) bool)

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

+ func (pm *Manager) UpdateAll(proxyCfgs []v1.ProxyConfigurer)

type Proxy

+ func NewGeneralTCPProxy(baseProxy *BaseProxy, _ v1.ProxyConfigurer) Proxy

+ func NewSUDPProxy(baseProxy *BaseProxy, cfg v1.ProxyConfigurer) Proxy

+ func NewUDPProxy(baseProxy *BaseProxy, cfg v1.ProxyConfigurer) Proxy

+ func NewXTCPProxy(baseProxy *BaseProxy, cfg v1.ProxyConfigurer) Proxy

+ SetInWorkConnCallback func(func(*v1.ProxyBaseConfig, net.Conn, *msg.StartWorkConn) bool)

+ type SUDPProxy struct

+ func (pxy *SUDPProxy) Close()

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

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

+ type UDPProxy struct

+ func (pxy *UDPProxy) Close()

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

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

+ type WorkingStatus struct

+ Cfg v1.ProxyConfigurer

+ Err string

+ Name string

+ Phase string

+ RemoteAddr string

+ Type string

+ type Wrapper struct

+ func NewWrapper(ctx context.Context, cfg v1.ProxyConfigurer, clientCfg *v1.ClientCommonConfig, ...) *Wrapper

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

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

+ func (pw *Wrapper) SetInWorkConnCallback(cb func(*v1.ProxyBaseConfig, net.Conn, *msg.StartWorkConn) bool)

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

+ func (pw *Wrapper) Start()

+ func (pw *Wrapper) Stop()

+ type XTCPProxy struct

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

v0.23.1

Jan 16, 2019

v0.23.0

Jan 15, 2019

v0.22.0

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)