fserver

Documentation

Index

• func NewServer() iface.Iserver
• func NewTcpServer(name string, version string, ip string, port int, maxConn int, ...) iface.Iserver
• type Server
  • func (this *Server) AddRouter(router interface{})
  • func (this *Server) CallLater(durations time.Duration, f func(v ...interface{}), args ...interface{})
  • func (this *Server) CallLoop(durations time.Duration, f func(v ...interface{}), args ...interface{})
  • func (this *Server) CallWhen(ts string, f func(v ...interface{}), args ...interface{})
  • func (this *Server) GetConnectionMgr() iface.Iconnectionmgr
  • func (this *Server) GetConnectionQueue() chan interface{}
  • func (this *Server) Serve()
  • func (this *Server) Start()
  • func (this *Server) Stop()
  • func (this *Server) WaitSignal()

Functions

func NewServer

func NewServer() iface.Iserver

func NewTcpServer

func NewTcpServer(name string, version string, ip string, port int, maxConn int, protoc iface.IServerProtocol) iface.Iserver

Types

type Server

type Server struct {
	Name      string
	IPVersion string
	IP        string
	Port      int
	MaxConn   int
	GenNum    *utils.UUIDGenerator

	Protoc iface.IServerProtocol
	// contains filtered or unexported fields
}

func (*Server) AddRouter

func (this *Server) AddRouter(router interface{})

func (*Server) CallLater

func (this *Server) CallLater(durations time.Duration, f func(v ...interface{}), args ...interface{})

func (*Server) CallLoop

func (this *Server) CallLoop(durations time.Duration, f func(v ...interface{}), args ...interface{})

func (*Server) CallWhen

func (this *Server) CallWhen(ts string, f func(v ...interface{}), args ...interface{})

func (*Server) GetConnectionMgr

func (this *Server) GetConnectionMgr() iface.Iconnectionmgr

func (*Server) GetConnectionQueue

func (this *Server) GetConnectionQueue() chan interface{}

func (*Server) Serve

func (this *Server) Serve()

func (*Server) Start

func (this *Server) Start()

func (*Server) Stop

func (this *Server) Stop()

func (*Server) WaitSignal

func (this *Server) WaitSignal()