user_agent_module

package
v0.0.0-...-bd0de05 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const AGENT_CHANNEL_USER_MAX = 80

每条消息通道驻扎玩家的最大数量

View Source 
const MSG_CHAN_SIZE = 40960

Variables

This section is empty.

Functions

func BroadCastToPlayer 

func BroadCastToPlayer(
	userId int64, msgType proto.EnvelopeType, msg googleProto.Message,
) error

func MultiBroadCastToClient 

func MultiBroadCastToClient(
	userIds []int64, msgType proto.EnvelopeType, msg googleProto.Message,
) error

Types

type AgentSendChannel 

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

func NewAgentSendChannel 

func NewAgentSendChannel(agentAppId string) *AgentSendChannel

func (*AgentSendChannel) AddUserAgentData 

func (p *AgentSendChannel) AddUserAgentData(data *UserAgentData)

func (*AgentSendChannel) GetAgentAppId 

func (p *AgentSendChannel) GetAgentAppId() string

func (*AgentSendChannel) GetId 

func (p *AgentSendChannel) GetId() int64

func (*AgentSendChannel) GetUserAgentData 

func (p *AgentSendChannel) GetUserAgentData(userId int64) (data *UserAgentData, exist bool)

func (*AgentSendChannel) RemoveUserAgentData 

func (p *AgentSendChannel) RemoveUserAgentData(userId int64)

func (*AgentSendChannel) SendMessage 

func (p *AgentSendChannel) SendMessage(msgData *ClientMsgData)

func (*AgentSendChannel) Stop 

func (p *AgentSendChannel) Stop()

func (*AgentSendChannel) UserCount 

func (p *AgentSendChannel) UserCount() int

type ClientMsgData 

type ClientMsgData struct {
	MultiMsg       bool
	MultiUserIds   []int64
	UserId         int64
	UserAgentAppId string
	UserSocketId   string
	MsgType        proto.EnvelopeType
	Msg            googleProto.Message
}

type ClientMsgDataPool 

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

func (*ClientMsgDataPool) Get 

func (p *ClientMsgDataPool) Get() *ClientMsgData

func (*ClientMsgDataPool) Init 

func (p *ClientMsgDataPool) Init()

func (*ClientMsgDataPool) MakeClientMsgData 

func (p *ClientMsgDataPool) MakeClientMsgData(
	isMultiMsg bool, userId int64,
	agentAppId, socketId string,
	multiUserIds []int64,
	msgType proto.EnvelopeType,
	msg googleProto.Message,
) *ClientMsgData

func (*ClientMsgDataPool) Put 

func (p *ClientMsgDataPool) Put(msg *ClientMsgData)

type UserAgent 

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

func NewUserAgent 

func NewUserAgent(agentAppId string) *UserAgent

func (*UserAgent) AddUserAgentData 

func (p *UserAgent) AddUserAgentData(data *UserAgentData)

func (*UserAgent) GetFreeAgentChannel 

func (p *UserAgent) GetFreeAgentChannel() (freeAgentChan *AgentSendChannel)

func (*UserAgent) GetId 

func (p *UserAgent) GetId() string

func (*UserAgent) GetUserAgentData 

func (p *UserAgent) GetUserAgentData(userId int64) (data *UserAgentData, exist bool)

func (*UserAgent) RemoveUserAgentData 

func (p *UserAgent) RemoveUserAgentData(userId int64)

func (*UserAgent) SendMessage 

func (p *UserAgent) SendMessage(msgData *ClientMsgData)

func (*UserAgent) Stop 

func (p *UserAgent) Stop()

func (*UserAgent) UserCount 

func (p *UserAgent) UserCount() int

type UserAgentData 

type UserAgentData struct {
	AgentAppId          string            `json:"agentAppId"`
	InSceneServiceAppId string            `json:"inSceneServiceAppId"`
	InMapId             int32             `json:"inMapId"`
	SocketId            string            `json:"socketId"`
	UserId              int64             `json:"userId"`
	LoginAt             int64             `json:"loginAt"`
	InUserAgent         *UserAgent        `json:"-"` // 记录位置
	InAgentChannel      *AgentSendChannel `json:"-"` // 记录位置
}

func NewUserAgentData 

func NewUserAgentData(
	userId int64, agentAppId, socketId, sceneAppId string,
) *UserAgentData

func (*UserAgentData) SendToPlayer 

func (p *UserAgentData) SendToPlayer(
	msgType proto.EnvelopeType, msg googleProto.Message,
) error

func (*UserAgentData) TryUpdate 

func (p *UserAgentData) TryUpdate(userId int64, agentAppId, socketId, sceneAppId string)

type UserAgentModel 

type UserAgentModel struct {
	module_base.ModuleBase
	// contains filtered or unexported fields
}

func GetUserAgentModel 

func GetUserAgentModel() *UserAgentModel

func NewUserAgentModel 

func NewUserAgentModel() *UserAgentModel

func (*UserAgentModel) AddUserAgentData 

func (p *UserAgentModel) AddUserAgentData(
	userId int64, agentAppId, socketId, sceneAppId string,
) (*UserAgentData, error)

func (*UserAgentModel) AllOnlineUserIds 

func (p *UserAgentModel) AllOnlineUserIds() []int64

func (*UserAgentModel) GetOrAddAgent 

func (p *UserAgentModel) GetOrAddAgent(agentAppId string) *UserAgent

func (*UserAgentModel) GetOrStoreUserAgentData 

func (p *UserAgentModel) GetOrStoreUserAgentData(
	userId int64, agentAppId, socketId, sceneAppId string,
) *UserAgentData

func (*UserAgentModel) GetUserAgentData 

func (p *UserAgentModel) GetUserAgentData(userId int64) (*UserAgentData, bool)

func (*UserAgentModel) OnInit 

func (p *UserAgentModel) OnInit() error

func (*UserAgentModel) OnStart 

func (p *UserAgentModel) OnStart() (err error)

func (*UserAgentModel) OnStop 

func (p *UserAgentModel) OnStop() error

func (*UserAgentModel) RemoveUserAgentData 

func (p *UserAgentModel) RemoveUserAgentData(userId int64, userSocketId string)

Source Files

View all Source files

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.