server

package
v0.8.698 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 29, 2017 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReserveDays = 7
)

Variables

This section is empty.

Functions

func HandleUserTcpConnection 

func HandleUserTcpConnection(pxy Proxy, userConn frpNet.Conn)

HandleUserTcpConnection is used for incoming tcp user connections. It can be used for tcp, http, https type.

func MakeGzipHandler 

func MakeGzipHandler(h http.Handler) http.Handler

func RunDashboardServer 

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

func StatsAddTrafficIn 

func StatsAddTrafficIn(name string, trafficIn int64)

func StatsAddTrafficOut 

func StatsAddTrafficOut(name string, trafficOut int64)

func StatsClearUselessInfo 

func StatsClearUselessInfo()

func StatsCloseClient 

func StatsCloseClient(runid string)

func StatsCloseConnection 

func StatsCloseConnection(name string)

func StatsCloseProxy 

func StatsCloseProxy(proxyName string, proxyType string)

func StatsNewClient 

func StatsNewClient(runid string)

func StatsNewProxy 

func StatsNewProxy(name string, proxyType string, runid string)

func StatsOpenConnection 

func StatsOpenConnection(name string)

Types

type AuthWraper 

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

func (*AuthWraper) ServeHTTP 

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

type BaseProxy 

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

func (*BaseProxy) Close 

func (pxy *BaseProxy) Close()

func (*BaseProxy) GetControl 

func (pxy *BaseProxy) GetControl() *Control

func (*BaseProxy) GetName 

func (pxy *BaseProxy) GetName() string

func (*BaseProxy) GetWorkConnFromPool 

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

type ClientStatistics added in v0.8.698 

type ClientStatistics struct {
	Online        int
	ProxyNum      metric.Counter
	ConnNum       metric.Counter
	LastStartTime time.Time
	LastCloseTime time.Time
}

type ClientStats added in v0.8.698 

type ClientStats struct {
	RunId         string
	ProxyNum      int64
	ConnNum       int64
	LastStartTime string
	LastCloseTime string
}

func StatsGetClient added in v0.8.698 

func StatsGetClient(online int) []*ClientStats

online is 1, means online; otherwise offline

type ClientStatsInfo added in v0.8.698 

type ClientStatsInfo struct {
	RunId         string `json:"runid"`
	ProxyNum      int64  `json:"proxy_num"`
	ConnNum       int64  `json:"conn_num"`
	LastStartTime string `json:"last_start_time"`
	LastCloseTime string `json:"last_close_time"`
}

Get client info

type Control 

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

func NewControl 

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

func (*Control) GetFreePort 

func (ctl *Control) GetFreePort() (port int64)

Get free port for client, every client has only one free port

func (*Control) GetFtpPort 

func (ctl *Control) GetFtpPort() (port int64)

Get ftp port for ftp client

func (*Control) GetWorkConn 

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

When frps get one user connection, we get one work connection from the pool and return it. If no workConn available in the pool, send message to frpc to get one or more and wait until it is available. return an error if wait timeout

func (*Control) RegisterProxy 

func (ctl *Control) RegisterProxy(pxyMsg *msg.NewProxy) (resp *msg.NewProxyResp, err error)

func (*Control) RegisterWorkConn 

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

func (*Control) Replaced 

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

func (*Control) Start 

func (ctl *Control) Start()

Start send a login success message to client and start working.

type ControlManager 

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

func NewControlManager 

func NewControlManager() *ControlManager

func (*ControlManager) Add 

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

func (*ControlManager) GetById 

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

type FtpProxy 

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

ftp proxy

func (*FtpProxy) Close 

func (pxy *FtpProxy) Close()

func (*FtpProxy) GetConf 

func (pxy *FtpProxy) GetConf() config.ProxyConf

func (*FtpProxy) GetRemotePort added in v0.8.698 

func (pxy *FtpProxy) GetRemotePort() int64

func (*FtpProxy) Run 

func (pxy *FtpProxy) Run() error

type GeneralResponse 

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

type GetClientInfoResp added in v0.8.698 

type GetClientInfoResp struct {
	GeneralResponse
	TotalPage int64              `json:"total_page"`
	TotalNum  int64              `json:"total_num"`
	Clients   []*ClientStatsInfo `json:"clients"`
}

type GetFreePortResp 

type GetFreePortResp struct {
	GeneralResponse

	Proto    string `json:"proto"`
	FreePort int    `json:"free_port"`
}

/api/port/getfree/:proto

type GetPortResp 

type GetPortResp struct {
	GeneralResponse

	Port int64 `json:"port"`
}

type GetProxyInfoResp 

type GetProxyInfoResp struct {
	GeneralResponse
	TotalPage int64             `json:"total_page"`
	TotalNum  int64             `json:"total_num"`
	Proxies   []*ProxyStatsInfo `json:"proxies"`
}

type GetProxyTrafficResp 

type GetProxyTrafficResp struct {
	GeneralResponse

	Name       string  `json:"name"`
	TrafficIn  []int64 `json:"traffic_in"`
	TrafficOut []int64 `json:"traffic_out"`
}

api/proxy/traffic/:name

type GzipWraper 

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

func (*GzipWraper) ServeHTTP 

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

type HttpProxy 

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

func (*HttpProxy) Close 

func (pxy *HttpProxy) Close()

func (*HttpProxy) GetConf 

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

func (*HttpProxy) GetRemotePort added in v0.8.698 

func (pxy *HttpProxy) GetRemotePort() int64

func (*HttpProxy) Run 

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

type HttpsProxy 

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

func (*HttpsProxy) Close 

func (pxy *HttpsProxy) Close()

func (*HttpsProxy) GetConf 

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

func (*HttpsProxy) GetRemotePort added in v0.8.698 

func (pxy *HttpsProxy) GetRemotePort() int64

func (*HttpsProxy) Run 

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

type PortManager 

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

func NewPortManager 

func NewPortManager() *PortManager

func (*PortManager) Add 

func (pm *PortManager) Add(runId string, port int64) (oldPort int64)

func (*PortManager) AddFtp 

func (pm *PortManager) AddFtp(runId string, port int64) (oldPort int64)

func (*PortManager) GetById 

func (pm *PortManager) GetById(runId string) (port int64, ok bool)

func (*PortManager) GetFtpById 

func (pm *PortManager) GetFtpById(runId string) (port int64, ok bool)

type Proxy 

type Proxy interface {
	Run() error
	GetControl() *Control
	GetName() string
	GetConf() config.ProxyConf
	GetWorkConnFromPool() (workConn frpNet.Conn, err error)
	GetRemotePort() int64
	Close()
	log.Logger
}

func NewProxy 

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

type ProxyManager 

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

func NewProxyManager 

func NewProxyManager() *ProxyManager

func (*ProxyManager) Add 

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

func (*ProxyManager) Del 

func (pm *ProxyManager) Del(name string)

func (*ProxyManager) GetByName 

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

type ProxyStatistics 

type ProxyStatistics struct {
	Name          string
	RunId         string
	ProxyType     string
	TrafficIn     metric.DateCounter
	TrafficOut    metric.DateCounter
	CurConns      metric.Counter
	LastStartTime time.Time
	LastCloseTime time.Time
}

type ProxyStats 

type ProxyStats struct {
	Name            string
	RunId           string
	Type            string
	TodayTrafficIn  int64
	TodayTrafficOut int64
	LastStartTime   string
	LastCloseTime   string
	CurConns        int64
}

func StatsGetProxiesByType 

func StatsGetProxiesByType(proxyType string) []*ProxyStats

type ProxyStatsInfo 

type ProxyStatsInfo struct {
	Name            string           `json:"name"`
	Conf            config.ProxyConf `json:"conf"`
	TodayTrafficIn  int64            `json:"today_traffic_in"`
	TodayTrafficOut int64            `json:"today_traffic_out"`
	CurConns        int64            `json:"cur_conns"`
	LastStartTime   string           `json:"last_start_time"`
	LastCloseTime   string           `json:"last_close_time"`
	Status          string           `json:"status"`
}

Get proxy info.

type ProxyTrafficInfo 

type ProxyTrafficInfo struct {
	Name       string
	TrafficIn  []int64
	TrafficOut []int64
}

func StatsGetProxyTraffic 

func StatsGetProxyTraffic(name string) (res *ProxyTrafficInfo)

type ServerInfoResp 

type ServerInfoResp struct {
	GeneralResponse

	Version          string `json:"version"`
	VhostHttpPort    int64  `json:"vhost_http_port"`
	VhostHttpsPort   int64  `json:"vhost_https_port"`
	AuthTimeout      int64  `json:"auth_timeout"`
	SubdomainHost    string `json:"subdomain_host"`
	MaxPoolCount     int64  `json:"max_pool_count"`
	HeartBeatTimeout int64  `json:"heart_beat_timeout"`

	TotalTrafficIn  int64            `json:"total_traffic_in"`
	TotalTrafficOut int64            `json:"total_traffic_out"`
	CurConns        int64            `json:"cur_conns"`
	ClientCounts    int64            `json:"client_counts"`
	ProxyTypeCounts map[string]int64 `json:"proxy_type_count"`
}

api/serverinfo

type ServerStatistics 

type ServerStatistics struct {
	TotalTrafficIn  metric.DateCounter
	TotalTrafficOut metric.DateCounter
	CurConns        metric.Counter

	// counter for clients
	ClientCounts metric.Counter

	// counter for proxy types
	ProxyTypeCounts map[string]metric.Counter

	// statistics for different proxies
	// key is proxy name
	ProxyStatistics map[string]*ProxyStatistics

	// statistics for client
	// key is runid
	ClientStatistics map[string]*ClientStatistics
	// contains filtered or unexported fields
}

type ServerStats 

type ServerStats struct {
	TotalTrafficIn  int64
	TotalTrafficOut int64
	CurConns        int64
	ClientCounts    int64
	ProxyTypeCounts map[string]int64
}

Functions for getting server stats.

func StatsGetServer 

func StatsGetServer() *ServerStats

type Service 

type Service struct {

	// For http proxies, route requests to different clients by hostname and other infomation.
	VhostHttpMuxer *vhost.HttpMuxer

	// For https proxies, route requests to different clients by hostname and other infomation.
	VhostHttpsMuxer *vhost.HttpsMuxer
	// contains filtered or unexported fields
}

Server service. 

var ServerService *Service

func NewService 

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

func (*Service) DelProxy 

func (svr *Service) DelProxy(name string)

func (*Service) RegisterControl 

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

func (*Service) RegisterProxy 

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

func (*Service) RegisterWorkConn 

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

RegisterWorkConn register a new work connection to control and proxies need it.

func (*Service) Run 

func (svr *Service) Run()

type TcpProxy 

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

func (*TcpProxy) Close 

func (pxy *TcpProxy) Close()

func (*TcpProxy) GetConf 

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

func (*TcpProxy) GetRemotePort added in v0.8.698 

func (pxy *TcpProxy) GetRemotePort() int64

func (*TcpProxy) Run 

func (pxy *TcpProxy) Run() error

type UdpProxy 

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

func (*UdpProxy) Close 

func (pxy *UdpProxy) Close()

func (*UdpProxy) GetConf 

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

func (*UdpProxy) GetRemotePort added in v0.8.698 

func (pxy *UdpProxy) GetRemotePort() int64

func (*UdpProxy) Run 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.