pomelo

Documentation

Index

• Constants
• func BindSID(agent *Agent)
• func BindUID(sid cfacade.SID, uid cfacade.UID) error
• func Broadcast(iActor cfacade.IActor, agentPath string, uidList []int64, allUID bool, ...)
• func BuildSession(agent *Agent, msg *pmessage.Message) *cproto.Session
• func ClusterLocalDataRoute(agent *Agent, session *cproto.Session, route *pmessage.Route, ...) error
• func Count() int
• func DefaultDataRoute(agent *Agent, route *pmessage.Route, msg *pmessage.Message)
• func ForeachAgent(fn func(a *Agent))
• func Kick(iActor cfacade.IActor, agentPath, sid string, reason interface{}, closed bool)
• func LocalDataRoute(agent *Agent, session *cproto.Session, route *pmessage.Route, ...)
• func NewActor(agentActorID string) *actor
• func Push(iActor cfacade.IActor, agentPath, sid, route string, v interface{})
• func Response(iActor cfacade.IActor, agentPath, sid string, mid uint32, v interface{})
• func ResponseCode(iActor cfacade.IActor, agentPath, sid string, mid uint32, statusCode int32)
• func Unbind(sid cfacade.SID)
• type ActorBase
  • func (p *ActorBase) Broadcast(agentPath string, uidList []int64, allUID bool, route string, v interface{})
  • func (p *ActorBase) Kick(session *cproto.Session, reason interface{}, closed bool)
  • func (p *ActorBase) Push(session *cproto.Session, route string, v interface{})
  • func (p *ActorBase) Response(session *cproto.Session, v interface{})
  • func (p *ActorBase) ResponseCode(session *cproto.Session, statusCode int32)
• type Agent
  • 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) IsBind() bool
  • func (a *Agent) Kick(reason interface{}, closed bool)
  • func (a *Agent) Push(route string, val interface{})
  • func (a *Agent) RemoteAddr() string
  • func (a *Agent) Response(session *cproto.Session, v interface{}, isError ...bool)
  • func (a *Agent) ResponseCode(session *cproto.Session, statusCode int32, isError ...bool)
  • func (a *Agent) ResponseMID(mid uint32, v interface{}, isError ...bool)
  • func (a *Agent) Run()
  • func (a *Agent) SID() cfacade.SID
  • func (a *Agent) SendPacket(typ pomeloPacket.Type, data []byte)
  • 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 Command
• type DataRouteFunc
• type OnCloseFunc
• type OnNewAgentFunc
• type PacketFunc

Constants

const (
	ResponseFuncName = "response"
	PushFuncName     = "push"
	KickFuncName     = "kick"
	BroadcastName    = "broadcast"
)

const (
	AgentInit    int32 = 0
	AgentWaitAck int32 = 1
	AgentWorking int32 = 2
	AgentClosed  int32 = 3
)

const (
	DataHeartbeat  = "heartbeat"
	DataDict       = "dict"
	DataSerializer = "serializer"
)

Functions

func BindSID

func BindSID(agent *Agent)

func BindUID

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

func Broadcast

func Broadcast(iActor cfacade.IActor, agentPath string, uidList []int64, allUID bool, route string, v interface{})

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 Kick

func Kick(iActor cfacade.IActor, agentPath, sid string, reason interface{}, closed bool)

func LocalDataRoute

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

func NewActor

func NewActor(agentActorID string) *actor

func Push

func Push(iActor cfacade.IActor, agentPath, sid, route string, v interface{})

func Response

func Response(iActor cfacade.IActor, agentPath, sid string, mid uint32, v interface{})

func ResponseCode

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

func Unbind

func Unbind(sid cfacade.SID)

Types

type ActorBase

type ActorBase struct {
	cactor.Base
}

func (*ActorBase) Broadcast

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

func (*ActorBase) Kick

func (p *ActorBase) Kick(session *cproto.Session, reason interface{}, closed bool)

func (*ActorBase) Push

func (p *ActorBase) Push(session *cproto.Session, route string, v interface{})

func (*ActorBase) Response

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

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 GetAgent

func GetAgent(sid cfacade.SID) (*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) 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)