modules

package

Go to main page

Versions in this module

v1

v1.3.2

Jun 13, 2020

v1.3.1

Jun 12, 2020

v1.3.0

Jun 5, 2020

Changes in this version

type SocketCliModule

+ func (mod *SocketCliModule) AddMsgSynByGate(gate messages.IGateMessage, msg interface{}) error

v1.2.6

May 28, 2020

v1.2.5

May 28, 2020

Changes in this version

type GameService

+ ServiceStartHander func()

v1.2.4

Apr 6, 2020

Changes in this version

+ func WebSocketSetFrame(frame byte) options

v1.2.3

Apr 5, 2020

Changes in this version

+ func WebSocketSetOnlineFun(fun func(conn *messages.WebSocketModel)) options

type LogicModule

+ func (mod *LogicModule) Handle(ctx context.Context)

v1.2.2

Feb 14, 2020

v1.2.1

Feb 8, 2020

Changes in this version

+ func DataBaseSetChanNum(channum int) options

+ func DataBaseSetTimeout(timeout time.Duration) options

+ func GameServiceSetPTime(ptime time.Duration) servOptions

+ func GameServiceSetSID(sid int) servOptions

+ func GameServiceSetStopHander(hander func()) servOptions

+ func LogicSetChanNum(channum int) options

+ func LogicSetTimeout(timeout time.Duration) options

+ func NsqdSetChanNum(channum int) options

+ func NsqdSetLookup(ports ...string) options

+ func NsqdSetMaxInFlight(v int) options

+ func NsqdSetMyChannelName(name string) options

+ func NsqdSetMyTopic(topic string) options

+ func NsqdSetPollInterval(t time.Duration) options

+ func NsqdSetPorts(ports ...string) options

+ func NsqdSetRoute(route messages.IMessageHandle) options

+ func SocketCliSetConnName(name string) options

+ func SocketCliSetPort(ipport string) options

+ func SocketCliSetRoute(route messages.IMessageHandle) options

+ func SocketSetPort(ipport string) options

+ func SocketSetRoute(route messages.IMessageHandle) options

+ func SocketSetTimeout(timeout time.Duration) options

+ func WebScoketSetOnlineFun(fun func(conn *messages.WebSocketModel)) options

+ func WebSetIpPort(ipPort string) options

+ func WebSetRoute(route messages.IMessageHandle) options

+ func WebSetTimeout(timeout time.Duration) options

+ func WebSetTimeoutFunc(...) options

+ func WebSocketSetIpPort(ipPort string) options

+ func WebSocketSetRoute(route messages.IMessageHandle) options

+ func WebSocketSetTimeout(timeout time.Duration) options

+ type AutoTaskModel struct

+ func (task *AutoTaskModel) GetTaskName() string

+ func (task *AutoTaskModel) Handle(ctx context.Context)

+ func (task *AutoTaskModel) Start(mod *AutoTaskModule)

+ func (task *AutoTaskModel) Stop()

+ type AutoTaskModule struct

+ func NewAutoTaskModule(opts ...options) *AutoTaskModule

+ func (mod *AutoTaskModule) AddTask(task IAutoTaskModel) bool

+ func (mod *AutoTaskModule) DelRask(name string) bool

+ func (mod *AutoTaskModule) Init()

+ func (mod *AutoTaskModule) PrintStatus() string

+ func (mod *AutoTaskModule) ReTask(task IAutoTaskModel) bool

+ func (mod *AutoTaskModule) Start()

+ func (mod *AutoTaskModule) Stop()

+ type DataBaseModule struct

+ func NewDataBaseModule(conndb *sql.DB, opts ...options) *DataBaseModule

+ func (mod *DataBaseModule) AddMsg(msgs ...messages.IDataBaseMessage)

+ func (mod *DataBaseModule) Handle(ctx context.Context)

+ func (mod *DataBaseModule) Init()

+ func (mod *DataBaseModule) PrintStatus() string

+ func (mod *DataBaseModule) Start()

+ func (mod *DataBaseModule) Stop()

+ type GameService struct

+ PStatusTime time.Duration

+ ServiceID int

+ ServiceStopHander func()

+ func NewGameService(opts ...servOptions) *GameService

+ func (gs *GameService) AddModule(mds ...IModule)

+ func (gs *GameService) GetIsRun() bool

+ func (gs *GameService) Run()

+ type IAutoTaskModel interface

+ GetTaskName func() string

+ Start func(mod *AutoTaskModule)

+ Stop func()

+ type IModule interface

+ Init func()

+ PrintStatus func() string

+ Start func()

+ Stop func()

+ type LogicModule struct

+ func NewLogicModule(opts ...options) *LogicModule

+ func (mod *LogicModule) AddMsg(logicmd messages.ILogicMessage)

+ func (mod *LogicModule) Hander(ctx context.Context)

+ func (mod *LogicModule) Init()

+ func (mod *LogicModule) PrintStatus() string

+ func (mod *LogicModule) Start()

+ func (mod *LogicModule) Stop()

+ type NsqdModule struct

+ ChannelName string

+ RouteHandle messages.IMessageHandle

+ Topic string

+ func NewNsqdModule(opts ...options) *NsqdModule

+ func (mod *NsqdModule) AddMsg(msg messages.INsqdResultMessage) bool

+ func (mod *NsqdModule) AddMsgSync(msg messages.INsqdResultMessage) error

+ func (mod *NsqdModule) Handle(ctx context.Context)

+ func (mod *NsqdModule) HandleMessage(message *nsq.Message) (err error)

+ func (mod *NsqdModule) Init()

+ func (mod *NsqdModule) PingNsq(ctx context.Context) bool

+ func (mod *NsqdModule) PrintStatus() string

+ func (mod *NsqdModule) Start()

+ func (mod *NsqdModule) Stop()

+ type SocketCliModule struct

+ ConInfo interface{}

+ ConnName string

+ RouteHandle messages.IMessageHandle

+ func NewSocketCliModule(opts ...options) *SocketCliModule

+ func (mod *SocketCliModule) AddMsgSyn(msg messages.ISocketResultMessage) error

+ func (mod *SocketCliModule) Init()

+ func (mod *SocketCliModule) PrintStatus() string

+ func (mod *SocketCliModule) Start()

+ func (mod *SocketCliModule) Stop()

+ type SocketModule struct

+ RouteHandle messages.IMessageHandle

+ func NewSocketModule(opts ...options) *SocketModule

+ func (mod *SocketModule) Init()

+ func (mod *SocketModule) PrintStatus() string

+ func (mod *SocketModule) Start()

+ func (mod *SocketModule) Stop()

+ type WebModule struct

+ RouteHandle messages.IMessageHandle

+ func NewWebModule(opts ...options) *WebModule

+ func (mod *WebModule) Handle(w http.ResponseWriter, req *http.Request)

+ func (mod *WebModule) Init()

+ func (mod *WebModule) PrintStatus() string

+ func (mod *WebModule) Start()

+ func (mod *WebModule) Stop()

+ type WebSocketModule struct

+ RouteHandle messages.IMessageHandle

+ func NewWebSocketModule(opts ...options) *WebSocketModule

+ func (mod *WebSocketModule) GetPlayerNum() int64

+ func (mod *WebSocketModule) Handle(conn *websocket.Conn)

+ func (mod *WebSocketModule) Init()

+ func (mod *WebSocketModule) PrintStatus() string

+ func (mod *WebSocketModule) Start()

+ func (mod *WebSocketModule) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL