lox

package
v0.1.40 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2021 License: MIT Imports: 41 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	TimeOut                  = time.Second * 15
	UpdateTime               = time.Second * 15
	LeaseDuration      int64 = 23
	LeaseRenewDuration int64 = 15
)
View Source 
const (
	MUTEX_AVATAR_SESSION_KEY lokas.Key = "avatar_session_%d"
	AVATAR_SESSION_KEY       lokas.Key = "/avatar_session/%d"
)
View Source 
const (
	TAG_USER             = 130
	TAG_JWT              = 131
	TAG_CLAIM_USER       = 132
	TAG_AVATAR_MAP       = 133
	TAG_AVATAR           = 134
	TAG_ADMIN_CMD        = 135
	TAG_ADMIN_CMD_RESULT = 136
	TAG_CREATE_AVATAR    = 137
	TAG_KICK_AVATAR      = 138
	TAG_RESPONSE         = 140
	TAG_CONSOLE_EVENT    = 221
)
View Source 
const (
	HeaderSize            = 8
	ProtectLongPacketSize = 4 * 1024 * 1024
)
View Source 
const (
	PingInterval = time.Second * 3
)
View Source 
const REFRESH_TOKEN_EXPIRE_TIME = time.Hour * 24 * 30
View Source 
const TOKEN_EXPIRE_TIME = time.Minute * 10

Variables

View Source 
var CenterCtor = centerCtor{}
View Source 
var GateCtor = gateCtor{}
View Source 
var HttpCtor = httpCtor{}
View Source 
var ProxyCtor = proxyCtor{}

Functions

func CreateUser added in v0.1.29 

func CreateUser() interface{}

func JwtAuth 

func JwtAuth(rsa bool, creator JwtClaimCreator, userCreator UserCreator) func(w rox.ResponseWriter, r *http.Request, a lokas.IProcess, next http.Handler)

func JwtSign 

func JwtSign(rsa bool, creator JwtClaimCreator) func(w rox.ResponseWriter, r *http.Request, a lokas.IProcess, next http.Handler)

func LogUserInfo added in v0.1.29 

func LogUserInfo(user *User) log.ZapFields

func NewAvatarManagerCtor added in v0.1.29 

func NewAvatarManagerCtor(option lokas.IGameHandler) avatarManagerCtor

func NewModuleFromRegistry 

func NewModuleFromRegistry(s string) (lokas.IModule, error)

func NewWebSocket added in v0.1.35 

func NewWebSocket(url string, client *WsClient, p protocol.TYPE) (*wsImpl, error)

func RegisterModule 

func RegisterModule(creator Creator)

func RegisterModulesFromPlugin 

func RegisterModulesFromPlugin(path string) error

func SignToken 

func SignToken(creator JwtClaimCreator, user interface{}, a lokas.IProcess, expire time.Duration, rsa bool) (string, error)

func UserId added in v0.1.29 

func UserId(user *User) zap.Field

func UserRefreshToken added in v0.1.29 

func UserRefreshToken(user *User) zap.Field

func UserToken added in v0.1.29 

func UserToken(user *User) zap.Field

Types

type AccState added in v0.1.29 

type AccState uint32
const (
	ACC_NORMAL    AccState = 0
	ACC_MUTE      AccState = 1
	ACC_FROST     AccState = 8
	ACC_FORBIDDEN AccState = 9
)

type ActiveSession added in v0.0.6 

type ActiveSession struct {
	util.ID

	Messages chan []byte
	Conn     lokas.IConn
	Protocol protocol.TYPE

	OnCloseFunc func(conn lokas.IConn)
	OnOpenFunc  func(conn lokas.IConn)
	OnVerified  func(conn lokas.IConn)
	MsgHandler  func(msg *protocol.BinaryMessage)
	// contains filtered or unexported fields
}

func NewActiveSession added in v0.0.6 

func NewActiveSession(conn lokas.IConn, id util.ID, manager lokas.ISessionManager, opts ...ActiveSessionOption) *ActiveSession

func (*ActiveSession) AsyncCall added in v0.0.6 

func (this *ActiveSession) AsyncCall(actorId util.ID, transId uint32, req protocol.ISerializable, resp protocol.ISerializable) error

func (*ActiveSession) Call added in v0.0.6 

func (this *ActiveSession) Call(actorId util.ID, transId uint32, req protocol.ISerializable, resp protocol.ISerializable) error

func (*ActiveSession) CloneEntity added in v0.0.6 

func (this *ActiveSession) CloneEntity() *ecs.Entity

func (*ActiveSession) GetConn added in v0.0.6 

func (this *ActiveSession) GetConn() lokas.IConn

func (*ActiveSession) GetId added in v0.0.6 

func (this *ActiveSession) GetId() util.ID

func (*ActiveSession) GetProcess added in v0.0.6 

func (this *ActiveSession) GetProcess() lokas.IProcess

func (*ActiveSession) OnClose added in v0.0.6 

func (this *ActiveSession) OnClose(conn lokas.IConn)

func (*ActiveSession) OnCreate added in v0.0.6 

func (this *ActiveSession) OnCreate() error

func (*ActiveSession) OnDestroy added in v0.0.6 

func (this *ActiveSession) OnDestroy() error

func (*ActiveSession) OnMessage added in v0.0.6 

func (this *ActiveSession) OnMessage(actorId util.ID, transId uint32, msg protocol.ISerializable) error

func (*ActiveSession) OnOpen added in v0.0.6 

func (this *ActiveSession) OnOpen(conn lokas.IConn)

func (*ActiveSession) OnRecv added in v0.0.6 

func (this *ActiveSession) OnRecv(conn lokas.IConn, data []byte)

func (*ActiveSession) PongHandler added in v0.0.6 

func (this *ActiveSession) PongHandler(pong *protocol.Pong)

func (*ActiveSession) SendMessage added in v0.0.6 

func (this *ActiveSession) SendMessage(actorId util.ID, transId uint32, msg protocol.ISerializable) error

func (*ActiveSession) SetId added in v0.0.6 

func (this *ActiveSession) SetId(id util.ID)

func (*ActiveSession) SetProcess added in v0.0.6 

func (this *ActiveSession) SetProcess(process lokas.IProcess)

func (*ActiveSession) Start added in v0.0.6 

func (this *ActiveSession) Start() error

func (*ActiveSession) Stop added in v0.0.6 

func (this *ActiveSession) Stop() error

func (*ActiveSession) Type added in v0.0.6 

func (this *ActiveSession) Type() string

func (*ActiveSession) Update added in v0.0.6 

func (this *ActiveSession) Update(dt time.Duration, now time.Time)

func (*ActiveSession) Write added in v0.0.6 

func (this *ActiveSession) Write(data []byte) error

type ActiveSessionOption added in v0.1.25 

type ActiveSessionOption func(*ActiveSession)

type Actor 

type Actor struct {
	lokas.IEntity

	OnUpdateFunc func()
	MsgHandler   func(actorId util.ID, transId uint32, msg protocol.ISerializable) (protocol.ISerializable, error)
	// contains filtered or unexported fields
}

func NewActor 

func NewActor() *Actor

func (*Actor) Call 

func (this *Actor) Call(actorId util.ID, req protocol.ISerializable) (protocol.ISerializable, error)

func (*Actor) GetLeaseId 

func (this *Actor) GetLeaseId() (clientv3.LeaseID, bool, error)

return leaseId,(bool)is registered,error

func (*Actor) GetProcess 

func (this *Actor) GetProcess() lokas.IProcess

func (*Actor) Load added in v0.1.25 

func (this *Actor) Load(conf lokas.IConfig) error

func (*Actor) OnMessage 

func (this *Actor) OnMessage(msg *protocol.RouteMessage)

func (*Actor) OnStart added in v0.1.25 

func (this *Actor) OnStart() error

func (*Actor) OnStop added in v0.1.25 

func (this *Actor) OnStop() error

func (*Actor) PId added in v0.1.4 

func (this *Actor) PId() util.ProcessId

func (*Actor) ReceiveMessage 

func (this *Actor) ReceiveMessage(msg *protocol.RouteMessage)

func (*Actor) Send added in v0.1.25 

func (this *Actor) Send(id util.ProcessId, msg *protocol.RouteMessage) error

func (*Actor) SendMessage 

func (this *Actor) SendMessage(actorId util.ID, transId uint32, msg protocol.ISerializable) error

func (*Actor) SendReply 

func (this *Actor) SendReply(actorId util.ID, transId uint32, msg protocol.ISerializable) error

func (*Actor) SetProcess 

func (this *Actor) SetProcess(process lokas.IProcess)

func (*Actor) SetType added in v0.0.9 

func (this *Actor) SetType(s string)

func (*Actor) Start added in v0.1.25 

func (this *Actor) Start() error

func (*Actor) StartMessagePump 

func (this *Actor) StartMessagePump()

func (*Actor) Stop added in v0.1.25 

func (this *Actor) Stop() error

func (*Actor) Type added in v0.0.9 

func (this *Actor) Type() string

func (*Actor) Unload added in v0.1.25 

func (this *Actor) Unload() error

func (*Actor) Update 

func (this *Actor) Update(dt time.Duration, now time.Time)

type ActorContainer 

type ActorContainer struct {
	Actors map[util.ID]lokas.IActor
	// contains filtered or unexported fields
}

func NewActorContainer 

func NewActorContainer(process lokas.IProcess) *ActorContainer

func (*ActorContainer) AddActor 

func (this *ActorContainer) AddActor(actor lokas.IActor)

func (*ActorContainer) GetActor 

func (this *ActorContainer) GetActor(id util.ID) lokas.IActor

func (*ActorContainer) GetActorIds 

func (this *ActorContainer) GetActorIds() []util.ID

func (*ActorContainer) GetProcess 

func (this *ActorContainer) GetProcess() lokas.IProcess

func (*ActorContainer) Load 

func (this *ActorContainer) Load(conf lokas.IConfig) error

func (*ActorContainer) OnStart 

func (this *ActorContainer) OnStart() error

func (*ActorContainer) OnStop 

func (this *ActorContainer) OnStop() error

func (*ActorContainer) RemoveActor 

func (this *ActorContainer) RemoveActor(actor lokas.IActor)

func (*ActorContainer) RemoveActorById 

func (this *ActorContainer) RemoveActorById(id util.ID) lokas.IActor

func (*ActorContainer) SetProcess 

func (this *ActorContainer) SetProcess(process lokas.IProcess)

func (*ActorContainer) Start 

func (this *ActorContainer) Start() error

func (*ActorContainer) StartActor 

func (this *ActorContainer) StartActor(actor lokas.IActor) error

func (*ActorContainer) Stop 

func (this *ActorContainer) Stop() error

func (*ActorContainer) StopActor 

func (this *ActorContainer) StopActor(actor lokas.IActor)

func (*ActorContainer) Type 

func (this *ActorContainer) Type() string

func (*ActorContainer) Unload 

func (this *ActorContainer) Unload() error

type ActorRegistry 

type ActorRegistry struct {
	Id        util.ID
	ProcessId util.ProcessId
	Type      string
	GameId    string
	Version   string
	ServerId  int32
	//Health    lokas.ActorState
	Ts time.Time
}

func NewActorRegistry 

func NewActorRegistry(id util.ID) *ActorRegistry

type ActorRegistryInfo 

type ActorRegistryInfo struct {
	Id        util.ID
	Type      string
	ProcessId util.ProcessId
	GameId    string
	Version   string
	ServerId  int32
	Ts        time.Time
}

func CreateActorRegistryInfo 

func CreateActorRegistryInfo(actor lokas.IActor) *ActorRegistryInfo

type AdminCommand added in v0.1.29 

type AdminCommand struct {
	Command  string
	Username string
	Params   []string
}

func NewAdminCommand added in v0.1.29 

func NewAdminCommand(cmd string, username string, params ...interface{}) *AdminCommand

func (*AdminCommand) GetId added in v0.1.29 

func (this *AdminCommand) GetId() (protocol.BINARY_TAG, error)

func (*AdminCommand) ParamsValue added in v0.1.29 

func (this *AdminCommand) ParamsValue() *cmds.ParamsValue

func (*AdminCommand) Serializable added in v0.1.29 

func (this *AdminCommand) Serializable() protocol.ISerializable

type AdminCommandResult added in v0.1.29 

type AdminCommandResult struct {
	Command  string
	Username string
	Success  bool
	Data     []byte
}

func NewAdminCommandResult added in v0.1.29 

func NewAdminCommandResult(cmd *AdminCommand, success bool, data []byte) *AdminCommandResult

func (*AdminCommandResult) GetId added in v0.1.29 

func (this *AdminCommandResult) GetId() (protocol.BINARY_TAG, error)

func (*AdminCommandResult) Serializable added in v0.1.29 

func (this *AdminCommandResult) Serializable() protocol.ISerializable

type AdminHandShake added in v0.1.29 

type AdminHandShake struct {
	Account  string
	Password string
}

func NewAdminHandShake added in v0.1.29 

func NewAdminHandShake(acc string, pass string) *AdminHandShake

func (*AdminHandShake) Marshal added in v0.1.29 

func (this *AdminHandShake) Marshal() ([]byte, error)

func (*AdminHandShake) Unmarshal added in v0.1.29 

func (this *AdminHandShake) Unmarshal(from []byte) error

type AppConfig 

type AppConfig struct {
	*viper.Viper
	// contains filtered or unexported fields
}

func NewAppConfig 

func NewAppConfig(name string, opts ...ConfigOption) *AppConfig

func NewSubAppConfig 

func NewSubAppConfig(name string, parent *AppConfig, conf *viper.Viper) *AppConfig

func (*AppConfig) AllSettings 

func (this *AppConfig) AllSettings() map[string]interface{}

func (*AppConfig) Get 

func (this *AppConfig) Get(key string) interface{}

func (*AppConfig) GetBool 

func (this *AppConfig) GetBool(key string) bool

func (*AppConfig) GetDuration 

func (this *AppConfig) GetDuration(key string) time.Duration

func (*AppConfig) GetFloat64 

func (this *AppConfig) GetFloat64(key string) float64

func (*AppConfig) GetFolder 

func (this *AppConfig) GetFolder() string

func (*AppConfig) GetInt 

func (this *AppConfig) GetInt(key string) int

func (*AppConfig) GetIntSlice 

func (this *AppConfig) GetIntSlice(key string) []int

func (*AppConfig) GetSizeInBytes 

func (this *AppConfig) GetSizeInBytes(key string) uint

func (*AppConfig) GetString 

func (this *AppConfig) GetString(key string) string

func (*AppConfig) GetStringMap 

func (this *AppConfig) GetStringMap(key string) map[string]interface{}

func (*AppConfig) GetStringMapString 

func (this *AppConfig) GetStringMapString(key string) map[string]string

func (*AppConfig) GetStringMapStringSlice 

func (this *AppConfig) GetStringMapStringSlice(key string) map[string][]string

func (*AppConfig) GetStringSlice 

func (this *AppConfig) GetStringSlice(key string) []string

func (*AppConfig) GetTime 

func (this *AppConfig) GetTime(key string) time.Time

func (*AppConfig) IsSet 

func (this *AppConfig) IsSet(key string) bool

func (*AppConfig) Load 

func (this *AppConfig) Load() error

func (*AppConfig) LoadFromRemote 

func (this *AppConfig) LoadFromRemote() error

func (*AppConfig) Save 

func (this *AppConfig) Save() error

func (*AppConfig) Set 

func (this *AppConfig) Set(key string, value interface{})

func (*AppConfig) SetFolder 

func (this *AppConfig) SetFolder(f string)

func (*AppConfig) SetRemoteConfig 

func (this *AppConfig) SetRemoteConfig(p string, etcd string)

func (*AppConfig) Sub 

func (this *AppConfig) Sub(key string) lokas.IConfig

type Avatar 

type Avatar struct {
	*Actor
	*AvatarSession

	Serializer   func(avatar lokas.IActor, process lokas.IProcess) error
	Deserializer func(avatar lokas.IActor, process lokas.IProcess) error
	Updater      func(avatar lokas.IActor, process lokas.IProcess) error
	MsgDelegator func(avatar lokas.IActor, actorId util.ID, transId uint32, msg protocol.ISerializable) (protocol.ISerializable, error)
	// contains filtered or unexported fields
}

func NewAvatar 

func NewAvatar(id util.ID, handler lokas.IGameHandler, manager *AvatarManager) *Avatar

func (*Avatar) Deserialize 

func (this *Avatar) Deserialize(a lokas.IProcess) error

func (*Avatar) Load 

func (this *Avatar) Load(conf lokas.IConfig) error

func (*Avatar) OnStart 

func (this *Avatar) OnStart() error

func (*Avatar) OnStop 

func (this *Avatar) OnStop() error

func (*Avatar) OnUpdate added in v0.1.29 

func (this *Avatar) OnUpdate()

func (*Avatar) SendEvent added in v0.1.29 

func (this *Avatar) SendEvent(msg protocol.ISerializable) error

func (*Avatar) Serialize 

func (this *Avatar) Serialize(a lokas.IProcess) error

func (*Avatar) Start 

func (this *Avatar) Start() error

func (*Avatar) Stop 

func (this *Avatar) Stop() error

func (*Avatar) Unload 

func (this *Avatar) Unload() error

type AvatarManager 

type AvatarManager struct {
	*Actor
	Avatars map[util.ID]*Avatar
	Option  lokas.IGameHandler
	// contains filtered or unexported fields
}

func (*AvatarManager) CreateAvatar 

func (this *AvatarManager) CreateAvatar(id util.ID) error

func (*AvatarManager) GetAvatar 

func (this *AvatarManager) GetAvatar(id util.ID) *Avatar

func (*AvatarManager) HandleMsg added in v0.1.29 

func (this *AvatarManager) HandleMsg(actorId util.ID, transId uint32, msg protocol.ISerializable) (protocol.ISerializable, error)

func (*AvatarManager) Load 

func (this *AvatarManager) Load(conf lokas.IConfig) error

func (*AvatarManager) OnStart 

func (this *AvatarManager) OnStart() error

func (*AvatarManager) OnStop 

func (this *AvatarManager) OnStop() error

func (*AvatarManager) OnUpdate 

func (this *AvatarManager) OnUpdate()

func (*AvatarManager) RemoveAvatar 

func (this *AvatarManager) RemoveAvatar(id util.ID)

func (*AvatarManager) Start 

func (this *AvatarManager) Start() error

func (*AvatarManager) Stop 

func (this *AvatarManager) Stop() error

func (*AvatarManager) Unload 

func (this *AvatarManager) Unload() error

type AvatarMap added in v0.1.29 

type AvatarMap struct {
	Id       util.ID `bson:"_id"`
	UserId   util.ID
	GameId   string
	ServerId int32
	UserName string
}

type AvatarSession added in v0.1.29 

type AvatarSession struct {
	Id       util.ID
	UserId   util.ID
	GateId   util.ID
	UserName string
	GameId   string
	ServerId int32
	// contains filtered or unexported fields
}

func NewAvatarSession added in v0.1.29 

func NewAvatarSession(id util.ID) *AvatarSession

func (*AvatarSession) ChangeUserName added in v0.1.35 

func (this *AvatarSession) ChangeUserName(a lokas.IProcess, name string) error

func (*AvatarSession) Deserialize added in v0.1.29 

func (this *AvatarSession) Deserialize(a lokas.IProcess) error

func (*AvatarSession) FetchData added in v0.1.29 

func (this *AvatarSession) FetchData(a lokas.IProcess) error

func (*AvatarSession) GetGameId added in v0.1.29 

func (this *AvatarSession) GetGameId() string

func (*AvatarSession) GetGateId added in v0.1.29 

func (this *AvatarSession) GetGateId() util.ID

func (*AvatarSession) GetId added in v0.1.29 

func (this *AvatarSession) GetId() util.ID

func (*AvatarSession) GetServerId added in v0.1.29 

func (this *AvatarSession) GetServerId() int32

func (*AvatarSession) GetUserId added in v0.1.35 

func (this *AvatarSession) GetUserId() util.ID

func (*AvatarSession) GetUserName added in v0.1.29 

func (this *AvatarSession) GetUserName() string

func (*AvatarSession) Serialize added in v0.1.29 

func (this *AvatarSession) Serialize(a lokas.IProcess) error

func (*AvatarSession) SetGateId added in v0.1.29 

func (this *AvatarSession) SetGateId(id util.ID)

func (*AvatarSession) SetOnGateWayChanged added in v0.1.29 

func (this *AvatarSession) SetOnGateWayChanged(f func(session *AvatarSession))

func (*AvatarSession) SetOnSessionClosed added in v0.1.29 

func (this *AvatarSession) SetOnSessionClosed(f func())

func (*AvatarSession) StartAvatarSession added in v0.1.29 

func (this *AvatarSession) StartAvatarSession()

func (*AvatarSession) StopAvatarSession added in v0.1.29 

func (this *AvatarSession) StopAvatarSession()

type Block 

type Block struct {
}

basic data unit,represent a block of gamespace

type Cell 

type Cell struct {
	*Actor
	Blocks map[int64]Block
}

unit processor of world server/game room

type CellManager 

type CellManager struct {
	*Actor
	ActorContainer
	Blocks map[int64]Block
}

func (*CellManager) Load 

func (this *CellManager) Load(conf lokas.IConfig) error

func (*CellManager) OnStart 

func (this *CellManager) OnStart() error

func (*CellManager) OnStop 

func (this *CellManager) OnStop() error

func (*CellManager) Spawn 

func (this *CellManager) Spawn() lokas.IActor

func (*CellManager) Unload 

func (this *CellManager) Unload() error

type Center 

type Center struct {
	*Actor
	UseEtcd bool
}

func (*Center) Load 

func (this *Center) Load(conf lokas.IConfig) error

func (*Center) OnCreate 

func (this *Center) OnCreate() error

func (*Center) OnDestroy 

func (this *Center) OnDestroy() error

func (*Center) OnRegister 

func (this *Center) OnRegister()

func (*Center) OnStart 

func (this *Center) OnStart() error

func (*Center) OnStop 

func (this *Center) OnStop() error

func (*Center) Start 

func (this *Center) Start() error

func (*Center) Stop 

func (this *Center) Stop() error

func (*Center) Unload 

func (this *Center) Unload() error

type ClaimUser added in v0.1.29 

type ClaimUser struct {
	Create time.Time
	Expire int64
	User   *User
}

func (*ClaimUser) GetUser added in v0.1.29 

func (this *ClaimUser) GetUser() interface{}

func (*ClaimUser) Marshal added in v0.1.29 

func (this *ClaimUser) Marshal() ([]byte, error)

func (*ClaimUser) SetUser added in v0.1.29 

func (this *ClaimUser) SetUser(user interface{})

func (*ClaimUser) Unmarshal added in v0.1.29 

func (this *ClaimUser) Unmarshal(v []byte) error

func (*ClaimUser) Valid added in v0.1.29 

func (this *ClaimUser) Valid() error

type CommonRegistry 

type CommonRegistry struct {
	Processes      map[util.ProcessId]*ProcessRegistry
	Service        map[protocol.BINARY_TAG]*ServiceRegistry
	Actors         map[util.ID]*ActorRegistry
	ActorsByType   map[string][]util.ID
	ActorsByServer map[int32][]util.ID
	Ts             time.Time
	// contains filtered or unexported fields
}

func NewCommonRegistry 

func NewCommonRegistry() *CommonRegistry

func (*CommonRegistry) AddActor 

func (this *CommonRegistry) AddActor(actor *ActorRegistry)

func (*CommonRegistry) AddProcess 

func (this *CommonRegistry) AddProcess(process *ProcessRegistry)

func (*CommonRegistry) AddService 

func (this *CommonRegistry) AddService(service *ServiceRegistry)

func (*CommonRegistry) GetActorIdsByTypeAndServerId 

func (this *CommonRegistry) GetActorIdsByTypeAndServerId(serverId int32, typ string) []util.ID

func (*CommonRegistry) GetActorRegistry 

func (this *CommonRegistry) GetActorRegistry(id util.ID) *ActorRegistry

func (*CommonRegistry) RemoveActor 

func (this *CommonRegistry) RemoveActor(actorId util.ID)

func (*CommonRegistry) RemoveProcess 

func (this *CommonRegistry) RemoveProcess(id util.ProcessId)

func (*CommonRegistry) RemoveService 

func (this *CommonRegistry) RemoveService(id protocol.BINARY_TAG)

type ConfigOption 

type ConfigOption func(*AppConfig) *AppConfig

func ConfigFile 

func ConfigFile(folder string) ConfigOption

func EtcdFile 

func EtcdFile(etcdPath string, addr string) ConfigOption

func MongoFile 

func MongoFile(folder string) ConfigOption

type ConnType 

type ConnType int
const (
	TCP       ConnType = 0
	Websocket ConnType = 1
)

func String2ConnType 

func String2ConnType(s string) ConnType

func (ConnType) String 

func (this ConnType) String() string

type ConsoleEvent added in v0.1.31 

type ConsoleEvent struct {
	Text string
}

func NewConsoleEvent added in v0.1.31 

func NewConsoleEvent(text string) *ConsoleEvent

func (*ConsoleEvent) GetId added in v0.1.31 

func (this *ConsoleEvent) GetId() (protocol.BINARY_TAG, error)

func (*ConsoleEvent) Serializable added in v0.1.31 

func (this *ConsoleEvent) Serializable() protocol.ISerializable

type Context 

type Context struct {
	Content map[string]interface{} `json:"content"`
}

func NewContext 

func NewContext() *Context

func (*Context) Get 

func (this *Context) Get(key string) interface{}

func (*Context) GetIdType 

func (this *Context) GetIdType(key string) util.ID

func (*Context) GetProcessIdType 

func (this *Context) GetProcessIdType(key string) util.ProcessId

func (*Context) GetString 

func (this *Context) GetString(key string) string

func (*Context) Set 

func (this *Context) Set(key string, value interface{})

type CreateAvatar added in v0.1.29 

type CreateAvatar struct {
	Id int64
}

创建角色

func NewCreateAvatar added in v0.1.29 

func NewCreateAvatar(id util.ID) *CreateAvatar

func (*CreateAvatar) GetId added in v0.1.29 

func (this *CreateAvatar) GetId() (protocol.BINARY_TAG, error)

func (*CreateAvatar) Serializable added in v0.1.29 

func (this *CreateAvatar) Serializable() protocol.ISerializable

type Creator 

type Creator func() lokas.IModule

type DefaultConfig 

type DefaultConfig struct {
	*AppConfig
	ProcessId util.ProcessId  `mapstructure:"pid"`
	ServerId  int32           `mapstructure:"sid"`
	GameId    string          `mapstructure:"gid"`
	Host      string          `mapstructure:"host"`
	Port      string          `mapstructure:"port"`
	Version   string          `mapstructure:"version"`
	SName     string          `mapstructure:"serverName"`
	Name      string          `mapstructure:"name"`
	Etcd      EtcdConfig      `mapstructure:"-"`
	Mongo     MongoConfig     `mapstructure:"-"`
	Mysql     MysqlConfig     `mapstructure:"-"`
	Redis     RedisConfig     `mapstructure:"-"`
	Mods      []lokas.IConfig `mapstructure:"-"`
	Modules   []string        `mapstructure:"modules"`
}

func NewDefaultConfig 

func NewDefaultConfig() *DefaultConfig

func (*DefaultConfig) GetAllSub 

func (this *DefaultConfig) GetAllSub() []lokas.IConfig

func (*DefaultConfig) GetDb 

func (this *DefaultConfig) GetDb(t string) interface{}

func (*DefaultConfig) GetGameId 

func (this *DefaultConfig) GetGameId() string

func (*DefaultConfig) GetIdType 

func (this *DefaultConfig) GetIdType(key string) util.ID

func (*DefaultConfig) GetName 

func (this *DefaultConfig) GetName() string

func (*DefaultConfig) GetProcessId 

func (this *DefaultConfig) GetProcessId() util.ProcessId

func (*DefaultConfig) GetProcessIdType 

func (this *DefaultConfig) GetProcessIdType(key string) util.ProcessId

func (*DefaultConfig) GetServerId 

func (this *DefaultConfig) GetServerId() int32

func (*DefaultConfig) GetVersion 

func (this *DefaultConfig) GetVersion() string

func (*DefaultConfig) Load 

func (this *DefaultConfig) Load() error

func (*DefaultConfig) LoadFromRemote 

func (this *DefaultConfig) LoadFromRemote() error

func (*DefaultConfig) LoadFromString 

func (this *DefaultConfig) LoadFromString(s string) error

func (*DefaultConfig) ServerName 

func (this *DefaultConfig) ServerName() string

type EtcdConfig 

type EtcdConfig struct {
	EndPoints []string `mapstructure:"endpoints"`
}

type GameHandler added in v0.1.29 

type GameHandler struct {
	Serializer   func(avatar lokas.IActor, process lokas.IProcess) error
	Deserializer func(avatar lokas.IActor, process lokas.IProcess) error
	Updater      func(avatar lokas.IActor, process lokas.IProcess) error
	MsgDelegator func(avatar lokas.IActor, actorId util.ID, transId uint32, msg protocol.ISerializable) (protocol.ISerializable, error)
}

func (*GameHandler) GetDeserializer added in v0.1.29 

func (this *GameHandler) GetDeserializer() func(avatar lokas.IActor, process lokas.IProcess) error

func (*GameHandler) GetMsgDelegator added in v0.1.29 

func (this *GameHandler) GetMsgDelegator() func(avatar lokas.IActor, actorId util.ID, transId uint32, msg protocol.ISerializable) (protocol.ISerializable, error)

func (*GameHandler) GetSerializer added in v0.1.29 

func (this *GameHandler) GetSerializer() func(avatar lokas.IActor, process lokas.IProcess) error

func (*GameHandler) GetUpdater added in v0.1.29 

func (this *GameHandler) GetUpdater() func(avatar lokas.IActor, process lokas.IProcess) error

type Gate 

type Gate struct {
	*Actor
	lokas.ISessionManager
	Host               string
	Port               string
	AuthFunc           func(data []byte) error
	SessionCreatorFunc func(conn lokas.IConn) lokas.ISession
	Protocol           protocol.TYPE
	// contains filtered or unexported fields
}

func (*Gate) Load 

func (this *Gate) Load(conf lokas.IConfig) error

func (*Gate) LoadCustom added in v0.1.29 

func (this *Gate) LoadCustom(host, port string, protocolType protocol.TYPE, connType ConnType) error

func (*Gate) OnCreate 

func (this *Gate) OnCreate() error

func (*Gate) OnDestroy 

func (this *Gate) OnDestroy() error

func (*Gate) OnStart 

func (this *Gate) OnStart() error

func (*Gate) OnStop 

func (this *Gate) OnStop() error

func (*Gate) SessionCreator 

func (this *Gate) SessionCreator(conn lokas.IConn) lokas.ISession

func (*Gate) Start 

func (this *Gate) Start() error

func (*Gate) Stop 

func (this *Gate) Stop() error

func (*Gate) Unload 

func (this *Gate) Unload() error

type Http 

type Http struct {
	*Actor
	Host string
	Port string
	// contains filtered or unexported fields
}

func (*Http) CreateHandlerFunc 

func (this *Http) CreateHandlerFunc(f rox.Handler) func(http.ResponseWriter, *http.Request)

func (*Http) HandleFunc 

func (this *Http) HandleFunc(path string, f rox.Handler) *rox.Route

func (*Http) Load 

func (this *Http) Load(conf lokas.IConfig) error

func (*Http) MatchRouter 

func (this *Http) MatchRouter(s string) *rox.Router

func (*Http) OnCreate 

func (this *Http) OnCreate() error

func (*Http) OnDestroy 

func (this *Http) OnDestroy() error

func (*Http) OnStart 

func (this *Http) OnStart() error

func (*Http) OnStop 

func (this *Http) OnStop() error

func (*Http) Path 

func (this *Http) Path(s string) *rox.Route

func (*Http) PathExcept 

func (this *Http) PathExcept(p string, m ...rox.MiddleWare) *Http

func (*Http) PathExcepts 

func (this *Http) PathExcepts(p []string, m ...rox.MiddleWare) *Http

func (*Http) PathIn 

func (this *Http) PathIn(p []string, m ...rox.MiddleWare) *Http

func (*Http) PathOnly 

func (this *Http) PathOnly(p string, m ...rox.MiddleWare) *Http

func (*Http) PathPrefix 

func (this *Http) PathPrefix(s string) *rox.Route

func (*Http) PrefixExcept 

func (this *Http) PrefixExcept(prefix string, m ...rox.MiddleWare) *Http

func (*Http) PrefixExceptStrict 

func (this *Http) PrefixExceptStrict(prefix string, m ...rox.MiddleWare) *Http

func (*Http) PrefixOnly 

func (this *Http) PrefixOnly(prefix string, m ...rox.MiddleWare) *Http

func (*Http) PrefixOnlyStrict 

func (this *Http) PrefixOnlyStrict(prefix string, m ...rox.MiddleWare) *Http

func (*Http) Start 

func (this *Http) Start() error

func (*Http) Stop 

func (this *Http) Stop() error

func (*Http) Unload 

func (this *Http) Unload() error

func (*Http) Use 

func (this *Http) Use(m ...rox.MiddleWare) *Http

func (*Http) When 

func (this *Http) When(matcher rox.MiddlewareMatcher, m ...rox.MiddleWare) *Http

type JwtClaim 

type JwtClaim struct {
	Create time.Time
	Expire int64
}

func NewJwtClaim 

func NewJwtClaim(expire time.Duration) *JwtClaim

func (*JwtClaim) Marshal 

func (this *JwtClaim) Marshal() ([]byte, error)

func (*JwtClaim) Unmarshal 

func (this *JwtClaim) Unmarshal(v []byte) error

func (*JwtClaim) Valid 

func (this *JwtClaim) Valid() error

type JwtClaimCreator 

type JwtClaimCreator func(user interface{}, expire time.Duration) JwtClaimWithUser

type JwtClaimWithUser 

type JwtClaimWithUser interface {
	jwt.Claims
	GetUser() interface{}
	SetUser(user interface{})
}

type KickAvatar added in v0.1.29 

type KickAvatar struct {
	Id int64
}

func NewKickAvatar added in v0.1.29 

func NewKickAvatar(id util.ID) *KickAvatar

func (*KickAvatar) GetId added in v0.1.29 

func (this *KickAvatar) GetId() (protocol.BINARY_TAG, error)

func (*KickAvatar) Serializable added in v0.1.29 

func (this *KickAvatar) Serializable() protocol.ISerializable

type LoginHandShake added in v0.1.29 

type LoginHandShake struct {
	GameId   string
	Version  string
	ServerId int32
	UserId   util.ID
	AvatarId util.ID
	Token    string
}

func NewLoginHandShake added in v0.1.29 

func NewLoginHandShake(gameId string, version string, serverId int32, userId util.ID, avatarId util.ID, token string) *LoginHandShake

func (*LoginHandShake) Marshal added in v0.1.29 

func (this *LoginHandShake) Marshal() ([]byte, error)

func (*LoginHandShake) Unmarshal added in v0.1.29 

func (this *LoginHandShake) Unmarshal(from []byte) error

type MongoConfig 

type MongoConfig struct {
	Host     string `mapstructure:"host"`
	Port     string `mapstructure:"port"`
	Database string `mapstructure:"database"`
	User     string `mapstructure:"user"`
	Password string `mapstructure:"password"`
}

type MysqlConfig 

type MysqlConfig struct {
	Host     string `mapstructure:"host"`
	Port     string `mapstructure:"port"`
	Database string `mapstructure:"database"`
	User     string `mapstructure:"user"`
	Password string `mapstructure:"password"`
}

type PassiveSession added in v0.0.6 

type PassiveSession struct {
	*Actor
	Verified bool
	Messages chan []byte
	Conn     lokas.IConn
	Protocol protocol.TYPE

	OnCloseFunc      func(conn lokas.IConn)
	OnOpenFunc       func(conn lokas.IConn)
	ClientMsgHandler func(msg *protocol.BinaryMessage)
	AuthFunc         func(data []byte) error
	// contains filtered or unexported fields
}

func NewPassiveSession added in v0.0.6 

func NewPassiveSession(conn lokas.IConn, id util.ID, manager lokas.ISessionManager, opts ...PassiveSessionOption) *PassiveSession

func (*PassiveSession) GetConn added in v0.0.6 

func (this *PassiveSession) GetConn() lokas.IConn

func (*PassiveSession) Load added in v0.0.6 

func (this *PassiveSession) Load(conf lokas.IConfig) error

func (*PassiveSession) OnClose added in v0.0.6 

func (this *PassiveSession) OnClose(conn lokas.IConn)

func (*PassiveSession) OnCreate added in v0.0.6 

func (this *PassiveSession) OnCreate() error

func (*PassiveSession) OnDestroy added in v0.0.6 

func (this *PassiveSession) OnDestroy() error

func (*PassiveSession) OnOpen added in v0.0.6 

func (this *PassiveSession) OnOpen(conn lokas.IConn)

func (*PassiveSession) OnRecv added in v0.0.6 

func (this *PassiveSession) OnRecv(conn lokas.IConn, data []byte)

func (*PassiveSession) OnStart added in v0.0.6 

func (this *PassiveSession) OnStart() error

func (*PassiveSession) OnStop added in v0.0.6 

func (this *PassiveSession) OnStop() error

func (*PassiveSession) Start added in v0.0.6 

func (this *PassiveSession) Start() error

func (*PassiveSession) StartMessagePump added in v0.0.6 

func (this *PassiveSession) StartMessagePump()

func (*PassiveSession) Stop added in v0.0.6 

func (this *PassiveSession) Stop() error

func (*PassiveSession) Unload added in v0.0.6 

func (this *PassiveSession) Unload() error

type PassiveSessionOption added in v0.1.25 

type PassiveSessionOption func(*PassiveSession)

type Process 

type Process struct {
	lokas.IActorContainer
	lokas.IRegistry
	lokas.IRouter
	lokas.IProxy
	// contains filtered or unexported fields
}

func CreateProcess 

func CreateProcess() *Process

func (*Process) Add 

func (this *Process) Add(mod lokas.IModule) lokas.IModule

func (*Process) Config 

func (this *Process) Config() lokas.IConfig

func (*Process) GameId 

func (this *Process) GameId() string

func (*Process) GameServerId 

func (this *Process) GameServerId() string

func (*Process) GenId 

func (this *Process) GenId() util.ID

GenId generate snowflake id

func (*Process) Get 

func (this *Process) Get(name string) lokas.IModule

func (*Process) GetEtcd 

func (this *Process) GetEtcd() *etcdclient.Client

func (*Process) GetId added in v0.1.4 

func (this *Process) GetId() util.ID

func (*Process) GetLogger 

func (this *Process) GetLogger() *log.ComposeLogger

func (*Process) GetMongo 

func (this *Process) GetMongo() *qmgo.Database

func (*Process) GetRedis 

func (this *Process) GetRedis() *redisclient.Client

func (*Process) GlobalMutex 

func (this *Process) GlobalMutex(key string, ttl int) (*etcdclient.Mutex, error)

func (*Process) Load 

func (this *Process) Load(config lokas.IProcessConfig) error

func (*Process) LoadAllModule 

func (this *Process) LoadAllModule(conf lokas.IProcessConfig) error

func (*Process) LoadMod 

func (this *Process) LoadMod(name string, conf lokas.IConfig) error

func (*Process) LoadModuleRegistry 

func (this *Process) LoadModuleRegistry() error

func (*Process) PId added in v0.1.4 

func (this *Process) PId() util.ProcessId

func (*Process) RegisterModule 

func (this *Process) RegisterModule(creator lokas.IModuleCtor)

func (*Process) SaveModuleRegistry 

func (this *Process) SaveModuleRegistry() error

func (*Process) ServerId 

func (this *Process) ServerId() int32

func (*Process) Start 

func (this *Process) Start() error

func (*Process) StartAllModule 

func (this *Process) StartAllModule() error

func (*Process) Stop 

func (this *Process) Stop() error

func (*Process) StopAllModule 

func (this *Process) StopAllModule() error

func (*Process) Type added in v0.1.4 

func (this *Process) Type() string

func (*Process) UnloadMod 

func (this *Process) UnloadMod(name string) error

func (*Process) Version 

func (this *Process) Version() string

type ProcessActorsInfo 

type ProcessActorsInfo struct {
	Id     util.ProcessId
	Actors []util.ID
	Ts     time.Time
}

func CreateProcessActorsInfo 

func CreateProcessActorsInfo(process lokas.IProcess) *ProcessActorsInfo

type ProcessRegistry 

type ProcessRegistry struct {
	Id       util.ProcessId
	GameId   string
	Version  string
	ServerId int32
	Host     string
	Port     string
	Services map[protocol.BINARY_TAG]*lokas.Service
	Actors   map[util.ID]*ActorRegistry
	Ts       time.Time
}

func NewProcessRegistry 

func NewProcessRegistry(id util.ProcessId) *ProcessRegistry

type ProcessRegistryInfo 

type ProcessRegistryInfo struct {
	Id       util.ProcessId
	GameId   string
	Version  string
	ServerId int32
	Host     string
	Port     string
	Ts       time.Time
}

func CreateProcessRegistryInfo 

func CreateProcessRegistryInfo(process lokas.IProcess) *ProcessRegistryInfo

type ProcessServiceInfo 

type ProcessServiceInfo struct {
	Id       util.ProcessId
	Services map[protocol.BINARY_TAG]int
}

type Proxy 

type Proxy struct {
	Host string
	Port string

	Sessions *ProxySessionManager
	// contains filtered or unexported fields
}

func NewProxy added in v0.1.25 

func NewProxy(process lokas.IProcess) *Proxy

func (*Proxy) GetProcess added in v0.1.25 

func (this *Proxy) GetProcess() lokas.IProcess

func (*Proxy) Load 

func (this *Proxy) Load(conf lokas.IConfig) error

func (*Proxy) OnCreate 

func (this *Proxy) OnCreate() error

func (*Proxy) OnDestroy 

func (this *Proxy) OnDestroy() error

func (*Proxy) OnStart 

func (this *Proxy) OnStart() error

func (*Proxy) OnStop 

func (this *Proxy) OnStop() error

func (*Proxy) Send added in v0.1.25 

func (this *Proxy) Send(id util.ProcessId, msg *protocol.RouteMessage) error

func (*Proxy) SetPort added in v0.1.25 

func (this *Proxy) SetPort(p string)

func (*Proxy) SetProcess added in v0.1.25 

func (this *Proxy) SetProcess(process lokas.IProcess)

func (*Proxy) Start 

func (this *Proxy) Start() error

func (*Proxy) Stop 

func (this *Proxy) Stop() error

func (*Proxy) Type 

func (this *Proxy) Type() string

func (*Proxy) Unload 

func (this *Proxy) Unload() error

type ProxySession added in v0.1.26 

type ProxySession struct {
	*Actor
	Verified bool
	Messages chan []byte
	Conn     lokas.IConn
	Protocol protocol.TYPE

	OnCloseFunc func(conn lokas.IConn)
	OnOpenFunc  func(conn lokas.IConn)
	OnVerified  func(success bool)
	MsgHandler  func(msg *protocol.BinaryMessage)
	AuthFunc    func(data []byte) error
	// contains filtered or unexported fields
}

func NewProxySession added in v0.1.26 

func NewProxySession(conn lokas.IConn, id util.ID, manager *ProxySessionManager, passive bool, opts ...SessionOption) *ProxySession

func (*ProxySession) GetConn added in v0.1.26 

func (this *ProxySession) GetConn() lokas.IConn

func (*ProxySession) GetProcess added in v0.1.26 

func (this *ProxySession) GetProcess() lokas.IProcess

func (*ProxySession) HandleMessage added in v0.1.26 

func (this *ProxySession) HandleMessage(f func(msg *protocol.BinaryMessage))

func (*ProxySession) OnClose added in v0.1.26 

func (this *ProxySession) OnClose(conn lokas.IConn)

func (*ProxySession) OnCreate added in v0.1.26 

func (this *ProxySession) OnCreate() error

func (*ProxySession) OnDestroy added in v0.1.26 

func (this *ProxySession) OnDestroy() error

func (*ProxySession) OnOpen added in v0.1.26 

func (this *ProxySession) OnOpen(conn lokas.IConn)

func (*ProxySession) OnRecv added in v0.1.26 

func (this *ProxySession) OnRecv(conn lokas.IConn, data []byte)

func (*ProxySession) SendMessage added in v0.1.26 

func (this *ProxySession) SendMessage(actorId util.ID, transId uint32, msg protocol.ISerializable) error

func (*ProxySession) SetProcess added in v0.1.26 

func (this *ProxySession) SetProcess(process lokas.IProcess)

func (*ProxySession) Start added in v0.1.26 

func (this *ProxySession) Start() error

func (*ProxySession) Stop added in v0.1.26 

func (this *ProxySession) Stop() error

func (*ProxySession) Type added in v0.1.26 

func (this *ProxySession) Type() string

func (*ProxySession) Update added in v0.1.26 

func (this *ProxySession) Update(dt time.Duration, now time.Time)

func (*ProxySession) Write added in v0.1.26 

func (this *ProxySession) Write(data []byte) error

type ProxySessionManager added in v0.1.26 

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

func NewProxySessionManager added in v0.1.26 

func NewProxySessionManager(safeMode bool) *ProxySessionManager

func (*ProxySessionManager) AddSession added in v0.1.26 

func (this *ProxySessionManager) AddSession(id util.ID, session lokas.ISession)

func (*ProxySessionManager) Clear added in v0.1.26 

func (this *ProxySessionManager) Clear()

func (*ProxySessionManager) GetRoundSession added in v0.1.26 

func (this *ProxySessionManager) GetRoundSession() (lokas.ISession, bool)

func (*ProxySessionManager) GetSession added in v0.1.26 

func (this *ProxySessionManager) GetSession(id util.ID) lokas.ISession

func (*ProxySessionManager) GetSessionCount added in v0.1.26 

func (this *ProxySessionManager) GetSessionCount() int

func (*ProxySessionManager) Range added in v0.1.26 

func (this *ProxySessionManager) Range(f func(id util.ID, session lokas.ISession) bool)

func (*ProxySessionManager) RemoveSession added in v0.1.26 

func (this *ProxySessionManager) RemoveSession(id util.ID)

func (*ProxySessionManager) ResetSession added in v0.1.26 

func (this *ProxySessionManager) ResetSession(id util.ID, session lokas.ISession)

type RedisConfig 

type RedisConfig struct {
	Host     string `mapstructure:"host"`
	Port     string `mapstructure:"port"`
	Password string `mapstructure:"password"`
}

type Registry 

type Registry struct {
	LocalRegistry  *CommonRegistry //local actor&service registry
	GlobalRegistry *CommonRegistry //local actor&service registry
	// contains filtered or unexported fields
}

func NewRegistry 

func NewRegistry(process lokas.IProcess) *Registry

func (*Registry) GetActorIdsByTypeAndServerId 

func (this *Registry) GetActorIdsByTypeAndServerId(serverId int32, typ string) []util.ID

func (*Registry) GetLeaseId added in v0.1.25 

func (this *Registry) GetLeaseId() (clientv3.LeaseID, bool, error)

return leaseId,(bool)is registered,error

func (*Registry) GetProcess 

func (this *Registry) GetProcess() lokas.IProcess

func (*Registry) GetProcessIdByActor 

func (this *Registry) GetProcessIdByActor(actorId util.ID) (util.ProcessId, error)

func (*Registry) GetProcessInfo added in v0.1.25 

func (this *Registry) GetProcessInfo() string

func (*Registry) Load 

func (this *Registry) Load(conf lokas.IConfig) error

func (*Registry) OnCreate 

func (this *Registry) OnCreate() error

func (*Registry) OnDestroy 

func (this *Registry) OnDestroy() error

func (*Registry) OnStart 

func (this *Registry) OnStart() error

func (*Registry) OnStop 

func (this *Registry) OnStop() error

func (*Registry) QueryRemoteActorsByServer 

func (this *Registry) QueryRemoteActorsByServer(typ string, ServerId int32) []*Actor

func (*Registry) QueryRemoteActorsByType 

func (this *Registry) QueryRemoteActorsByType(typ string) []*Actor

func (*Registry) RegisterActorLocal 

func (this *Registry) RegisterActorLocal(actor lokas.IActor) error

func (*Registry) RegisterActorRemote 

func (this *Registry) RegisterActorRemote(actor lokas.IActor) error

func (*Registry) RegisterActors 

func (this *Registry) RegisterActors() error

func (*Registry) SetProcess 

func (this *Registry) SetProcess(process lokas.IProcess)

func (*Registry) Start 

func (this *Registry) Start() error

func (*Registry) Stop 

func (this *Registry) Stop() error

func (*Registry) Type 

func (this *Registry) Type() string

func (*Registry) Unload 

func (this *Registry) Unload() error

func (*Registry) UnregisterActorLocal 

func (this *Registry) UnregisterActorLocal(actor lokas.IActor) error

func (*Registry) UnregisterActorRemote 

func (this *Registry) UnregisterActorRemote(actor lokas.IActor) error

type Response added in v0.1.29 

type Response struct {
	OK bool
}

默认回复

func NewResponse added in v0.1.29 

func NewResponse(v bool) *Response

func (*Response) GetId added in v0.1.29 

func (this *Response) GetId() (protocol.BINARY_TAG, error)

func (*Response) Serializable added in v0.1.29 

func (this *Response) Serializable() protocol.ISerializable

type Router 

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

router读取配置表,同步服务器注册信息 路由信息到本机或调用Proxy建立连接

func NewRouter 

func NewRouter(process lokas.IProcess) *Router

func (*Router) GetProcess 

func (this *Router) GetProcess() lokas.IProcess

func (*Router) Load 

func (this *Router) Load(conf lokas.IConfig) error

func (*Router) OnStart 

func (this *Router) OnStart() error

func (*Router) OnStop 

func (this *Router) OnStop() error

func (*Router) RouteMsg 

func (this *Router) RouteMsg(msg *protocol.RouteMessage)

func (*Router) SetProcess 

func (this *Router) SetProcess(process lokas.IProcess)

func (*Router) Start 

func (this *Router) Start() error

func (*Router) Stop 

func (this *Router) Stop() error

func (*Router) Type 

func (this *Router) Type() string

func (*Router) Unload 

func (this *Router) Unload() error

type ServiceRegistry 

type ServiceRegistry struct {
	Id          protocol.BINARY_TAG
	ServiceType lokas.ServiceType
	GameId      string
	Version     string
	ServerId    uint32
	Weights     map[util.ID]int
	Ts          time.Time
}

type SessionOption 

type SessionOption func(*ProxySession)

func WithCloseFunc 

func WithCloseFunc(closeFunc func(conn lokas.IConn)) SessionOption

func WithMsgHandler added in v0.1.26 

func WithMsgHandler(msgHandler func(msg *protocol.BinaryMessage)) SessionOption

func WithOpenFunc 

func WithOpenFunc(closeFunc func(conn lokas.IConn)) SessionOption

type TcpClient added in v0.0.6 

type TcpClient struct {
	events.EventEmmiter
	*ActiveSession

	Closing  bool
	Opening  bool
	ConnType ConnType
	Protocol protocol.TYPE
	// contains filtered or unexported fields
}

func NewTcpClient added in v0.0.6 

func NewTcpClient() *TcpClient

func (*TcpClient) Call added in v0.0.6 

func (this *TcpClient) Call(transId uint32, req interface{}) (interface{}, error)

func (*TcpClient) ClearContext added in v0.0.6 

func (this *TcpClient) ClearContext(err error)

func (*TcpClient) Connect added in v0.0.6 

func (this *TcpClient) Connect(addr string) *promise.Promise

func (*TcpClient) Connected added in v0.0.6 

func (this *TcpClient) Connected() bool

func (*TcpClient) Disconnect added in v0.0.6 

func (this *TcpClient) Disconnect(b bool) *promise.Promise

func (*TcpClient) GetContext added in v0.0.8 

func (this *TcpClient) GetContext(transId uint32) lokas.IReqContext

func (*TcpClient) MessageHandler added in v0.0.6 

func (this *TcpClient) MessageHandler(msg *protocol.BinaryMessage)

func (*TcpClient) Off added in v0.0.6 

func (this *TcpClient) Off(cmdId uint16, listener events.Listener)

func (*TcpClient) OnClose added in v0.0.6 

func (this *TcpClient) OnClose(conn lokas.IConn)

func (*TcpClient) OnMessage added in v0.0.6 

func (this *TcpClient) OnMessage(cmdId protocol.BINARY_TAG, listeners ...events.Listener)

func (*TcpClient) OnOpen added in v0.0.6 

func (this *TcpClient) OnOpen(conn lokas.IConn)

func (*TcpClient) OnRecvCmd added in v0.0.6 

func (this *TcpClient) OnRecvCmd(cmdId protocol.BINARY_TAG, time time.Duration) *promise.Promise

func (*TcpClient) Request added in v0.0.6 

func (this *TcpClient) Request(req interface{}) *promise.Promise

func (*TcpClient) SendMessage added in v0.0.6 

func (this *TcpClient) SendMessage(transId uint32, msg interface{})

func (*TcpClient) SetMessageHandler added in v0.1.35 

func (this *TcpClient) SetMessageHandler(handler func(msg *protocol.BinaryMessage))

func (*TcpClient) SetProtocol added in v0.1.35 

func (this *TcpClient) SetProtocol(p protocol.TYPE)

type User 

type User struct {
	Id           util.ID `bson:"_id"`
	Role         uint32
	Avatars      map[string]util.ID
	AgentsParams map[string]string
	Token        string
	RefreshToken string
	UserName     string
	Password     string
}

func (*User) Deserialize added in v0.1.29 

func (this *User) Deserialize(a lokas.IProcess) error

func (*User) GetId added in v0.1.29 

func (this *User) GetId() util.ID

func (*User) GetServerInfo added in v0.1.29 

func (this *User) GetServerInfo(s string) (string, int32)

func (*User) HasAvatarById added in v0.1.29 

func (this *User) HasAvatarById(id util.ID) bool

func (*User) HasAvatarByServer added in v0.1.29 

func (this *User) HasAvatarByServer(gameId string, serverId int32) (bool, util.ID)

func (*User) Serialize added in v0.1.29 

func (this *User) Serialize(a lokas.IProcess) error

func (*User) SimpleUser added in v0.1.29 

func (this *User) SimpleUser() *User

type UserCreator 

type UserCreator func() interface{}

type WsClient added in v0.1.35 

type WsClient struct {
	events.EventEmmiter

	Closing    bool
	Opening    bool
	Protocol   protocol.TYPE
	MsgHandler func(msg *protocol.BinaryMessage)
	// contains filtered or unexported fields
}

func NewWsClient added in v0.1.35 

func NewWsClient() *WsClient

func (*WsClient) AsyncCall added in v0.1.35 

func (this *WsClient) AsyncCall(transId uint32, req interface{}) (interface{}, error)

func (*WsClient) Call added in v0.1.35 

func (this *WsClient) Call(transId uint32, req interface{}) (interface{}, error)

func (*WsClient) ClearContext added in v0.1.35 

func (this *WsClient) ClearContext()

func (*WsClient) Close added in v0.1.35 

func (this *WsClient) Close() *promise.Promise

func (*WsClient) Connect added in v0.1.35 

func (this *WsClient) Connect(addr string) *promise.Promise

func (*WsClient) Connected added in v0.1.35 

func (this *WsClient) Connected() bool

func (*WsClient) Disconnect added in v0.1.35 

func (this *WsClient) Disconnect(force bool) *promise.Promise

func (*WsClient) GetContext added in v0.1.35 

func (this *WsClient) GetContext(transId uint32) lokas.IReqContext

func (*WsClient) MessageHandler added in v0.1.35 

func (this *WsClient) MessageHandler(msg *protocol.BinaryMessage)

func (*WsClient) Off added in v0.1.35 

func (this *WsClient) Off(cmdId uint16, listener events.Listener)

func (*WsClient) OnClose added in v0.1.35 

func (this *WsClient) OnClose(conn *websocket.Conn)

func (*WsClient) OnMessage added in v0.1.35 

func (this *WsClient) OnMessage(cmdId protocol.BINARY_TAG, listeners ...events.Listener)

func (*WsClient) OnOpen added in v0.1.35 

func (this *WsClient) OnOpen(conn *websocket.Conn)

func (*WsClient) OnRecv added in v0.1.35 

func (this *WsClient) OnRecv(conn lokas.IConn, data []byte)

func (*WsClient) OnRecvCmd added in v0.1.35 

func (this *WsClient) OnRecvCmd(cmdId protocol.BINARY_TAG, time time.Duration) *promise.Promise

func (*WsClient) OnRecvMessage added in v0.1.35 

func (this *WsClient) OnRecvMessage(cmdId protocol.BINARY_TAG, transId uint32, msg interface{})

func (*WsClient) Open added in v0.1.35 

func (this *WsClient) Open() *promise.Promise

func (*WsClient) Request added in v0.1.35 

func (this *WsClient) Request(req interface{}) *promise.Promise

func (*WsClient) Run added in v0.1.35 

func (this *WsClient) Run()

func (*WsClient) SendMessage added in v0.1.35 

func (this *WsClient) SendMessage(transId uint32, msg interface{})

func (*WsClient) SetMessageHandler added in v0.1.35 

func (this *WsClient) SetMessageHandler(handler func(msg *protocol.BinaryMessage))

func (*WsClient) SetProtocol added in v0.1.35 

func (this *WsClient) SetProtocol(p protocol.TYPE)

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.