Versions in this module Expand all Collapse all v0 v0.36.2 Jan 15, 2022 Changes in this version + type BaseVisitor struct + type ByProxyStatusResp []ProxyStatusResp + func (a ByProxyStatusResp) Len() int + func (a ByProxyStatusResp) Less(i, j int) bool + func (a ByProxyStatusResp) Swap(i, j int) + type Control struct + ProxyFunc func(err error) + func NewControl(ctx context.Context, runID string, conn net.Conn, session *fmux.Session, ...) *Control + func (ctl *Control) Close() error + func (ctl *Control) ClosedDoneCh() <-chan struct{} + func (ctl *Control) HandleNewProxyResp(inMsg *msg.NewProxyResp) + func (ctl *Control) HandleReqWorkConn(inMsg *msg.ReqWorkConn) + func (ctl *Control) ReloadConf(pxyCfgs map[string]config.ProxyConf, visitorCfgs map[string]config.VisitorConf) error + func (ctl *Control) Run() + type GeneralResponse struct + Code int + Msg string + type ProxyStatusResp struct + Err string + LocalAddr string + Name string + Plugin string + RemoteAddr string + Status string + Type string + func NewProxyStatusResp(status *proxy.WorkingStatus, serverAddr string) ProxyStatusResp + type STCPVisitor struct + func (sv *STCPVisitor) Close() + func (sv *STCPVisitor) Run() (err error) + type SUDPVisitor struct + func (sv *SUDPVisitor) Close() + func (sv *SUDPVisitor) Run() (err error) + type Service struct + ReConnectByCount bool + func NewService(cfg config.ClientCommonConf, pxyCfgs map[string]config.ProxyConf, ...) (svr *Service, err error) + func (svr *Service) Close() + func (svr *Service) GetController() *Control + func (svr *Service) IsClosed() bool + func (svr *Service) ReloadConf(pxyCfgs map[string]config.ProxyConf, visitorCfgs map[string]config.VisitorConf) error + func (svr *Service) Run(isCmd bool) error + func (svr *Service) RunAdminServer(address string) (err error) + func (svr *Service) SetOnCloseListener(listener ServiceClosedListener) + func (svr *Service) SetProxyFailedFunc(proxyFailedFunc func(err error)) + type ServiceClosedListener interface + OnClosed func(msg string) + type StatusResp struct + HTTP []ProxyStatusResp + HTTPS []ProxyStatusResp + STCP []ProxyStatusResp + SUDP []ProxyStatusResp + TCP []ProxyStatusResp + UDP []ProxyStatusResp + XTCP []ProxyStatusResp + type Visitor interface + Close func() + Run func() error + func NewVisitor(ctx context.Context, ctl *Control, cfg config.VisitorConf) (visitor Visitor) + type VisitorManager struct + func NewVisitorManager(ctx context.Context, ctl *Control) *VisitorManager + func (vm *VisitorManager) Close() + func (vm *VisitorManager) Reload(cfgs map[string]config.VisitorConf) + func (vm *VisitorManager) Run() + type XTCPVisitor struct + func (sv *XTCPVisitor) Close() + func (sv *XTCPVisitor) Run() (err error)