simple

Mar 19, 2025

Changes in this version

type Agent

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

Jun 6, 2023

Changes in this version

+ const AgentClosed

+ const AgentInit

+ const ResponseFuncName

+ var NoneMessage = Message

+ func AddNodeRoute(mid uint32, nodeRoute *NodeRoute)

+ func BindSID(agent *Agent)

+ func BindUID(sid cfacade.SID, uid cfacade.UID) error

+ func ClusterLocalDataRoute(agent *Agent, session *cproto.Session, msg *Message, nodeRoute *NodeRoute, ...) error

+ func Count() int

+ func DefaultDataRoute(agent *Agent, msg *Message, route *NodeRoute)

+ func ForeachAgent(fn func(a *Agent))

+ func LocalDataRoute(agent *Agent, session *cproto.Session, msg *Message, nodeRoute *NodeRoute, ...)

+ func NewActor(agentActorID string) *actor

+ func Response(actor cfacade.IActor, session *cproto.Session, mid uint32, v interface{})

+ func SetEndian(e binary.ByteOrder)

+ func SetHeartbeatTime(t time.Duration)

+ func SetWriteBacklog(backlog int)

+ func Unbind(sid cfacade.SID)

+ type ActorBase struct

+ func (p *ActorBase) Response(session *cproto.Session, mid uint32, v interface{})

+ type Agent struct

+ func GetAgent(sid cfacade.SID) (*Agent, bool)

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

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

+ func (a *Agent) AddOnClose(fn OnCloseFunc)

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

+ func (a *Agent) Close()

+ func (a *Agent) RemoteAddr() string

+ func (a *Agent) Response(mid uint32, v interface{})

+ func (a *Agent) Run()

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

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

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

+ func (a *Agent) SetLastAt()

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

+ func (a *Agent) State() int32

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

+ func (a *Agent) Unbind()

+ type DataRouteFunc func(agent *Agent, msg *Message, route *NodeRoute)

+ type Message struct

+ Data []byte

+ Len uint32

+ MID uint32

+ func ReadMessage(conn net.Conn) (Message, bool, error)

+ type NodeRoute struct

+ ActorID string

+ FuncName string

+ NodeType string

+ func GetNodeRoute(mid uint32) (*NodeRoute, bool)

+ type OnCloseFunc func(*Agent)

+ type OnNewAgentFunc func(newAgent *Agent)