cherryDiscovery

Documentation

Index

• func AddMember(member cfacade.IMember)
• func Discovery() cfacade.IDiscovery
• func GetMember(nodeId string) (member cfacade.IMember, found bool)
• func GetType(nodeId string) (nodeType string, err error)
• func Init(app cfacade.IApplication)
• func List() []cfacade.IMember
• func ListByType(nodeType string, filterNodeId ...string) []cfacade.IMember
• func OnAddMember(listener cfacade.MemberListener)
• func OnRemoveMember(listener cfacade.MemberListener)
• func OnStop()
• func RegisterDiscovery(discovery cfacade.IDiscovery)
• func RemoveMember(nodeId string)
• 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) Init(_ cfacade.IApplication)
  • func (n *DiscoveryDefault) List() []cfacade.IMember
  • func (n *DiscoveryDefault) ListByType(nodeType string, filterNodeId ...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) OnStop()
  • func (n *DiscoveryDefault) RemoveMember(nodeId string)
• type DiscoveryNATS
  • func (m *DiscoveryNATS) Init(app cfacade.IApplication)
  • func (m *DiscoveryNATS) Name() string
  • func (m *DiscoveryNATS) OnStop()

Functions

func AddMember

func AddMember(member cfacade.IMember)

func Discovery

func Discovery() cfacade.IDiscovery

func GetMember

func GetMember(nodeId string) (member cfacade.IMember, found bool)

func GetType

func GetType(nodeId string) (nodeType string, err error)

func Init

func Init(app cfacade.IApplication)

func List

func List() []cfacade.IMember

func ListByType

func ListByType(nodeType string, filterNodeId ...string) []cfacade.IMember

func OnAddMember

func OnAddMember(listener cfacade.MemberListener)

func OnRemoveMember

func OnRemoveMember(listener cfacade.MemberListener)

func OnStop

func OnStop()

func RegisterDiscovery

func RegisterDiscovery(discovery cfacade.IDiscovery)

func RemoveMember

func RemoveMember(nodeId string)

Types

type DiscoveryDefault

type DiscoveryDefault struct {
	sync.RWMutex
	// 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) Init

func (n *DiscoveryDefault) Init(_ cfacade.IApplication)

func (*DiscoveryDefault) List

func (n *DiscoveryDefault) List() []cfacade.IMember

func (*DiscoveryDefault) ListByType

func (n *DiscoveryDefault) ListByType(nodeType string, filterNodeId ...string) []cfacade.IMember

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) OnStop

func (n *DiscoveryDefault) OnStop()

func (*DiscoveryDefault) RemoveMember

func (n *DiscoveryDefault) RemoveMember(nodeId string)

type DiscoveryNATS

type DiscoveryNATS struct {
	DiscoveryDefault
	cfacade.IApplication
	// contains filtered or unexported fields
}

DiscoveryNATS master节点模式(master为单节点) 先启动一个master节点 其他节点启动时Request(cherry.discovery.register)，到master节点注册 master节点subscribe(cherry.discovery.register)，返回已注册节点列表 master节点publish(cherry.discovery.addMember)，当前已注册的节点到 所有客户端节点subscribe(cherry.discovery.addMember)，接收新节点 所有节点subscribe(cherry.discovery.unregister)，退出时注销节点

func (*DiscoveryNATS) Init

func (m *DiscoveryNATS) Init(app cfacade.IApplication)

func (*DiscoveryNATS) Name

func (m *DiscoveryNATS) Name() string

func (*DiscoveryNATS) OnStop

func (m *DiscoveryNATS) OnStop()