Documentation
¶
Index ¶
- func GetDiscovery(mode string) (cfacade.IDiscoveryComponent, error)
- func GetMode() (string, error)
- func New() cfacade.IDiscoveryComponent
- func NewMemberWithApp(app cherryFacade.IApplication) *cproto.Member
- func Register(component cfacade.IDiscoveryComponent)
- type ComponentDefault
- func (n *ComponentDefault) AddMember(member cfacade.IMember)
- func (n *ComponentDefault) GetMember(nodeID string) (cfacade.IMember, bool)
- func (n *ComponentDefault) GetType(nodeID string) (nodeType string, err error)
- func (n *ComponentDefault) Init()
- func (n *ComponentDefault) InitFields()
- func (n *ComponentDefault) ListByType(nodeType string, filterNodeID ...string) []cfacade.IMember
- func (n *ComponentDefault) Map() map[string]cfacade.IMember
- func (n *ComponentDefault) Mode() string
- func (*ComponentDefault) Name() string
- func (n *ComponentDefault) OnAddMember(listener cfacade.MemberListener)
- func (n *ComponentDefault) OnRemoveMember(listener cfacade.MemberListener)
- func (n *ComponentDefault) OnUpdateMember(listener cfacade.MemberListener)
- func (n *ComponentDefault) Random(nodeType string) (cfacade.IMember, bool)
- func (n *ComponentDefault) RemoveMember(nodeID string)
- func (n *ComponentDefault) UpdateMember(member *cproto.Member)
- func (n *ComponentDefault) UpdateSetting(key, value string)
- func (n *ComponentDefault) UpdateSettings(setting map[string]string)
- type ComponentMaster
- func (m *ComponentMaster) Init()
- func (m *ComponentMaster) Mode() string
- func (m *ComponentMaster) NodeID2Bytes(nodeID string) ([]byte, error)
- func (m *ComponentMaster) Stop()
- func (m *ComponentMaster) UpdateSetting(key, value string)
- func (m *ComponentMaster) UpdateSettings(setting map[string]string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetDiscovery ¶ added in v1.5.0
func GetDiscovery(mode string) (cfacade.IDiscoveryComponent, error)
func New ¶ added in v1.3.0
func New() cfacade.IDiscoveryComponent
func NewMemberWithApp ¶ added in v1.5.0
func NewMemberWithApp(app cherryFacade.IApplication) *cproto.Member
func Register ¶ added in v1.3.0
func Register(component cfacade.IDiscoveryComponent)
Types ¶
type ComponentDefault ¶ added in v1.5.0
ComponentDefault 默认方式，通过读取profile文件的节点信息
该类型发现服务仅用于开发测试使用，直接读取profile.json->node配置
func (*ComponentDefault) AddMember ¶ added in v1.5.0
func (n *ComponentDefault) AddMember(member cfacade.IMember)
func (*ComponentDefault) GetMember ¶ added in v1.5.0
func (n *ComponentDefault) GetMember(nodeID string) (cfacade.IMember, bool)
func (*ComponentDefault) GetType ¶ added in v1.5.0
func (n *ComponentDefault) GetType(nodeID string) (nodeType string, err error)
func (*ComponentDefault) Init ¶ added in v1.5.0
func (n *ComponentDefault) Init()
func (*ComponentDefault) InitFields ¶ added in v1.5.0
func (n *ComponentDefault) InitFields()
func (*ComponentDefault) ListByType ¶ added in v1.5.0
func (n *ComponentDefault) ListByType(nodeType string, filterNodeID ...string) []cfacade.IMember
func (*ComponentDefault) Map ¶ added in v1.5.0
func (n *ComponentDefault) Map() map[string]cfacade.IMember
func (*ComponentDefault) Mode ¶ added in v1.5.0
func (n *ComponentDefault) Mode() string
func (*ComponentDefault) Name ¶ added in v1.5.0
func (*ComponentDefault) Name() string
func (*ComponentDefault) OnAddMember ¶ added in v1.5.0
func (n *ComponentDefault) OnAddMember(listener cfacade.MemberListener)
func (*ComponentDefault) OnRemoveMember ¶ added in v1.5.0
func (n *ComponentDefault) OnRemoveMember(listener cfacade.MemberListener)
func (*ComponentDefault) OnUpdateMember ¶ added in v1.5.0
func (n *ComponentDefault) OnUpdateMember(listener cfacade.MemberListener)
func (*ComponentDefault) Random ¶ added in v1.5.0
func (n *ComponentDefault) Random(nodeType string) (cfacade.IMember, bool)
func (*ComponentDefault) RemoveMember ¶ added in v1.5.0
func (n *ComponentDefault) RemoveMember(nodeID string)
func (*ComponentDefault) UpdateMember ¶ added in v1.5.0
func (n *ComponentDefault) UpdateMember(member *cproto.Member)
func (*ComponentDefault) UpdateSetting ¶ added in v1.5.0
func (n *ComponentDefault) UpdateSetting(key, value string)
func (*ComponentDefault) UpdateSettings ¶ added in v1.5.0
func (n *ComponentDefault) UpdateSettings(setting map[string]string)
type ComponentMaster ¶ added in v1.5.0
type ComponentMaster struct {
ComponentDefault
// contains filtered or unexported fields
}
ComponentMaster master节点模式(master为单节点) 先启动一个master节点 其他节点启动时发送注册(cherry.discovery.register)，到master节点 master节点订阅(cherry.discovery.register)，返回已注册节点列表 master节点推送(cherry.discovery.addMember)，当前已注册的节点 所有客户端节点订阅(cherry.discovery.addMember)，接收新节点 所有节点退出时请求(cherry.discovery.remove)，到master节点
func NewMaster ¶ added in v1.5.0
func NewMaster() ComponentMaster
func (*ComponentMaster) Init ¶ added in v1.5.0
func (m *ComponentMaster) Init()
func (*ComponentMaster) Mode ¶ added in v1.5.0
func (m *ComponentMaster) Mode() string
func (*ComponentMaster) NodeID2Bytes ¶ added in v1.5.0
func (m *ComponentMaster) NodeID2Bytes(nodeID string) ([]byte, error)
func (*ComponentMaster) Stop ¶ added in v1.5.0
func (m *ComponentMaster) Stop()
func (*ComponentMaster) UpdateSetting ¶ added in v1.5.0
func (m *ComponentMaster) UpdateSetting(key, value string)
func (*ComponentMaster) UpdateSettings ¶ added in v1.5.0
func (m *ComponentMaster) UpdateSettings(setting map[string]string)
Source Files
Click to show internal directories.
Click to hide internal directories.