Versions in this module Expand all Collapse all v0 v0.30.2 Nov 7, 2020 v0.30.1 Nov 6, 2020 Changes in this version + type BaseOutConf struct + type Control struct + func NewControl(ctx context.Context, rc *controller.ResourceController, ...) *Control + func (ctl *Control) CloseProxy(closeMsg *msg.CloseProxy) (err error) + func (ctl *Control) GetWorkConn() (workConn net.Conn, err error) + func (ctl *Control) RegisterProxy(pxyMsg *msg.NewProxy) (remoteAddr string, err error) + func (ctl *Control) RegisterWorkConn(conn net.Conn) + func (ctl *Control) Replaced(newCtl *Control) + func (ctl *Control) Start() + func (ctl *Control) WaitClosed() + type ControlManager struct + func NewControlManager() *ControlManager + func (cm *ControlManager) Add(runId string, ctl *Control) (oldCtl *Control) + func (cm *ControlManager) Del(runId string, ctl *Control) + func (cm *ControlManager) GetById(runId string) (ctl *Control, ok bool) + type GeneralResponse struct + Code int + Msg string + type GetProxyInfoResp struct + Proxies []*ProxyStatsInfo + type GetProxyStatsResp struct + Conf interface{} + CurConns int64 + LastCloseTime string + LastStartTime string + Name string + Status string + TodayTrafficIn int64 + TodayTrafficOut int64 + type GetProxyTrafficResp struct + Name string + TrafficIn []int64 + TrafficOut []int64 + type HttpOutConf struct + HostHeaderRewrite string + Locations []string + type HttpsOutConf struct + type ProxyStatsInfo struct + Conf interface{} + CurConns int64 + LastCloseTime string + LastStartTime string + Name string + Status string + TodayTrafficIn int64 + TodayTrafficOut int64 + type ServerInfoResp struct + BindPort int + BindUdpPort int + ClientCounts int64 + CurConns int64 + HeartBeatTimeout int64 + KcpBindPort int + MaxPoolCount int64 + MaxPortsPerClient int64 + ProxyTypeCounts map[string]int64 + SubdomainHost string + TotalTrafficIn int64 + TotalTrafficOut int64 + Version string + VhostHttpPort int + VhostHttpsPort int + type Service struct + Closed bool + func NewService(cfg config.ServerCommonConf) (svr *Service, err error) + func (svr *Service) ApiProxyByType(w http.ResponseWriter, r *http.Request) + func (svr *Service) ApiProxyByTypeAndName(w http.ResponseWriter, r *http.Request) + func (svr *Service) ApiProxyTraffic(w http.ResponseWriter, r *http.Request) + func (svr *Service) ApiServerInfo(w http.ResponseWriter, r *http.Request) + func (svr *Service) HandleListener(l net.Listener) + func (svr *Service) RegisterControl(ctlConn net.Conn, loginMsg *msg.Login) (err error) + func (svr *Service) RegisterVisitorConn(visitorConn net.Conn, newMsg *msg.NewVisitorConn) error + func (svr *Service) RegisterWorkConn(workConn net.Conn, newMsg *msg.NewWorkConn) + func (svr *Service) Run() + func (svr *Service) RunDashboardServer(addr string, port int) (err error) + func (svr *Service) Stop() error + type StcpOutConf struct + type TcpOutConf struct + RemotePort int + type UdpOutConf struct + RemotePort int + type XtcpOutConf struct