fullmesh

Documentation

Index

• func WithRemote(etcdAddr, prefix string) actor.SystemOption
• type Cluster
  • func (c *Cluster) OnEventClusterUpdate(event internal.EvClusterUpdate)
  • func (c *Cluster) OnEventDelActor(ev event.EvDelActor)
  • func (c *Cluster) OnEventNewActor(event internal.EvNewLocalActor)
  • func (c *Cluster) OnEventSessionClosed(ev internal.EvSessionClosed)
  • func (c *Cluster) OnEventSessionOpened(ev internal.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 *innermsg.ActorMessage)
  • func (c *Cluster) OnStop() bool
• type RemoteProvider
• type ServiceMeshProvider

Functions

func WithRemote

func WithRemote(etcdAddr, prefix string) actor.SystemOption

Types

type Cluster

type Cluster struct {
	actor.Base
	RandAddr chan<- string
	// contains filtered or unexported fields
}

func (*Cluster) OnEventClusterUpdate

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

func (*Cluster) OnEventDelActor

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

func (*Cluster) OnEventNewActor

func (c *Cluster) OnEventNewActor(event internal.EvNewLocalActor)

func (*Cluster) OnEventSessionClosed

func (c *Cluster) OnEventSessionClosed(ev internal.EvSessionClosed)

func (*Cluster) OnEventSessionOpened

func (c *Cluster) OnEventSessionOpened(ev internal.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 node

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 *innermsg.ActorMessage)

func (*Cluster) OnStop

func (c *Cluster) OnStop() bool

type RemoteProvider

type RemoteProvider interface {
	Start(remote.Handler) error
	Addr() string
	Stop()
	NewClient(host string)
	StopClient(host string)

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

type ServiceMeshProvider

type ServiceMeshProvider interface {
	Start(servmesh.MeshHandler) error
	Stop()
	RegisterService(key string, value string) error
	UnregisterService(key string) error
	Get(key string) (val string, err error)
}