module

Apr 5, 2020

Changes in this version

type LogicModule

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

Jul 29, 2019

Changes in this version

+ func HTMLHandlego(w http.ResponseWriter, req *http.Request)

+ func NullHandle(w http.ResponseWriter, req *http.Request)

+ func TimeoutRun(et event.JsonMap, w http.ResponseWriter)

+ func WebSocketHTMLHandlego(w http.ResponseWriter, req *http.Request)

+ type DataThread struct

+ Conndb *sql.DB

+ KeyID int

+ SendChan chan []event.ISqlDataModel

+ TranSave bool

+ UpTime time.Time

+ func (this *DataThread) CloseChan()

+ func (this *DataThread) Handle(ctx context.Context, mg *SqlDataModule)

+ func (this *DataThread) Save()

+ func (this *DataThread) Start(mg *SqlDataModule)

+ func (this *DataThread) Stop(mg *SqlDataModule, index int)

+ type HTTPConfig struct

+ HTTPAddr string

+ Timeout int

+ type HTTPModule struct

+ GetIPFun func(w http.ResponseWriter, req *http.Request) string

+ HTTPAddr string

+ RouteFun func(code int) event.HTTPcall

+ TimeoutFun event.HTTPcall

+ func NewHTTPModule(configmd *HTTPConfig) *HTTPModule

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

+ func (mod *HTTPModule) Init()

+ func (mod *HTTPModule) PrintStatus() string

+ func (mod *HTTPModule) Start()

+ func (mod *HTTPModule) Stop()

+ type IModule interface

+ Init func()

+ PrintStatus func() string

+ Start func()

+ Stop func()

+ type LogicConfig struct

+ ChanNum int

+ InitNum int

+ SubChanNum int

+ Timeout int

+ type LogicModule struct

+ func NewLogicModule(config *LogicConfig) *LogicModule

+ func (mod *LogicModule) PrintStatus() string

+ func (this *LogicModule) AddMsg(logicmd event.LogicModel)

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

+ func (this *LogicModule) Init()

+ func (this *LogicModule) Start()

+ func (this *LogicModule) Stop()

+ type LogicThreadModule struct

+ KeyID string

+ UpTime time.Time

+ func (this *LogicThreadModule) CloseChan()

+ func (this *LogicThreadModule) Handle(ctx context.Context, mg *LogicModule)

+ func (this *LogicThreadModule) Start(mg *LogicModule)

+ func (this *LogicThreadModule) Stop(mg *LogicModule, index int)

+ type MemoryConfig struct

+ ChanNum int

+ InitNum int

+ RunTime int

+ type MemoryModule struct

+ func NewMemoryModule(config *MemoryConfig) *MemoryModule

+ func (this *MemoryModule) AddListenMsg(data event.IMemoryModel)

+ func (this *MemoryModule) DelListenMsg(data event.IMemoryModel)

+ func (this *MemoryModule) GetNum() int

+ func (this *MemoryModule) Handle(ctx context.Context)

+ func (this *MemoryModule) Init()

+ func (this *MemoryModule) PrintStatus() string

+ func (this *MemoryModule) Start()

+ func (this *MemoryModule) Stop()

+ type MemoryThread struct

+ DataMemory event.IMemoryModel

+ Key string

+ func (this *MemoryThread) Handle(ctx context.Context, mg *MemoryModule)

+ type NsqdConfig struct

+ Addr []string

+ ChanNum int

+ LookupdPollInterval int

+ MaxInFlight int

+ NSQLookupdAddr []string

+ type NsqdModule struct

+ GetNewMsg func() event.INsqdMessage

+ RouteFun event.NsqdHander

+ ServerID string

+ func NewNsqdModule(configmd *NsqdConfig, sid int) *NsqdModule

+ func (this *NsqdModule) AddMsg(msg event.INsqdMessage) bool

+ func (this *NsqdModule) AddMsgSync(msg event.INsqdMessage) error

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

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

+ func (this *NsqdModule) Init()

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

+ func (this *NsqdModule) PrintStatus() string

+ func (this *NsqdModule) Start()

+ func (this *NsqdModule) Stop()

+ func (this *NsqdModule) StopConsumer()

+ type SocketClientModule struct

+ type SocketModule struct

+ type SqlDataConfig struct

+ ChanNum int

+ InitNum int

+ SubChanNum int

+ Timeout int

+ TranSave bool

+ type SqlDataModule struct

+ func NewSqlDataModule(config *SqlDataConfig, sqldb *sql.DB) *SqlDataModule

+ func (this *SqlDataModule) AddMsg(msg ...event.ISqlDataModel)

+ func (this *SqlDataModule) Handle(ctx context.Context)

+ func (this *SqlDataModule) Init()

+ func (this *SqlDataModule) PrintStatus() string

+ func (this *SqlDataModule) Start()

+ func (this *SqlDataModule) Stop()

+ type WebSocketConfig struct

+ Addr string

+ MsgMaxLen int

+ Timeout int

+ type WebSocketModule struct

+ Addr string

+ RouteFun func(code int) event.WebSocketCall

+ WebSocketOnlineFun func(conn *websocket.Conn) string

+ func NewWSModule(configmd *WebSocketConfig) *WebSocketModule

+ func (mod *WebSocketModule) GetPlayerNum() int

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

+ func (mod *WebSocketModule) Init()

+ func (mod *WebSocketModule) PrintStatus() string

+ func (mod *WebSocketModule) Start()

+ func (mod *WebSocketModule) Stop()