game

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 18, 2020 License: MIT Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFlags 

func NewFlags() []cli.Flag

Types

type AccountManager 

type AccountManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewAccountManager 

func NewAccountManager(game *Game, ctx *cli.Context) *AccountManager

func (*AccountManager) AccountLogon 

func (am *AccountManager) AccountLogon(userID int64, accountID int64, accountName string, sock transport.Socket) (*player.Account, error)

func (*AccountManager) BroadCast 

func (am *AccountManager) BroadCast(msg proto.Message)

func (*AccountManager) CreatePlayer 

func (am *AccountManager) CreatePlayer(c *player.Account, name string) (*player.Player, error)

func (*AccountManager) DisconnectAccount 

func (am *AccountManager) DisconnectAccount(ac *player.Account, reason string)

func (*AccountManager) DisconnectAccountByID 

func (am *AccountManager) DisconnectAccountByID(id int64, reason string)

func (*AccountManager) DisconnectAccountBySock 

func (am *AccountManager) DisconnectAccountBySock(sock transport.Socket, reason string)

func (*AccountManager) Exit 

func (am *AccountManager) Exit()

func (*AccountManager) GetAccountByID 

func (am *AccountManager) GetAccountByID(acctID int64) *player.Account

func (*AccountManager) GetAccountBySock 

func (am *AccountManager) GetAccountBySock(sock transport.Socket) *player.Account

func (*AccountManager) GetAllAccounts 

func (am *AccountManager) GetAllAccounts() []*player.Account

func (*AccountManager) GetLiteAccount 

func (am *AccountManager) GetLiteAccount(acctID int64) *player.LiteAccount

func (*AccountManager) Main 

func (am *AccountManager) Main() error

func (*AccountManager) Run 

func (am *AccountManager) Run() error

func (*AccountManager) SelectPlayer 

func (am *AccountManager) SelectPlayer(c *player.Account, id int64) (*player.Player, error)

func (*AccountManager) TableName 

func (am *AccountManager) TableName() string

type Game 

type Game struct {
	ID        int16
	SectionID int16
	sync.RWMutex
	// contains filtered or unexported fields
}

func New 

func New() (*Game, error)

func (*Game) Action 

func (g *Game) Action(c *cli.Context) error

func (*Game) After 

func (g *Game) After(c *cli.Context) error

func (*Game) ExpireLitePlayer 

func (g *Game) ExpireLitePlayer(playerID int64)

func (*Game) ExpirePlayer 

func (g *Game) ExpirePlayer(playerID int64)

func (*Game) Run 

func (g *Game) Run(arguments []string) error

func (*Game) StartGate 

func (g *Game) StartGate()

///////////////////////////////////////////////////// pubsub /////////////////////////////////////////////////////

func (*Game) Stop 

func (g *Game) Stop()

type MC_AccountTest 

type MC_AccountTest struct {
	AccountId int64  `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*MC_AccountTest) GetName 

func (msg *MC_AccountTest) GetName() string

type MicroService 

type MicroService struct {
	// contains filtered or unexported fields
}

func NewMicroService 

func NewMicroService(g *Game, c *ucli.Context) *MicroService

func (*MicroService) Run 

func (s *MicroService) Run() error

type MsgHandler 

type MsgHandler struct {
	// contains filtered or unexported fields
}

func NewMsgHandler 

func NewMsgHandler(g *Game) *MsgHandler

type PlayerManager 

type PlayerManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPlayerManager 

func NewPlayerManager(g *Game, ctx *cli.Context) *PlayerManager

func (*PlayerManager) CreatePlayer 

func (m *PlayerManager) CreatePlayer(acct *player.Account, name string) (*player.Player, error)

func (*PlayerManager) Exit 

func (m *PlayerManager) Exit()

func (*PlayerManager) ExpireLitePlayer 

func (m *PlayerManager) ExpireLitePlayer(playerID int64)

func (*PlayerManager) ExpirePlayer 

func (m *PlayerManager) ExpirePlayer(playerID int64)

func (*PlayerManager) GetPlayerByAccount 

func (m *PlayerManager) GetPlayerByAccount(acct *player.Account) *player.Player

func (*PlayerManager) Main 

func (m *PlayerManager) Main() error

func (*PlayerManager) Run 

func (m *PlayerManager) Run() error

func (*PlayerManager) TableName 

func (m *PlayerManager) TableName() string

type PubSub 

type PubSub struct {
	// contains filtered or unexported fields
}

func NewPubSub 

func NewPubSub(g *Game) *PubSub

func (*PubSub) PubExpireLitePlayer 

func (ps *PubSub) PubExpireLitePlayer(ctx context.Context, playerID int64) error

func (*PubSub) PubExpirePlayer 

func (ps *PubSub) PubExpirePlayer(ctx context.Context, playerID int64) error

func (*PubSub) PubStartGate 

func (ps *PubSub) PubStartGate(ctx context.Context, c *pbAccount.LiteAccount) error

/////////////////////////////////// publish handle ///////////////////////////////////

type RpcHandler 

type RpcHandler struct {
	// contains filtered or unexported fields
}

func NewRpcHandler 

func NewRpcHandler(g *Game) *RpcHandler

func (*RpcHandler) CallGetGateStatus 

func (h *RpcHandler) CallGetGateStatus() (*pbGate.GetGateStatusReply, error)

/////////////////////////////////////////// rpc call ///////////////////////////////////////////

func (*RpcHandler) CallGetRemoteLiteAccount 

func (h *RpcHandler) CallGetRemoteLiteAccount(acctID int64) (*pbGame.GetRemoteLiteAccountReply, error)

func (*RpcHandler) CallGetRemoteLitePlayer 

func (h *RpcHandler) CallGetRemoteLitePlayer(playerID int64) (*pbGame.GetRemoteLitePlayerReply, error)

func (*RpcHandler) CallUpdateUserInfo 

func (h *RpcHandler) CallUpdateUserInfo(c *player.Account) (*pbGate.GateEmptyMessage, error)

func (*RpcHandler) GetRemoteLiteAccount 

func (h *RpcHandler) GetRemoteLiteAccount(ctx context.Context, req *pbGame.GetRemoteLiteAccountRequest, rsp *pbGame.GetRemoteLiteAccountReply) error

/////////////////////////////////////////// rpc receive ///////////////////////////////////////////

func (*RpcHandler) GetRemoteLitePlayer 

func (h *RpcHandler) GetRemoteLitePlayer(ctx context.Context, req *pbGame.GetRemoteLitePlayerRequest, rsp *pbGame.GetRemoteLitePlayerReply) error

func (*RpcHandler) UpdatePlayerExp 

func (h *RpcHandler) UpdatePlayerExp(ctx context.Context, req *pbGame.UpdatePlayerExpRequest, rsp *pbGame.UpdatePlayerExpReply) error

type TcpServer 

type TcpServer struct {
	// contains filtered or unexported fields
}

func NewTcpServer 

func NewTcpServer(g *Game, ctx *cli.Context) *TcpServer

func (*TcpServer) Exit 

func (s *TcpServer) Exit()

func (*TcpServer) Run 

func (s *TcpServer) Run() error

type WsServer 

type WsServer struct {
	// contains filtered or unexported fields
}

func NewWsServer 

func NewWsServer(g *Game, ctx *cli.Context) *WsServer

func (*WsServer) Exit 

func (s *WsServer) Exit()

func (*WsServer) Run 

func (s *WsServer) Run() error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.