Documentation
¶
Index ¶
- Constants
- func Register(discovery cfacade.IDiscovery)
- type Component
- type DiscoveryDefault
- func (n *DiscoveryDefault) AddMember(member cfacade.IMember)
- func (n *DiscoveryDefault) GetMember(nodeID string) (cfacade.IMember, bool)
- func (n *DiscoveryDefault) GetType(nodeID string) (nodeType string, err error)
- func (n *DiscoveryDefault) ListByType(nodeType string, filterNodeID ...string) []cfacade.IMember
- func (n *DiscoveryDefault) Load(_ cfacade.IApplication)
- func (n *DiscoveryDefault) Map() map[string]cfacade.IMember
- func (n *DiscoveryDefault) Name() string
- func (n *DiscoveryDefault) OnAddMember(listener cfacade.MemberListener)
- func (n *DiscoveryDefault) OnRemoveMember(listener cfacade.MemberListener)
- func (n *DiscoveryDefault) PreInit()
- func (n *DiscoveryDefault) Random(nodeType string) (cfacade.IMember, bool)
- func (n *DiscoveryDefault) RemoveMember(nodeID string)
- func (n *DiscoveryDefault) Stop()
- type DiscoveryMaster
Constants ¶
View Source
const (
Name = "discovery_component"
)
Variables ¶
This section is empty.
Functions ¶
func Register ¶
func Register(discovery cfacade.IDiscovery)
Types ¶
type DiscoveryDefault ¶
type DiscoveryDefault struct {
// contains filtered or unexported fields
}
DiscoveryDefault 默认方式，通过读取profile文件的节点信息
该类型发现服务仅用于开发测试使用，直接读取profile.json->node配置
func (*DiscoveryDefault) AddMember ¶
func (n *DiscoveryDefault) AddMember(member cfacade.IMember)
func (*DiscoveryDefault) GetMember ¶
func (n *DiscoveryDefault) GetMember(nodeID string) (cfacade.IMember, bool)
func (*DiscoveryDefault) GetType ¶
func (n *DiscoveryDefault) GetType(nodeID string) (nodeType string, err error)
func (*DiscoveryDefault) ListByType ¶
func (n *DiscoveryDefault) ListByType(nodeType string, filterNodeID ...string) []cfacade.IMember
func (*DiscoveryDefault) Load ¶
func (n *DiscoveryDefault) Load(_ cfacade.IApplication)
func (*DiscoveryDefault) Name ¶
func (n *DiscoveryDefault) Name() string
func (*DiscoveryDefault) OnAddMember ¶
func (n *DiscoveryDefault) OnAddMember(listener cfacade.MemberListener)
func (*DiscoveryDefault) OnRemoveMember ¶
func (n *DiscoveryDefault) OnRemoveMember(listener cfacade.MemberListener)
func (*DiscoveryDefault) PreInit ¶
func (n *DiscoveryDefault) PreInit()
func (*DiscoveryDefault) Random ¶
func (n *DiscoveryDefault) Random(nodeType string) (cfacade.IMember, bool)
func (*DiscoveryDefault) RemoveMember ¶
func (n *DiscoveryDefault) RemoveMember(nodeID string)
func (*DiscoveryDefault) Stop ¶
func (n *DiscoveryDefault) Stop()
type DiscoveryMaster ¶
type DiscoveryMaster struct {
DiscoveryDefault
// contains filtered or unexported fields
}
DiscoveryMaster master节点模式(master为单节点) 先启动一个master节点 其他节点启动时Request(actorgo.discovery.register)，到master节点注册 master节点subscribe(actorgo.discovery.register)，返回已注册节点列表 master节点publish(actorgo.discovery.addMember)，当前已注册的节点到 所有客户端节点subscribe(actorgo.discovery.addMember)，接收新节点 所有节点subscribe(actorgo.discovery.unregister)，退出时注销节点
func (*DiscoveryMaster) Load ¶
func (m *DiscoveryMaster) Load(app cfacade.IApplication)
func (*DiscoveryMaster) Name ¶
func (m *DiscoveryMaster) Name() string
func (*DiscoveryMaster) NodeID2Bytes ¶
func (m *DiscoveryMaster) NodeID2Bytes(nodeID string) ([]byte, error)
func (*DiscoveryMaster) Stop ¶
func (m *DiscoveryMaster) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.