cherryDiscovery

Documentation

Index

• func AddMember(member facade.IMember)
• func Discovery() facade.IDiscovery
• func GetMember(nodeId string) (member facade.IMember, found bool)
• func GetType(nodeId string) (nodeType string, err error)
• func Init(app facade.IApplication)
• func List() []facade.IMember
• func ListByType(nodeType string, filterNodeId ...string) []facade.IMember
• func OnAddMember(listener facade.MemberListener)
• func OnRemoveMember(listener facade.MemberListener)
• func OnStop()
• func RegisterDiscovery(discovery facade.IDiscovery)
• func RemoveMember(nodeId string)
• type DiscoveryDefault
  • func (n *DiscoveryDefault) AddMember(member facade.IMember)
  • func (n *DiscoveryDefault) GetMember(nodeId string) (facade.IMember, bool)
  • func (n *DiscoveryDefault) GetType(nodeId string) (nodeType string, err error)
  • func (n *DiscoveryDefault) Init(_ facade.IApplication)
  • func (n *DiscoveryDefault) List() []facade.IMember
  • func (n *DiscoveryDefault) ListByType(nodeType string, filterNodeId ...string) []facade.IMember
  • func (n *DiscoveryDefault) Name() string
  • func (n *DiscoveryDefault) OnAddMember(listener facade.MemberListener)
  • func (n *DiscoveryDefault) OnRemoveMember(listener facade.MemberListener)
  • func (n *DiscoveryDefault) OnStop()
  • func (n *DiscoveryDefault) RemoveMember(nodeId string)
• type DiscoveryETCD
  • func (p *DiscoveryETCD) Init(app facade.IApplication)
  • func (p *DiscoveryETCD) Name() string
  • func (p *DiscoveryETCD) OnStop()
• type DiscoveryNATS
  • func (m *DiscoveryNATS) Init(app facade.IApplication)
  • func (m *DiscoveryNATS) Name() string
  • func (m *DiscoveryNATS) OnStop()

Functions

func AddMember

func AddMember(member facade.IMember)

func Discovery

func Discovery() facade.IDiscovery

func GetMember

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

func GetType

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

func Init

func Init(app facade.IApplication)

func List

func List() []facade.IMember

func ListByType

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

func OnAddMember

func OnAddMember(listener facade.MemberListener)

func OnRemoveMember

func OnRemoveMember(listener facade.MemberListener)

func OnStop

func OnStop()

func RegisterDiscovery

func RegisterDiscovery(discovery facade.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 facade.IMember)

func (*DiscoveryDefault) GetMember

func (n *DiscoveryDefault) GetMember(nodeId string) (facade.IMember, bool)

func (*DiscoveryDefault) GetType

func (n *DiscoveryDefault) GetType(nodeId string) (nodeType string, err error)

func (*DiscoveryDefault) Init

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

func (*DiscoveryDefault) List

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

func (*DiscoveryDefault) ListByType

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

func (*DiscoveryDefault) Name

func (n *DiscoveryDefault) Name() string

func (*DiscoveryDefault) OnAddMember

func (n *DiscoveryDefault) OnAddMember(listener facade.MemberListener)

func (*DiscoveryDefault) OnRemoveMember

func (n *DiscoveryDefault) OnRemoveMember(listener facade.MemberListener)

func (*DiscoveryDefault) OnStop

func (n *DiscoveryDefault) OnStop()

func (*DiscoveryDefault) RemoveMember

func (n *DiscoveryDefault) RemoveMember(nodeId string)

type DiscoveryETCD

type DiscoveryETCD struct {
	facade.IApplication
	DiscoveryDefault
	// contains filtered or unexported fields
}

DiscoveryETCD etcd方式发现服务

func (*DiscoveryETCD) Init

func (p *DiscoveryETCD) Init(app facade.IApplication)

func (*DiscoveryETCD) Name

func (p *DiscoveryETCD) Name() string

func (*DiscoveryETCD) OnStop

func (p *DiscoveryETCD) OnStop()

type DiscoveryNATS

type DiscoveryNATS struct {
	DiscoveryDefault
	facade.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 facade.IApplication)

func (*DiscoveryNATS) Name

func (m *DiscoveryNATS) Name() string

func (*DiscoveryNATS) OnStop

func (m *DiscoveryNATS) OnStop()