cluster

Documentation

Index

• func WithRemote(ectd_addr, prefix string) actor.SystemOption
• type Cluster
  • func (c *Cluster) Address() string
  • func (c *Cluster) OnHandleEvent(event interface{})
  • func (c *Cluster) OnHandleMessage(sourceId, targetId string, msg interface{})
  • func (c *Cluster) OnHandleRequest(sourceId, targetId, requestId string, msg interface{}) (respErr error)
  • func (c *Cluster) OnInit()
  • func (c *Cluster) OnNewServ(actorId, host string, add bool)
  • func (c *Cluster) OnSessionClosed(peerHost string)
  • func (c *Cluster) OnSessionOpened(peerHost string)
  • func (c *Cluster) OnSessionRecv(msg *actor_msg.ActorMessage)
  • func (c *Cluster) OnStop() bool
• type IRemoteProvider
• type IServiceMeshProvider

Functions

func WithRemote

func WithRemote(ectd_addr, prefix string) actor.SystemOption

Types

type Cluster

type Cluster struct {
	actor.Base
	// contains filtered or unexported fields
}

func (*Cluster) Address

func (c *Cluster) Address() string

func (*Cluster) OnHandleEvent

func (c *Cluster) OnHandleEvent(event interface{})

func (*Cluster) OnHandleMessage

func (c *Cluster) OnHandleMessage(sourceId, targetId string, msg interface{})

func (*Cluster) OnHandleRequest

func (c *Cluster) OnHandleRequest(sourceId, targetId, requestId string, msg interface{}) (respErr error)

func (*Cluster) OnInit

func (c *Cluster) OnInit()

func (*Cluster) OnNewServ

func (c *Cluster) OnNewServ(actorId, host string, add bool)

OnNewServ dispatch a new remote

func (*Cluster) OnSessionClosed

func (c *Cluster) OnSessionClosed(peerHost string)

func (*Cluster) OnSessionOpened

func (c *Cluster) OnSessionOpened(peerHost string)

func (*Cluster) OnSessionRecv

func (c *Cluster) OnSessionRecv(msg *actor_msg.ActorMessage)

func (*Cluster) OnStop

func (c *Cluster) OnStop() bool

type IRemoteProvider

type IRemoteProvider interface {
	Start(remote_provider.RemoteHandler) error
	Stop()
	NewClient(host string)
	StopClient(host string)

	SendMsg(addr string, bytes []byte) error
}

type IServiceMeshProvider

type IServiceMeshProvider interface {
	Start(servmesh_provider.ServMeshHander) error
	Stop()
	RegisterService(key string, value string) error
	UnregisterService(key string) error
}