server

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: May 20, 2017 License: Apache-2.0 Imports: 25 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 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 StatsCloseClient 

func StatsCloseClient()

func StatsCloseConnection 

func StatsCloseConnection(name string)

func StatsCloseProxy 

func StatsCloseProxy(proxyType string)

func StatsNewClient 

func StatsNewClient()

func StatsNewProxy 

func StatsNewProxy(name string, proxyType 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 Control 

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

func NewControl 

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

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) (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 GeneralResponse 

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

type GetProxyInfoResp 

type GetProxyInfoResp struct {
	GeneralResponse
	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 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) 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) Run 

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

type Proxy 

type Proxy interface {
	Run() error
	GetControl() *Control
	GetName() string
	GetConf() config.ProxyConf
	GetWorkConnFromPool() (workConn frpNet.Conn, err error)
	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 {
	ProxyType  string
	TrafficIn  metric.DateCounter
	TrafficOut metric.DateCounter
	CurConns   metric.Counter
}

type ProxyStats 

type ProxyStats struct {
	Name            string
	Type            string
	TodayTrafficIn  int64
	TodayTrafficOut int64
	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"`
	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

	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
	// 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) 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) 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.