pomelo

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2023 License: MIT Imports: 23 Imported by: 7

Documentation

Index

Constants

View Source 
const (
	ResponseFuncName = "response"
	PushFuncName     = "push"
	KickFuncName     = "kick"
)
View Source 
const (
	AgentInit    int32 = 0
	AgentWaitAck int32 = 1
	AgentWorking int32 = 2
	AgentClosed  int32 = 3
)

Variables

This section is empty.

Functions

func BindSID 

func BindSID(agent *Agent)

func BindUID 

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

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)

func Count 

func Count() int

func DefaultDataRoute 

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

func ForeachAgent 

func ForeachAgent(fn func(a *Agent))

func GetRandMember 

func GetRandMember(agent *Agent, route *pmessage.Route) (cfacade.IMember, bool)

func LocalDataRoute 

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

func LocalInvokeFunc 

func LocalInvokeFunc(app cfacade.IApplication, fi *creflect.FuncInfo, m *cfacade.Message)

func PublishClusterLocal 

func PublishClusterLocal(agent *Agent, nodeId string, clusterPacket *cproto.ClusterPacket)

func RemoteInvokeFunc 

func RemoteInvokeFunc(app cfacade.IApplication, fi *creflect.FuncInfo, m *cfacade.Message)

func Unbind 

func Unbind(sid cfacade.SID)

Types

type ActorBase 

type ActorBase struct {
	cactor.Base
}

func (*ActorBase) Kick 

func (p *ActorBase) Kick(session *cproto.Session, reason interface{}, close 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 {
	// 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) App 

func (a *Agent) App() cfacade.IApplication

func (*Agent) Bind 

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

func (*Agent) Close 

func (a *Agent) Close()

func (*Agent) Kick 

func (a *Agent) Kick(reason interface{}, close 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) 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 AgentActor 

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

func NewActor 

func NewActor(agentActorID string) *AgentActor

func (*AgentActor) AddConnector 

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

func (*AgentActor) Load 

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

func (*AgentActor) OnInit 

func (p *AgentActor) OnInit()

OnInit Actor初始化前触发该函数

func (*AgentActor) SetDataCompression 

func (*AgentActor) SetDataCompression(compression bool)

func (*AgentActor) SetDictionary 

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

func (*AgentActor) SetHeartbeat 

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

func (*AgentActor) SetOnDataRoute 

func (*AgentActor) SetOnDataRoute(fn DataRouteFunc)

func (*AgentActor) SetOnNewAgent 

func (p *AgentActor) SetOnNewAgent(fn OnNewAgentFunc)

func (*AgentActor) SetOnPacket 

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

func (*AgentActor) SetSysData 

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

func (*AgentActor) SetWriteBacklog 

func (*AgentActor) SetWriteBacklog(size int)

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.