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) CronFunc(spec string, cb func()) *cron.Cron
  • func (s *Skeleton) GetChanAsynRet() chan *chanrpc.RetInfo
  • func (s *Skeleton) Go(f func(), cb func())
  • func (s *Skeleton) Init()
  • func (s *Skeleton) NewLinearContext() *g.LinearContext
  • 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) CronFunc

func (s *Skeleton) CronFunc(spec string, cb func()) *cron.Cron

func (*Skeleton) GetChanAsynRet

func (s *Skeleton) GetChanAsynRet() chan *chanrpc.RetInfo

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) Run

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