rpc

Documentation

Index

• type Config
• type Manager
  • func NewManagerWithConfig(config *Config) *Manager
  • func (m *Manager) GetCluster() *cluster.Cluster
  • func (m *Manager) OnDestroy()
  • func (m *Manager) Start(actorSystem *actor.ActorSystem) (cls *cluster.Cluster)

Types

type Config

type Config struct {
	ClusterName  string                 // 集群名称
	Consul       string                 // 服务发现注册地址
	ServiceKind  []*cluster.Kind        // 使用proto actor grain生成的服务类型
	EventHandler func(any)              // event处理
	Options      []cluster.ConfigOption // 集群设置
}

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManagerWithConfig

func NewManagerWithConfig(config *Config) *Manager

func (*Manager) GetCluster

func (m *Manager) GetCluster() *cluster.Cluster

func (*Manager) OnDestroy

func (m *Manager) OnDestroy()

func (*Manager) Start

func (m *Manager) Start(actorSystem *actor.ActorSystem) (cls *cluster.Cluster)