gateway

package

v0.0.0-...-4d53ac5 Latest Latest Go to latest Published: Mar 24, 2025 License: MIT Imports: 24 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/75912001/xcore

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func EtcdKeyValue(arg ...interface{}) error
func UserHeartbeatMsg(args ...interface{}) error
func UserOnlineMsg(args ...interface{}) error
type LoginService
- func NewLoginService() *LoginService
type LoginServiceMgr
- func NewLoginServiceMgr() *LoginServiceMgr
type Server
- func NewSerer(defaultServer *xserver.Server) *Server
type User
type UserConnect

Constants ¶

View Source

const UserHeartbeatInterval int64 = 20 // 用户心跳时间间隔-秒

View Source

const UserHeartbeatIntervalMax int64 = UserHeartbeatInterval * 2 // 用户心跳时间间隔-最大-秒

View Source

const UserInactiveTimeout int64 = xtime.OneDaySecond // 用户非活跃时间-秒

View Source

const UserLoginTimeout int64 = xtime.OneDaySecond // 用户登录超时时间-秒

Variables ¶

View Source

var GMessage message.Mgr

Functions ¶

func EtcdKeyValue ¶

func EtcdKeyValue(arg ...interface{}) error

EtcdKeyValue etcd 刷新 key value

func UserHeartbeatMsg ¶

func UserHeartbeatMsg(args ...interface{}) error

func UserOnlineMsg ¶

func UserOnlineMsg(args ...interface{}) error

Types ¶

type LoginService ¶

type LoginService struct {
	*xnettcp.Client
}

func NewLoginService ¶

func NewLoginService() *LoginService

func (*LoginService) OnCheckPacketLength ¶

func (p *LoginService) OnCheckPacketLength(length uint32) error

func (*LoginService) OnCheckPacketLimit ¶

func (p *LoginService) OnCheckPacketLimit(remote xcommon.IRemote) error

func (*LoginService) OnConnect ¶

func (p *LoginService) OnConnect(remote xcommon.IRemote) error

func (*LoginService) OnDisconnect ¶

func (p *LoginService) OnDisconnect(remote xcommon.IRemote) error

func (*LoginService) OnPacket ¶

func (p *LoginService) OnPacket(remote xcommon.IRemote, packet packet2.IPacket) error

func (*LoginService) OnUnmarshalPacket ¶

func (p *LoginService) OnUnmarshalPacket(remote xcommon.IRemote, data []byte) (packet2.IPacket, error)

type LoginServiceMgr ¶

type LoginServiceMgr struct {
	LoginService map[uint32]*LoginService // key: loginId
}

func NewLoginServiceMgr ¶

func NewLoginServiceMgr() *LoginServiceMgr

func (*LoginServiceMgr) Add ¶

func (p *LoginServiceMgr) Add(loginId uint32, loginService *LoginService)

func (*LoginServiceMgr) Get ¶

func (p *LoginServiceMgr) Get(loginId uint32) *LoginService

func (*LoginServiceMgr) GetLoginService ¶

func (p *LoginServiceMgr) GetLoginService() *LoginService

GetLoginService 按照策略获取一个LoginService

func (*LoginServiceMgr) Remove ¶

func (p *LoginServiceMgr) Remove(loginId uint32)

type Server ¶

type Server struct {
	*xserver.Server
	LoginServiceMgr *LoginServiceMgr
}

func NewSerer ¶

func NewSerer(defaultServer *xserver.Server) *Server

func (*Server) OnCheckPacketLength ¶

func (p *Server) OnCheckPacketLength(length uint32) error

func (*Server) OnCheckPacketLimit ¶

func (p *Server) OnCheckPacketLimit(remote common.IRemote) error

func (*Server) OnConnect ¶

func (p *Server) OnConnect(remote common.IRemote) error

func (*Server) OnDisconnect ¶

func (p *Server) OnDisconnect(remote common.IRemote) error

func (*Server) OnPacket ¶

func (p *Server) OnPacket(remote common.IRemote, packet packet2.IPacket) error

func (*Server) OnUnmarshalPacket ¶

func (p *Server) OnUnmarshalPacket(remote common.IRemote, data []byte) (packet2.IPacket, error)

func (*Server) PreStop ¶

func (p *Server) PreStop() error

func (*Server) Start ¶

func (p *Server) Start(ctx context.Context) (err error)

func (*Server) Stop ¶

func (p *Server) Stop() (err error)

type User ¶

type User struct {
	LoginService *LoginService
	// contains filtered or unexported fields
}

type UserConnect ¶

type UserConnect struct {
	IRemote         xnetconnect.IRemote
	ExpireTimestamp int64 // 到期时间戳-灰度

	Status *xnetconnect.Status
	// contains filtered or unexported fields
}

UserConnect 用户-链接

Source Files ¶

View all Source files

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