client

package

v0.13.0 Latest Latest Go to latest Published: Jul 16, 2017 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ccdeer/frp

Links

Open Source Insights

Documentation ¶

Index ¶

func HandleTcpWorkConnection(localInfo *config.LocalSvrConf, proxyPlugin plugin.Plugin, ...)
type BaseProxy
type BaseVistor
type Control
- func NewControl(svr *Service, pxyCfgs map[string]config.ProxyConf, ...) *Control
- func (ctl *Control) Close() error
- func (ctl *Control) NewWorkConn()
- func (ctl *Control) Run() (err error)
type GeneralResponse
type HttpProxy
- func (pxy *HttpProxy) Close()
- func (pxy *HttpProxy) InWorkConn(conn frpNet.Conn)
- func (pxy *HttpProxy) Run() (err error)
type HttpsProxy
- func (pxy *HttpsProxy) Close()
- func (pxy *HttpsProxy) InWorkConn(conn frpNet.Conn)
- func (pxy *HttpsProxy) Run() (err error)
type Proxy
- func NewProxy(ctl *Control, pxyConf config.ProxyConf) (pxy Proxy)
type ReloadResp
type Service
- func NewService(pxyCfgs map[string]config.ProxyConf, vistorCfgs map[string]config.ProxyConf) (svr *Service)
- func (svr *Service) Close() error
- func (svr *Service) Run() error
- func (svr *Service) RunAdminServer(addr string, port int64) (err error)
type StcpProxy
- func (pxy *StcpProxy) Close()
- func (pxy *StcpProxy) InWorkConn(conn frpNet.Conn)
- func (pxy *StcpProxy) Run() (err error)
type StcpVistor
- func (sv *StcpVistor) Close()
- func (sv *StcpVistor) Run() (err error)
type TcpProxy
- func (pxy *TcpProxy) Close()
- func (pxy *TcpProxy) InWorkConn(conn frpNet.Conn)
- func (pxy *TcpProxy) Run() (err error)
type UdpProxy
- func (pxy *UdpProxy) Close()
- func (pxy *UdpProxy) InWorkConn(conn frpNet.Conn)
- func (pxy *UdpProxy) Run() (err error)
type Vistor
- func NewVistor(ctl *Control, pxyConf config.ProxyConf) (vistor Vistor)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func HandleTcpWorkConnection ¶

func HandleTcpWorkConnection(localInfo *config.LocalSvrConf, proxyPlugin plugin.Plugin,
	baseInfo *config.BaseProxyConf, workConn frpNet.Conn)

Common handler for tcp work connections.

Types ¶

type BaseProxy ¶

type BaseProxy struct {
	log.Logger
	// contains filtered or unexported fields
}

type BaseVistor ¶ added in v0.13.0

type BaseVistor struct {
	log.Logger
	// contains filtered or unexported fields
}

type Control ¶

type Control struct {
	log.Logger
	// contains filtered or unexported fields
}

func NewControl ¶

func NewControl(svr *Service, pxyCfgs map[string]config.ProxyConf, vistorCfgs map[string]config.ProxyConf) *Control

func (*Control) Close ¶ added in v0.13.0

func (ctl *Control) Close() error

func (*Control) NewWorkConn ¶

func (ctl *Control) NewWorkConn()

func (*Control) Run ¶

func (ctl *Control) Run() (err error)

1. login 2. start reader() writer() manager() 3. connection closed 4. In reader(): close closedCh and exit, controler() get it 5. In controler(): close readCh and sendCh, manager() and writer() will exit 6. In controler(): ini readCh, sendCh, closedCh 7. In controler(): start new reader(), writer(), manager() controler() will keep running

type GeneralResponse ¶ added in v0.13.0

type GeneralResponse struct {
	Code int64  `json:"code"`
	Msg  string `json:"msg"`
}

type HttpProxy ¶

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

HTTP

func (*HttpProxy) Close ¶

func (pxy *HttpProxy) Close()

func (*HttpProxy) InWorkConn ¶

func (pxy *HttpProxy) InWorkConn(conn frpNet.Conn)

func (*HttpProxy) Run ¶

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

type HttpsProxy ¶

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

HTTPS

func (*HttpsProxy) Close ¶

func (pxy *HttpsProxy) Close()

func (*HttpsProxy) InWorkConn ¶

func (pxy *HttpsProxy) InWorkConn(conn frpNet.Conn)

func (*HttpsProxy) Run ¶

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

type Proxy ¶

type Proxy interface {
	Run() error

	// InWorkConn accept work connections registered to server.
	InWorkConn(conn frpNet.Conn)
	Close()
	log.Logger
}

Proxy defines how to deal with work connections for different proxy type.

func NewProxy ¶

func NewProxy(ctl *Control, pxyConf config.ProxyConf) (pxy Proxy)

type ReloadResp ¶ added in v0.13.0

type ReloadResp struct {
	GeneralResponse
}

api/reload

type Service ¶

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

func NewService ¶

func NewService(pxyCfgs map[string]config.ProxyConf, vistorCfgs map[string]config.ProxyConf) (svr *Service)

func (*Service) Close ¶ added in v0.13.0

func (svr *Service) Close() error

func (*Service) Run ¶

func (svr *Service) Run() error

func (*Service) RunAdminServer ¶ added in v0.13.0

func (svr *Service) RunAdminServer(addr string, port int64) (err error)

type StcpProxy ¶ added in v0.13.0

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

STCP

func (*StcpProxy) Close ¶ added in v0.13.0

func (pxy *StcpProxy) Close()

func (*StcpProxy) InWorkConn ¶ added in v0.13.0

func (pxy *StcpProxy) InWorkConn(conn frpNet.Conn)

func (*StcpProxy) Run ¶ added in v0.13.0

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

type StcpVistor ¶ added in v0.13.0

type StcpVistor struct {
	BaseVistor
	// contains filtered or unexported fields
}

func (*StcpVistor) Close ¶ added in v0.13.0

func (sv *StcpVistor) Close()

func (*StcpVistor) Run ¶ added in v0.13.0

func (sv *StcpVistor) Run() (err error)

type TcpProxy ¶

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

TCP

func (*TcpProxy) Close ¶

func (pxy *TcpProxy) Close()

func (*TcpProxy) InWorkConn ¶

func (pxy *TcpProxy) InWorkConn(conn frpNet.Conn)

func (*TcpProxy) Run ¶

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

type UdpProxy ¶

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

UDP

func (*UdpProxy) Close ¶

func (pxy *UdpProxy) Close()

func (*UdpProxy) InWorkConn ¶

func (pxy *UdpProxy) InWorkConn(conn frpNet.Conn)

func (*UdpProxy) Run ¶

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

type Vistor ¶ added in v0.13.0

type Vistor interface {
	Run() error
	Close()
	log.Logger
}

Vistor is used for forward traffics from local port tot remote service.

func NewVistor ¶ added in v0.13.0

func NewVistor(ctl *Control, pxyConf config.ProxyConf) (vistor Vistor)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL