server

Dec 8, 2023

Changes in this version

type Control

+ func (ctl *Control) Close() error

+ func (ctl *Control) HandleNatHoleClient(m *msg.NatHoleClient)

+ func (ctl *Control) HandleNatHoleReport(m *msg.NatHoleReport)

+ func (ctl *Control) HandleNatHoleVisitor(m *msg.NatHoleVisitor)

type ControlManager

+ func (cm *ControlManager) Close() error

+ func (cm *ControlManager) GetByID(runID string) (ctl *Control, ok bool)

+ type HTTPOutConf struct

+ HostHeaderRewrite string

+ Locations []string

+ type HTTPSOutConf struct

type ProxyStatsInfo

+ ClientVersion string

+ type STCPOutConf struct

type Service

+ 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) Close() error

+ func (svr *Service) HandleQUICListener(l *quic.Listener)

+ func (svr *Service) Healthz(w http.ResponseWriter, _ *http.Request)

+ type TCPMuxOutConf struct

+ Multiplexer string

+ type TCPOutConf struct

+ RemotePort int

+ type UDPOutConf struct

+ RemotePort int

+ type XTCPOutConf struct

Jan 15, 2019

Changes in this version

type Control

+ func (ctl *Control) WaitClosed()

type ControlManager

+ func (cm *ControlManager) Del(runId string)

type Service

+ 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) RunDashboardServer(addr string, port int) (err error)

May 31, 2018

Changes in this version

+ type BaseOutConf struct

+ type HttpOutConf struct

+ HostHeaderRewrite string

+ Locations []string

+ type HttpsOutConf struct

+ type StcpOutConf struct

+ type TcpOutConf struct

+ RemotePort int

+ type UdpOutConf struct

+ RemotePort int

+ type XtcpOutConf struct

May 14, 2018

Changes in this version

type ServerInfoResp

+ BindPort int

+ BindUdpPort int

+ KcpBindPort int

+ MaxPortsPerClient int64

Apr 23, 2018

Changes in this version

+ type GetProxyStatsResp struct

+ Conf config.ProxyConf

+ CurConns int64

+ LastCloseTime string

+ LastStartTime string

+ Name string

+ Status string

+ TodayTrafficIn int64

+ TodayTrafficOut int64

type ProxyStats

+ func StatsGetProxiesByTypeAndName(proxyType string, proxyName string) (res *ProxyStats)

Jan 29, 2018

Changes in this version

type BaseProxy

+ func (pxy *BaseProxy) GetUsedPortsNum() int

type Proxy

+ GetUsedPortsNum func() int

Jan 18, 2018

Changes in this version

+ const CleanReservedPortsInterval

+ const MaxPort

+ const MaxPortReservedDuration

+ const MinPort

+ var ErrNoAvailablePort = errors.New("no available port")

+ var ErrPortAlreadyUsed = errors.New("port already used")

+ var ErrPortNotAllowed = errors.New("port not allowed")

+ var ErrPortUnAvailable = errors.New("port unavailable")

+ type PortCtx struct

+ Closed bool

+ Port int

+ ProxyName string

+ UpdateTime time.Time

+ type PortManager struct

+ func NewPortManager(netType string, bindAddr string, allowPorts map[int]struct{}) *PortManager

+ func (pm *PortManager) Acquire(name string, port int) (realPort int, err error)

+ func (pm *PortManager) Release(port int)

Dec 14, 2017

Changes in this version

type HttpProxy

+ func (pxy *HttpProxy) GetRealConn() (workConn frpNet.Conn, err error)

Dec 4, 2017

Changes in this version

+ var NatHoleTimeout int64 = 10

+ type NatHoleClientCfg struct

+ Name string

+ SidCh chan string

+ Sk string

+ type NatHoleController struct

+ func NewNatHoleController(udpBindAddr string) (nc *NatHoleController, err error)

+ func (nc *NatHoleController) CloseClient(name string)

+ func (nc *NatHoleController) GenNatHoleResponse(raddr *net.UDPAddr, session *NatHoleSession) []byte

+ func (nc *NatHoleController) GenSid() string

+ func (nc *NatHoleController) HandleClient(m *msg.NatHoleClient, raddr *net.UDPAddr)

+ func (nc *NatHoleController) HandleVisitor(m *msg.NatHoleVisitor, raddr *net.UDPAddr)

+ func (nc *NatHoleController) ListenClient(name string, sk string) (sidCh chan string)

+ func (nc *NatHoleController) Run()

+ type NatHoleSession struct

+ ClientAddr *net.UDPAddr

+ NotifyCh chan struct{}

+ Sid string

+ VisitorAddr *net.UDPAddr

type Service

+ func (svr *Service) RegisterVisitorConn(visitorConn frpNet.Conn, newMsg *msg.NewVisitorConn) error

+ type VisitorManager struct

+ func NewVisitorManager() *VisitorManager

+ func (vm *VisitorManager) CloseListener(name string)

+ func (vm *VisitorManager) Listen(name string, sk string) (l *frpNet.CustomListener, err error)

+ func (vm *VisitorManager) NewConn(name string, conn frpNet.Conn, timestamp int64, signKey string, ...) (err error)

+ type XtcpProxy struct

+ func (pxy *XtcpProxy) Close()

+ func (pxy *XtcpProxy) GetConf() config.ProxyConf

+ func (pxy *XtcpProxy) Run() error

Jul 16, 2017

Changes in this version

type Service

+ func (svr *Service) RegisterVistorConn(vistorConn frpNet.Conn, newMsg *msg.NewVistorConn) error

+ type StcpProxy struct

+ func (pxy *StcpProxy) Close()

+ func (pxy *StcpProxy) GetConf() config.ProxyConf

+ func (pxy *StcpProxy) Run() error

+ type VistorManager struct

+ func NewVistorManager() *VistorManager

+ func (vm *VistorManager) CloseListener(name string)

+ func (vm *VistorManager) Listen(name string, sk string) (l *frpNet.CustomListener, err error)

+ func (vm *VistorManager) NewConn(name string, conn frpNet.Conn, timestamp int64, signKey string, ...) (err error)

Jun 19, 2017

Changes in this version

type Control

+ func (ctl *Control) CloseProxy(closeMsg *msg.CloseProxy) (err error)

type Service

+ func (svr *Service) HandleListener(l frpNet.Listener)

Jun 1, 2017

Changes in this version

+ func MakeGzipHandler(h http.Handler) http.Handler

+ func StatsClearUselessInfo()

+ type GzipWraper struct

+ func (gw *GzipWraper) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ProxyStatistics

+ LastCloseTime time.Time

+ LastStartTime time.Time

+ Name string

type ProxyStats

+ LastCloseTime string

+ LastStartTime string

type ProxyStatsInfo

+ LastCloseTime string

+ LastStartTime string

type ServerInfoResp

+ Version string

May 20, 2017

Changes in this version

+ const ReserveDays

+ func HandleUserTcpConnection(pxy Proxy, userConn frpNet.Conn)

+ func RunDashboardServer(addr string, port int64) (err error)

+ func StatsAddTrafficIn(name string, trafficIn int64)

+ func StatsAddTrafficOut(name string, trafficOut int64)

+ func StatsCloseClient()

+ func StatsCloseConnection(name string)

+ func StatsCloseProxy(proxyType string)

+ func StatsNewClient()

+ func StatsNewProxy(name string, proxyType string)

+ func StatsOpenConnection(name string)

+ type AuthWraper struct

+ func (aw *AuthWraper) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type BaseProxy struct

+ func (pxy *BaseProxy) Close()

+ func (pxy *BaseProxy) GetControl() *Control

+ func (pxy *BaseProxy) GetName() string

+ func (pxy *BaseProxy) GetWorkConnFromPool() (workConn frpNet.Conn, err error)

+ type Control struct

+ func NewControl(svr *Service, ctlConn net.Conn, loginMsg *msg.Login) *Control

+ func (ctl *Control) GetWorkConn() (workConn net.Conn, err error)

+ func (ctl *Control) RegisterProxy(pxyMsg *msg.NewProxy) (err error)

+ func (ctl *Control) RegisterWorkConn(conn net.Conn)

+ func (ctl *Control) Replaced(newCtl *Control)

+ func (ctl *Control) Start()

+ type ControlManager struct

+ func NewControlManager() *ControlManager

+ func (cm *ControlManager) Add(runId string, ctl *Control) (oldCtl *Control)

+ func (cm *ControlManager) GetById(runId string) (ctl *Control, ok bool)

+ type GeneralResponse struct

+ Code int64

+ Msg string

+ type GetProxyInfoResp struct

+ Proxies []*ProxyStatsInfo

+ type GetProxyTrafficResp struct

+ Name string

+ TrafficIn []int64

+ TrafficOut []int64

+ type HttpProxy struct

+ func (pxy *HttpProxy) Close()

+ func (pxy *HttpProxy) GetConf() config.ProxyConf

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

+ type HttpsProxy struct

+ func (pxy *HttpsProxy) Close()

+ func (pxy *HttpsProxy) GetConf() config.ProxyConf

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

+ type Proxy interface

+ Close func()

+ GetConf func() config.ProxyConf

+ GetControl func() *Control

+ GetName func() string

+ GetWorkConnFromPool func() (workConn frpNet.Conn, err error)

+ Run func() error

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

+ type ProxyManager struct

+ func NewProxyManager() *ProxyManager

+ func (pm *ProxyManager) Add(name string, pxy Proxy) error

+ func (pm *ProxyManager) Del(name string)

+ func (pm *ProxyManager) GetByName(name string) (pxy Proxy, ok bool)

+ type ProxyStatistics struct

+ CurConns metric.Counter

+ ProxyType string

+ TrafficIn metric.DateCounter

+ TrafficOut metric.DateCounter

+ type ProxyStats struct

+ CurConns int64

+ Name string

+ TodayTrafficIn int64

+ TodayTrafficOut int64

+ Type string

+ func StatsGetProxiesByType(proxyType string) []*ProxyStats

+ type ProxyStatsInfo struct

+ Conf config.ProxyConf

+ CurConns int64

+ Name string

+ Status string

+ TodayTrafficIn int64

+ TodayTrafficOut int64

+ type ProxyTrafficInfo struct

+ Name string

+ TrafficIn []int64

+ TrafficOut []int64

+ func StatsGetProxyTraffic(name string) (res *ProxyTrafficInfo)

+ type ServerInfoResp struct

+ AuthTimeout int64

+ ClientCounts int64

+ CurConns int64

+ HeartBeatTimeout int64

+ MaxPoolCount int64

+ ProxyTypeCounts map[string]int64

+ SubdomainHost string

+ TotalTrafficIn int64

+ TotalTrafficOut int64

+ VhostHttpPort int64

+ VhostHttpsPort int64

+ type ServerStatistics struct

+ ClientCounts metric.Counter

+ CurConns metric.Counter

+ ProxyStatistics map[string]*ProxyStatistics

+ ProxyTypeCounts map[string]metric.Counter

+ TotalTrafficIn metric.DateCounter

+ TotalTrafficOut metric.DateCounter

+ type ServerStats struct

+ ClientCounts int64

+ CurConns int64

+ ProxyTypeCounts map[string]int64

+ TotalTrafficIn int64

+ TotalTrafficOut int64

+ func StatsGetServer() *ServerStats

+ type Service struct

+ VhostHttpMuxer *vhost.HttpMuxer

+ VhostHttpsMuxer *vhost.HttpsMuxer

+ var ServerService *Service

+ func NewService() (svr *Service, err error)

+ func (svr *Service) DelProxy(name string)

+ func (svr *Service) RegisterControl(ctlConn frpNet.Conn, loginMsg *msg.Login) (err error)

+ func (svr *Service) RegisterProxy(name string, pxy Proxy) error

+ func (svr *Service) RegisterWorkConn(workConn frpNet.Conn, newMsg *msg.NewWorkConn)

+ func (svr *Service) Run()

+ type TcpProxy struct

+ func (pxy *TcpProxy) Close()

+ func (pxy *TcpProxy) GetConf() config.ProxyConf

+ func (pxy *TcpProxy) Run() error

+ type UdpProxy struct

+ func (pxy *UdpProxy) Close()

+ func (pxy *UdpProxy) GetConf() config.ProxyConf

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