server

Documentation

Index

• Constants
• Variables
• type Config
• type Manager
  • func NewManager(ClientId string, conn net.Conn, msg *message.AuthRequest) *Manager
  • func (self *Manager) Close()
  • func (self *Manager) DeregisterProxy(name string)
  • func (self *Manager) RegisterProxy(msg *message.ProxyRequest, conn net.Conn) (p proxy.Proxy, err error)
  • func (self *Manager) Run()
  • func (self *Manager) String() string
• type Server
  • func NewServer(cfg *Config) *Server
  • func (self *Server) Run() error

Constants

const MessageReadTimeout = time.Second * 5

Variables

var HeartBeatTimeout = time.Second * 60

var HeartbeatInterval = time.Second * 30

Types

type Config

type Config struct {
	Ip        string `ini:"bind_ip"`
	Port      string `ini:"bind_port"`
	AuthToken string `ini:"auth_token"`
	LogFile   string `ini:"log_file"`
	LogLevel  string `ini:"log_level"`
}

type Manager

type Manager struct {
	ClientId string
	Meta     *message.AuthRequest
	// contains filtered or unexported fields
}

func NewManager

func NewManager(ClientId string, conn net.Conn, msg *message.AuthRequest) *Manager

func (*Manager) Close

func (self *Manager) Close()

func (*Manager) DeregisterProxy

func (self *Manager) DeregisterProxy(name string)

func (*Manager) RegisterProxy

func (self *Manager) RegisterProxy(msg *message.ProxyRequest, conn net.Conn) (p proxy.Proxy, err error)

func (*Manager) Run

func (self *Manager) Run()

func (*Manager) String

func (self *Manager) String() string

type Server

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

func NewServer

func NewServer(cfg *Config) *Server

func (*Server) Run

func (self *Server) Run() error