nano

package module

Go to main page

Versions in this module

v0

v0.4.5

Jan 1, 2020

v0.4.4

Jan 1, 2020

Changes in this version

type GameManager

+ func (g *GameManager) HandleMsg(msg *nats.Msg)

+ func (g *GameManager) InitNats()

+ func (g *GameManager) ServerMaintence()

v0.4.3

Aug 19, 2019

Changes in this version

+ var ErrCloseClosedConnector = errors.New("close closed connector")

+ var ErrClosedConnector = errors.New("connector closed")

+ var ResponseFail = []byte("FAIL")

+ var ResponseSuccess = []byte("SUCCESS")

+ type ApiManager struct

+ var ApiManagerHandler *ApiManager

+ var DefautApiAddrs = "127.0.0.1:20066"

+ func NewApiManager(opts ...ApiManagerOpts) *ApiManager

+ func (am *ApiManager) AfterInit()

+ func (am *ApiManager) BeforeShutdown()

+ func (am *ApiManager) Init()

+ func (am *ApiManager) Shutdown()

+ type ApiManagerOpts func(am *ApiManager)

+ func WithApiAddrs(addrs string) ApiManagerOpts

+ type ApiServer struct

+ ReadEndStr []byte

+ func NewApiServer(conn net.Conn, opts ...ApiServerOpts) *ApiServer

+ func (as *ApiServer) SendObj(data map[string]interface{})

+ type ApiServerOpts func(as *ApiServer)

+ type GameManager struct

+ Alltablesort map[string]*game.GameTable

+ Serversort map[string]*game.GameServer

+ var DefautListenGame = "0.0.0.0:20572"

+ var GMHander *GameManager

+ func NewGameManager(opts ...GameManagerOpts) *GameManager

+ func (g *GameManager) AfterInit()

+ func (g *GameManager) BeforeShutdown()

+ func (g *GameManager) EnterToGame(uid int, serverdata *game.ServerData, ...) error

+ func (g *GameManager) GetCenterServerByBalance(ngid int) *game.GameServer

+ func (g *GameManager) GetCenterServers(ngid int, ngc func(s *game.GameServer) bool) map[string]*game.GameServer

+ func (g *GameManager) GetGameListState() map[string]interface{}

+ func (g *GameManager) GetServerByGSID(gsid string) *game.GameServer

+ func (g *GameManager) GetServerSort() map[string]*game.GameServer

+ func (g *GameManager) GetTable(gsidtid string) *game.GameTable

+ func (g *GameManager) Init()

+ func (g *GameManager) ProcessServer(route string, body reflect.Value)

+ func (g *GameManager) ReconnectToGame(uid int, connectServerdata *game.ServerData) (*game.ServerData, error)

+ func (g *GameManager) RegisterServer(gsid string, server *game.GameServer)

+ func (g *GameManager) RegisterTable(gsidtid string, table *game.GameTable)

+ func (g *GameManager) RemoveServerByGSID(gsid string)

+ func (g *GameManager) Shutdown()

+ type GameManagerOpts func(g *GameManager)

+ func WithGameManagerAddrs(addrs string) GameManagerOpts

type Logger

+ Printf func(format string, v ...interface{})

v0.4.2

Aug 4, 2019

v0.4.0

Dec 10, 2018

Changes in this version

+ var ErrBrokenPipe = errors.New("broken low-level pipe")

+ var ErrBufferExceed = errors.New("session send buffer exceed")

+ var ErrCloseClosedGroup = errors.New("close closed group")

+ var ErrCloseClosedSession = errors.New("close closed session")

+ var ErrClosedGroup = errors.New("group closed")

+ var ErrMemberNotFound = errors.New("member not found in the group")

+ var ErrSessionDuplication = errors.New("session has existed in the current group")

+ var ErrSessionOnNotify = errors.New("current session working on notify mode")

+ var VERSION = "0.0.1"

+ func EnableDebug()

+ func Invoke(fn func())

+ func Listen(addr string, opts ...Option)

+ func ListenWS(addr string, opts ...Option)

+ func Register(c component.Component, options ...component.Option)

+ func SetCheckOriginFunc(fn func(*http.Request) bool)

+ func SetDictionary(dict map[string]uint16)

+ func SetHeartbeatInterval(d time.Duration)

+ func SetLogger(l Logger)

+ func SetSerializer(seri serialize.Serializer)

+ func SetTimerPrecision(precision time.Duration)

+ func SetWSPath(path string)

+ func Shutdown()

+ type Group struct

+ func NewGroup(n string) *Group

+ func (c *Group) Add(session *session.Session) error

+ func (c *Group) Broadcast(route string, v interface{}) error

+ func (c *Group) Close() error

+ func (c *Group) Contains(uid int64) bool

+ func (c *Group) Count() int

+ func (c *Group) Leave(s *session.Session) error

+ func (c *Group) LeaveAll() error

+ func (c *Group) Member(uid int64) (*session.Session, error)

+ func (c *Group) Members() []int64

+ func (c *Group) Multicast(route string, v interface{}, filter SessionFilter) error

+ type Logger interface

+ Fatal func(v ...interface{})

+ Println func(v ...interface{})

+ type Message struct

+ type Option func(*options)

+ func WithPipeline(pipeline Pipeline) Option

+ type Pipeline interface

+ Inbound func() PipelineChannel

+ Outbound func() PipelineChannel

+ func NewPipeline() Pipeline

+ type PipelineChannel interface

+ Process func(s *session.Session, msg Message) error

+ PushBack func(h PipelineFunc)

+ PushFront func(h PipelineFunc)

+ type PipelineFunc func(s *session.Session, msg Message) error

+ type SessionFilter func(*session.Session) bool

+ type Timer struct

+ func NewAfterTimer(duration time.Duration, fn TimerFunc) *Timer

+ func NewCondTimer(condition TimerCondition, fn TimerFunc) *Timer

+ func NewCountTimer(interval time.Duration, count int, fn TimerFunc) *Timer

+ func NewTimer(interval time.Duration, fn TimerFunc) *Timer

+ func (t *Timer) ID() int64

+ func (t *Timer) Stop()

+ type TimerCondition interface

+ Check func(now time.Time) bool

+ type TimerFunc func()

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