pomelo

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Feb 23, 2026 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ResponseFuncName = "response"
	PushFuncName     = "push"
	KickFuncName     = "kick"
	BroadcastName    = "broadcast"
)
View Source 
const (
	AgentInit    int32 = 0
	AgentWaitAck int32 = 1
	AgentWorking int32 = 2
	AgentClosed  int32 = 3
)
View Source 
const (
	DataHeartbeat  = "heartbeat"
	DataDict       = "dict"
	DataSerializer = "serializer"
)

Variables

This section is empty.

Functions

func BindSID 

func BindSID(agent *Agent)

func BuildSession 

func BuildSession(agent *Agent, msg *pmessage.Message) *cproto.Session

func ClusterLocalDataRoute 

func ClusterLocalDataRoute(agent *Agent, session *cproto.Session, route *pmessage.Route, msg *pmessage.Message, nodeID, targetPath string) error

func Count 

func Count() int

func DefaultDataRoute 

func DefaultDataRoute(agent *Agent, route *pmessage.Route, msg *pmessage.Message)

DefaultDataRoute 默认的消息路由

func ForeachAgent 

func ForeachAgent(fn func(a *Agent))

func GetSID 

func GetSID(uid int64) (cfacade.SID, bool)

func Kick 

func Kick(iActor cfacade.IActor, agentPath, sid string, reason any, closed bool)

根据sid找到agent，下发踢除消息给客户端

func KickUID 

func KickUID(iActor cfacade.IActor, agentPath string, uid cfacade.UID, reason any, closed bool)

func LocalDataRoute 

func LocalDataRoute(agent *Agent, session *cproto.Session, route *pmessage.Route, msg *pmessage.Message, targetPath string)

func Push 

func Push(iActor cfacade.IActor, agentPath, sid string, uid cfacade.UID, route string, v any)

根据sid或uid找到agent，推送消息给客户端

func PushWithSID 

func PushWithSID(iActor cfacade.IActor, agentPath, sid, route string, v any)

根据sid找到agent，推送消息给客户端

func PushWithUID 

func PushWithUID(iActor cfacade.IActor, agentPath string, uid cfacade.UID, route string, v any)

根据uid找到agent，推送消息给客户端

func PushWithUIDS 

func PushWithUIDS(iActor cfacade.IActor, agentPath string, uidList []int64, allUID bool, route string, v any)

根据uidList或allUID匹配找到Agent，下发数据给客户端

func Response 

func Response(iActor cfacade.IActor, agentPath, sid string, mid uint32, v any)

根据request的mid找到agent，返回消息给客户端

func ResponseCode 

func ResponseCode(iActor cfacade.IActor, agentPath, sid string, mid uint32, statusCode int32)

根据request的mid找到agent，返回消息给客户端

func Unbind 

func Unbind(sid cfacade.SID)

Types

type Actor 

type Actor struct {
	cactor.Base
	// contains filtered or unexported fields
}

func NewActor 

func NewActor(agentActorID string) *Actor

func (*Actor) AddConnector 

func (p *Actor) AddConnector(connector cfacade.IConnector)

func (*Actor) Connectors 

func (p *Actor) Connectors() []cfacade.IConnector

func (*Actor) Load 

func (p *Actor) Load(app cfacade.IApplication)

func (*Actor) OnInit 

func (p *Actor) OnInit()

OnInit Actor初始化前触发该函数

func (*Actor) SetDataCompression 

func (*Actor) SetDataCompression(compression bool)

func (*Actor) SetDictionary 

func (*Actor) SetDictionary(dict map[string]uint16)

func (*Actor) SetHeartbeat 

func (*Actor) SetHeartbeat(t time.Duration)

func (*Actor) SetOnDataRoute 

func (*Actor) SetOnDataRoute(fn DataRouteFunc)

func (*Actor) SetOnInitFunc 

func (p *Actor) SetOnInitFunc(fn func())

func (*Actor) SetOnNewAgent 

func (p *Actor) SetOnNewAgent(fn OnNewAgentFunc)

func (*Actor) SetOnPacket 

func (*Actor) SetOnPacket(typ ppacket.Type, fn PacketFunc)

func (*Actor) SetSysData 

func (*Actor) SetSysData(key string, value interface{})

func (*Actor) SetWriteBacklog 

func (*Actor) SetWriteBacklog(size int)

type ActorBase 

type ActorBase struct {
	cactor.Base
}

func (*ActorBase) Kick 

func (p *ActorBase) Kick(session *cproto.Session, reason any, closed bool)

func (*ActorBase) Push 

func (p *ActorBase) Push(session *cproto.Session, route string, v any)

func (*ActorBase) PushWithUIDS 

func (p *ActorBase) PushWithUIDS(agentPath string, uidList []int64, allUID bool, route string, v interface{})

func (*ActorBase) Response 

func (p *ActorBase) Response(session *cproto.Session, v any)

func (*ActorBase) ResponseCode 

func (p *ActorBase) ResponseCode(session *cproto.Session, statusCode int32)

type Agent 

type Agent struct {
	cfacade.IApplication // app
	// contains filtered or unexported fields
}

func Bind 

func Bind(sid cfacade.SID, uid cfacade.UID) (*Agent, error)

func GetAgent 

func GetAgent(sid string, uid cfacade.UID) (*Agent, bool)

func GetAgentWithSID 

func GetAgentWithSID(sid cfacade.SID) (*Agent, bool)

func GetAgentWithSIDAndDel 

func GetAgentWithSIDAndDel(sid cfacade.SID, isDel bool) (*Agent, bool)

func GetAgentWithUID 

func GetAgentWithUID(uid cfacade.UID) (*Agent, bool)

func NewAgent 

func NewAgent(app cfacade.IApplication, conn net.Conn, session *cproto.Session) Agent

func (*Agent) AddOnClose 

func (a *Agent) AddOnClose(fn OnCloseFunc)

func (*Agent) Bind 

func (a *Agent) Bind(uid cfacade.UID) (*Agent, error)

func (*Agent) Close 

func (a *Agent) Close()

func (*Agent) IsBind 

func (a *Agent) IsBind() bool

func (*Agent) Kick 

func (a *Agent) Kick(reason interface{}, closed bool)

func (*Agent) Push 

func (a *Agent) Push(route string, val interface{})

func (*Agent) RemoteAddr 

func (a *Agent) RemoteAddr() string

func (*Agent) Response 

func (a *Agent) Response(session *cproto.Session, v interface{}, isError ...bool)

func (*Agent) ResponseCode 

func (a *Agent) ResponseCode(session *cproto.Session, statusCode int32, isError ...bool)

func (*Agent) ResponseMID 

func (a *Agent) ResponseMID(mid uint32, v interface{}, isError ...bool)

func (*Agent) Run 

func (a *Agent) Run()

func (*Agent) SID 

func (a *Agent) SID() cfacade.SID

func (*Agent) SendPacket 

func (a *Agent) SendPacket(typ pomeloPacket.Type, data []byte)

func (*Agent) SendRaw 

func (a *Agent) SendRaw(bytes []byte)

func (*Agent) Session 

func (a *Agent) Session() *cproto.Session

func (*Agent) SetLastAt 

func (a *Agent) SetLastAt()

func (*Agent) SetState 

func (a *Agent) SetState(state int32) bool

func (*Agent) State 

func (a *Agent) State() int32

func (*Agent) UID 

func (a *Agent) UID() cfacade.UID

func (*Agent) Unbind 

func (a *Agent) Unbind()

type Command 

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

type DataRouteFunc 

type DataRouteFunc func(agent *Agent, route *pmessage.Route, msg *pmessage.Message)

type OnCloseFunc 

type OnCloseFunc func(*Agent)

type OnNewAgentFunc 

type OnNewAgentFunc func(newAgent *Agent)

type PacketFunc 

type PacketFunc func(agent *Agent, packet *ppacket.Packet)

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.