cluster

Documentation

Index

• func WithRemote(ectd_addr, prefix string) actor.SystemOption
• type Cluster
  • 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) OnStop() (immediatelyStop 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) 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) OnStop

func (c *Cluster) OnStop() (immediatelyStop bool)

type IRemoteProvider

type IRemoteProvider interface {
	Start(actorSystem *actor.System) error
	Stop()
	NewClient(host string)
	StopClient(host string)

	Send(addr string, sourceId, targetId, requestId string, actMsg proto.Message) error
}

type IServiceMeshProvider

type IServiceMeshProvider interface {
	Start(actorSystem *actor.System) error
	Stop()
	RegistService(key string, value string) error
}