server

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2019 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UserPassAuth = uint8(2)
)

Variables

View Source 
var (
	Bridge  *bridge.Bridge
	RunList map[int]interface{} //运行中的任务
	CsvDb   = utils.GetCsvDb()
)

Functions

func AddTask 

func AddTask(t *utils.Tunnel) error

add task

func DelClientConnect added in v0.0.10 

func DelClientConnect(clientId int)

关闭客户端连接

func DelTask 

func DelTask(id int) error

delete task

func DelTunnelAndHostByClientId added in v0.0.10 

func DelTunnelAndHostByClientId(clientId int)

根据客户端id删除其所属的所有隧道和域名

func GetClientList added in v0.0.10 

func GetClientList(start, length int) (list []*utils.Client, cnt int)

获取客户端列表

func GetDashboardData added in v0.0.10 

func GetDashboardData() map[string]int

func GetInfoByHost added in v0.0.10 

func GetInfoByHost(host string) (h *utils.Host, err error)

get key by host from x

func GetTunnel added in v0.0.10 

func GetTunnel(start, length int, typeVal string, clientId int) ([]*utils.Tunnel, int)

get task list by page num

func InitFromCsv 

func InitFromCsv()

从csv文件中恢复任务

func NewHttp added in v0.0.12 

func NewHttp(bridge *bridge.Bridge, c *utils.Tunnel) *httpServer

func NewMode 

func NewMode(Bridge *bridge.Bridge, c *utils.Tunnel) interface{}

new a server by mode name

func ProcessHttp 

func ProcessHttp(c *utils.Conn, s *TunnelModeServer) error

http代理模式

func ProcessTunnel 

func ProcessTunnel(c *utils.Conn, s *TunnelModeServer) error

tcp隧道模式

func StartNewServer 

func StartNewServer(bridgePort int, cnf *utils.Tunnel)

start a new server

func StartTask 

func StartTask(id int) error

start task

func StopServer 

func StopServer(id int) error

stop server

Types

type HostServer 

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

host

func NewHostServer 

func NewHostServer(task *utils.Tunnel) *HostServer

func (*HostServer) Close 

func (s *HostServer) Close() error

close

func (*HostServer) FlowAdd added in v0.0.10 

func (s *HostServer) FlowAdd(in, out int64)

func (*HostServer) FlowAddHost added in v0.0.10 

func (s *HostServer) FlowAddHost(host *utils.Host, in, out int64)

func (*HostServer) ResetConfig added in v0.0.10 

func (s *HostServer) ResetConfig() bool

热更新配置

func (*HostServer) Start 

func (s *HostServer) Start() error

开始

type Sock5ModeServer 

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

func NewSock5ModeServer 

func NewSock5ModeServer(bridge *bridge.Bridge, task *utils.Tunnel) *Sock5ModeServer

new

func (*Sock5ModeServer) Auth 

func (s *Sock5ModeServer) Auth(c net.Conn) error

socks5 auth

func (*Sock5ModeServer) Close 

func (s *Sock5ModeServer) Close() error

close

func (*Sock5ModeServer) FlowAdd added in v0.0.10 

func (s *Sock5ModeServer) FlowAdd(in, out int64)

func (*Sock5ModeServer) FlowAddHost added in v0.0.10 

func (s *Sock5ModeServer) FlowAddHost(host *utils.Host, in, out int64)

func (*Sock5ModeServer) ResetConfig added in v0.0.10 

func (s *Sock5ModeServer) ResetConfig() bool

热更新配置

func (*Sock5ModeServer) Start 

func (s *Sock5ModeServer) Start() error

start

type TunnelModeServer 

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

func NewTunnelModeServer 

func NewTunnelModeServer(process process, bridge *bridge.Bridge, task *utils.Tunnel) *TunnelModeServer

tcp|http|host

func (*TunnelModeServer) Close 

func (s *TunnelModeServer) Close() error

close

func (*TunnelModeServer) FlowAdd added in v0.0.10 

func (s *TunnelModeServer) FlowAdd(in, out int64)

func (*TunnelModeServer) FlowAddHost added in v0.0.10 

func (s *TunnelModeServer) FlowAddHost(host *utils.Host, in, out int64)

func (*TunnelModeServer) ResetConfig added in v0.0.10 

func (s *TunnelModeServer) ResetConfig() bool

热更新配置

func (*TunnelModeServer) Start 

func (s *TunnelModeServer) Start() error

开始

type UdpModeServer 

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

func NewUdpModeServer 

func NewUdpModeServer(bridge *bridge.Bridge, task *utils.Tunnel) *UdpModeServer

func (*UdpModeServer) Close 

func (s *UdpModeServer) Close() error

func (*UdpModeServer) FlowAdd added in v0.0.10 

func (s *UdpModeServer) FlowAdd(in, out int64)

func (*UdpModeServer) FlowAddHost added in v0.0.10 

func (s *UdpModeServer) FlowAddHost(host *utils.Host, in, out int64)

func (*UdpModeServer) ResetConfig added in v0.0.10 

func (s *UdpModeServer) ResetConfig() bool

热更新配置

func (*UdpModeServer) Start 

func (s *UdpModeServer) Start() error

开始

type WebServer 

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

web管理方式

func NewWebServer 

func NewWebServer(bridge *bridge.Bridge) *WebServer

new

func (*WebServer) FlowAdd added in v0.0.10 

func (s *WebServer) FlowAdd(in, out int64)

func (*WebServer) FlowAddHost added in v0.0.10 

func (s *WebServer) FlowAddHost(host *utils.Host, in, out int64)

func (*WebServer) ResetConfig added in v0.0.10 

func (s *WebServer) ResetConfig() bool

热更新配置

func (*WebServer) Start 

func (s *WebServer) Start()

开始

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.