module

Documentation

Index

• func Destroy()
• func Init()
• func Register(mi Module)
• type Module
• type Skeleton
  • func (s *Skeleton) AfterFunc(d time.Duration, cb func()) *timer.Timer
  • func (s *Skeleton) AsynCall(server *chanrpc.Server, id interface{}, args ...interface{})
  • func (s *Skeleton) CronFunc(cronExpr *timer.CronExpr, cb func()) *timer.Cron
  • func (s *Skeleton) Go(f func(), cb func())
  • func (s *Skeleton) Init()
  • func (s *Skeleton) LoopFunc(d time.Duration, cb func()) *timer.Cron
  • func (s *Skeleton) NewLinearContext() *g.LinearContext
  • func (s *Skeleton) RegisterChanRPC(id interface{}, f interface{})
  • func (s *Skeleton) Run(closeSig chan bool)

Functions

func Destroy

func Destroy()

func Init

func Init()

func Register

func Register(mi Module)

Types

type Module

type Module interface {
	OnInit()
	OnDestroy()
	Run(closeSig chan bool)
}

type Skeleton

type Skeleton struct {
	GoLen              int
	TimerDispatcherLen int
	AsynCallLen        int
	ChanRPCServer      *chanrpc.Server
	// contains filtered or unexported fields
}

func (*Skeleton) AfterFunc

func (s *Skeleton) AfterFunc(d time.Duration, cb func()) *timer.Timer

func (*Skeleton) AsynCall

func (s *Skeleton) AsynCall(server *chanrpc.Server, id interface{}, args ...interface{})

func (*Skeleton) CronFunc

func (s *Skeleton) CronFunc(cronExpr *timer.CronExpr, cb func()) *timer.Cron

func (*Skeleton) Go

func (s *Skeleton) Go(f func(), cb func())

func (*Skeleton) Init

func (s *Skeleton) Init()

func (*Skeleton) LoopFunc

func (s *Skeleton) LoopFunc(d time.Duration, cb func()) *timer.Cron

LoopFunc 由于循环队列只支持cron表达式，而cron表达式最少只有到秒级别，游戏中同步一般都是毫秒级别，所以在此添加毫秒级别的循环队列

func (*Skeleton) NewLinearContext

func (s *Skeleton) NewLinearContext() *g.LinearContext

func (*Skeleton) RegisterChanRPC

func (s *Skeleton) RegisterChanRPC(id interface{}, f interface{})

func (*Skeleton) Run

func (s *Skeleton) Run(closeSig chan bool)