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.48.3

Apr 3, 2023

v0.48.2

Apr 3, 2023

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(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)

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)