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) NewLinearContext() *g.LinearContext
  • func (s *Skeleton) RegisterChanRPC(id interface{}, f interface{})
  • func (s *Skeleton) RegisterCommand(name string, help string, 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) NewLinearContext

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

func (*Skeleton) RegisterChanRPC

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

func (*Skeleton) RegisterCommand

func (s *Skeleton) RegisterCommand(name string, help string, f interface{})

func (*Skeleton) Run

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