server

Documentation

Index

• Constants
• Variables
• func AddTask(t *file.Tunnel) error
• func DelClientConnect(clientId int)
• func DelTask(id int) error
• func DelTunnelAndHostByClientId(clientId int)
• func GetClientList(start, length int) (list []*file.Client, cnt int)
• func GetDashboardData() map[string]int
• func GetInfoByHost(host string) (h *file.Host, err error)
• func GetTunnel(start, length int, typeVal string, clientId int) ([]*file.Tunnel, int)
• func InitFromCsv()
• func NewHttp(bridge *bridge.Bridge, c *file.Tunnel) *httpServer
• func NewMode(Bridge *bridge.Bridge, c *file.Tunnel) interface{}
• func ProcessHttp(c *conn.Conn, s *TunnelModeServer) error
• func ProcessTunnel(c *conn.Conn, s *TunnelModeServer) error
• func StartNewServer(bridgePort int, cnf *file.Tunnel, bridgeType string)
• func StartTask(id int) error
• func StopServer(id int) error
• func TestServerConfig()
• type Sock5ModeServer
  • func NewSock5ModeServer(bridge *bridge.Bridge, task *file.Tunnel) *Sock5ModeServer
  • func (s *Sock5ModeServer) Auth(c net.Conn) error
  • func (s *Sock5ModeServer) Close() error
  • func (s *Sock5ModeServer) FlowAdd(in, out int64)
  • func (s *Sock5ModeServer) FlowAddHost(host *file.Host, in, out int64)
  • func (s *Sock5ModeServer) ResetConfig() bool
  • func (s *Sock5ModeServer) Start() error
• type TunnelModeServer
  • func NewTunnelModeServer(process process, bridge *bridge.Bridge, task *file.Tunnel) *TunnelModeServer
  • func (s *TunnelModeServer) Close() error
  • func (s *TunnelModeServer) FlowAdd(in, out int64)
  • func (s *TunnelModeServer) FlowAddHost(host *file.Host, in, out int64)
  • func (s *TunnelModeServer) ResetConfig() bool
  • func (s *TunnelModeServer) Start() error
• type UdpModeServer
  • func NewUdpModeServer(bridge *bridge.Bridge, task *file.Tunnel) *UdpModeServer
  • func (s *UdpModeServer) Close() error
  • func (s *UdpModeServer) FlowAdd(in, out int64)
  • func (s *UdpModeServer) FlowAddHost(host *file.Host, in, out int64)
  • func (s *UdpModeServer) ResetConfig() bool
  • func (s *UdpModeServer) Start() error
• type WebServer
  • func NewWebServer(bridge *bridge.Bridge) *WebServer
  • func (s *WebServer) FlowAdd(in, out int64)
  • func (s *WebServer) FlowAddHost(host *file.Host, in, out int64)
  • func (s *WebServer) ResetConfig() bool
  • func (s *WebServer) Start() error

Constants

const (
	UserPassAuth = uint8(2)
)

Variables

var (
	Bridge  *bridge.Bridge
	RunList map[int]interface{} //运行中的任务
)

Functions

func AddTask

func AddTask(t *file.Tunnel) error

add task

func DelClientConnect

func DelClientConnect(clientId int)

关闭客户端连接

func DelTask

func DelTask(id int) error

delete task

func DelTunnelAndHostByClientId

func DelTunnelAndHostByClientId(clientId int)

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

func GetClientList

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

获取客户端列表

func GetDashboardData

func GetDashboardData() map[string]int

func GetInfoByHost

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

get key by host from x

func GetTunnel

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

get task list by page num

func InitFromCsv

func InitFromCsv()

从csv文件中恢复任务

func NewHttp

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

func NewMode

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

new a server by mode name

func ProcessHttp

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

http代理模式

func ProcessTunnel

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

tcp隧道模式

func StartNewServer

func StartNewServer(bridgePort int, cnf *file.Tunnel, bridgeType string)

start a new server

func StartTask

func StartTask(id int) error

start task

func StopServer

func StopServer(id int) error

stop server

func TestServerConfig

func TestServerConfig()

Types

type Sock5ModeServer

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

func NewSock5ModeServer

func NewSock5ModeServer(bridge *bridge.Bridge, task *file.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

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

func (*Sock5ModeServer) FlowAddHost

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

func (*Sock5ModeServer) ResetConfig

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 *file.Tunnel) *TunnelModeServer

tcp|http|host

func (*TunnelModeServer) Close

func (s *TunnelModeServer) Close() error

close

func (*TunnelModeServer) FlowAdd

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

func (*TunnelModeServer) FlowAddHost

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

func (*TunnelModeServer) ResetConfig

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 *file.Tunnel) *UdpModeServer

func (*UdpModeServer) Close

func (s *UdpModeServer) Close() error

func (*UdpModeServer) FlowAdd

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

func (*UdpModeServer) FlowAddHost

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

func (*UdpModeServer) ResetConfig

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

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

func (*WebServer) FlowAddHost

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

func (*WebServer) ResetConfig

func (s *WebServer) ResetConfig() bool

热更新配置

func (*WebServer) Start

func (s *WebServer) Start() error

开始