Documentation
¶
Index ¶
- func CreateUser(openId string, socketUrl string, logHandler func(format string, a ...any), ...) user_data.User
- type CmdAction
- type RpcTimeout
- type User
- func (u *User) AddOnClosedHandler(f func(user user_data.User))
- func (user *User) AllocSequence() uint64
- func (user *User) AwaitReceiveHandlerClose()
- func (user *User) Close()
- func (user *User) GetAccessToken() string
- func (user *User) GetExtralData(key string) any
- func (user *User) GetLoginCode() string
- func (user *User) GetLogined() bool
- func (user *User) GetOpenId() string
- func (user *User) GetUserId() uint64
- func (user *User) GetZoneId() uint32
- func (user *User) InitHeartbeatFunc(f func(user_data.User) error)
- func (u *User) IsLogin() bool
- func (user *User) Log(format string, a ...any)
- func (u *User) Logout()
- func (user *User) ReceiveHandler(unpack user_data.UserReceiveUnpackFunc, ...)
- func (user *User) RegisterMessageHandler(rpcName string, f func(*user_data.TaskActionUser, proto.Message, int32) error)
- func (u *User) ReleaseActionGuard()
- func (user *User) RunTask(timeout time.Duration, f func(*user_data.TaskActionUser) error, name string) *user_data.TaskActionUser
- func (user *User) RunTaskDefaultTimeout(f func(*user_data.TaskActionUser) error, name string) *user_data.TaskActionUser
- func (user *User) SendReq(action *user_data.TaskActionUser, csMsg proto.Message, csHead proto.Message, ...) (int32, proto.Message, error)
- func (user *User) SetExtralData(key string, value any)
- func (user *User) SetHasGetInfo(d bool)
- func (user *User) SetHeartbeatInterval(d time.Duration)
- func (user *User) SetLastPingTime(d time.Time)
- func (user *User) SetLoginCode(d string)
- func (user *User) SetLogined(d bool)
- func (user *User) SetUserId(d uint64)
- func (user *User) SetZoneId(d uint32)
- func (u *User) TakeActionGuard()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateUser ¶
Types ¶
type RpcTimeout ¶
type RpcTimeout struct {
// contains filtered or unexported fields
}
type User ¶
type User struct {
OpenId string
UserId uint64
ZoneId uint32
AccessToken string
LoginCode string
Logined bool
HasGetInfo bool
HeartbeatInterval time.Duration
LastPingTime time.Time
Closed atomic.Bool
// contains filtered or unexported fields
}
func (*User) AddOnClosedHandler ¶
func (*User) AllocSequence ¶
func (*User) AwaitReceiveHandlerClose ¶
func (user *User) AwaitReceiveHandlerClose()
func (*User) GetAccessToken ¶
func (*User) GetExtralData ¶
func (*User) GetLoginCode ¶
func (*User) GetLogined ¶
func (*User) ReceiveHandler ¶
func (user *User) ReceiveHandler(unpack user_data.UserReceiveUnpackFunc, createMsg user_data.UserReceiveCreateMessageFunc)
func (*User) RegisterMessageHandler ¶
func (*User) ReleaseActionGuard ¶
func (u *User) ReleaseActionGuard()
func (*User) RunTask ¶
func (user *User) RunTask(timeout time.Duration, f func(*user_data.TaskActionUser) error, name string) *user_data.TaskActionUser
func (*User) RunTaskDefaultTimeout ¶
func (user *User) RunTaskDefaultTimeout(f func(*user_data.TaskActionUser) error, name string) *user_data.TaskActionUser
func (*User) SetExtralData ¶
func (*User) SetHasGetInfo ¶
func (*User) SetHeartbeatInterval ¶
func (*User) SetLastPingTime ¶
func (*User) SetLoginCode ¶
func (*User) SetLogined ¶
func (*User) TakeActionGuard ¶
func (u *User) TakeActionGuard()
Click to show internal directories.
Click to hide internal directories.