fullmesh

Documentation

Index

• func WithRemote(ectdAddr, prefix string) actor.SystemOption
• type Cluster
  • func (c *Cluster) Address() string
  • func (c *Cluster) OnEventClusterUpdate(event actor.EvClusterUpdate)
  • func (c *Cluster) OnEventDelActor(event actor.EvDelActor)
  • func (c *Cluster) OnEventNewActor(event actor.EvNewActor)
  • func (c *Cluster) OnEventSessionClosed(event actor.EvSessionClosed)
  • func (c *Cluster) OnEventSessionOpened(event actor.EvSessionOpened)
  • func (c *Cluster) OnHandle(msg actor.Message)
  • 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 RemoteProvider
• type ServiceMeshProvider

Functions

func WithRemote

func WithRemote(ectdAddr, 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) OnEventClusterUpdate

func (c *Cluster) OnEventClusterUpdate(event actor.EvClusterUpdate)

func (*Cluster) OnEventDelActor

func (c *Cluster) OnEventDelActor(event actor.EvDelActor)

func (*Cluster) OnEventNewActor

func (c *Cluster) OnEventNewActor(event actor.EvNewActor)

func (*Cluster) OnEventSessionClosed

func (c *Cluster) OnEventSessionClosed(event actor.EvSessionClosed)

func (*Cluster) OnEventSessionOpened

func (c *Cluster) OnEventSessionOpened(event actor.EvSessionOpened)

func (*Cluster) OnHandle

func (c *Cluster) OnHandle(msg actor.Message)

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 RemoteProvider

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

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

type ServiceMeshProvider

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