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, params ...interface{})
• func List() []facade.IMember
• func ListByType(nodeType 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, _ jsoniter.Any, _ ...interface{})
  • func (n *DiscoveryDefault) List() []facade.IMember
  • func (n *DiscoveryDefault) ListByType(nodeType 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
• type DiscoveryMaster
  • func (m *DiscoveryMaster) Add(ctx context.Context, newMember *cherryProto2.Member) (*cherryProto2.Response, error)
  • func (m *DiscoveryMaster) Delete(ctx context.Context, oldMember *cherryProto2.Member) (*cherryProto2.Response, error)
  • func (m *DiscoveryMaster) Init(app facade.IApplication, config jsoniter.Any, params ...interface{})
  • func (m *DiscoveryMaster) Name() string
  • func (m *DiscoveryMaster) OnStop()
  • func (m *DiscoveryMaster) Register(ctx context.Context, newMember *cherryProto2.Member) (*cherryProto2.MemberList, error)
  • func (m *DiscoveryMaster) Unregister(ctx context.Context, oldMember *cherryProto2.Member) (*cherryProto2.Response, error)

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, params ...interface{})

func List

func List() []facade.IMember

func ListByType

func ListByType(nodeType 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, _ jsoniter.Any, _ ...interface{})

func (*DiscoveryDefault) List

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

func (*DiscoveryDefault) ListByType

func (n *DiscoveryDefault) ListByType(nodeType 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 {
}

DiscoveryETCD etcd方式发现服务

type DiscoveryMaster

type DiscoveryMaster struct {
	DiscoveryDefault
	facade.IApplication

	RPCServer *grpc.Server
	// contains filtered or unexported fields
}

DiscoveryMaster master节点模式(master为单点)

func (*DiscoveryMaster) Add

func (m *DiscoveryMaster) Add(ctx context.Context, newMember *cherryProto2.Member) (*cherryProto2.Response, error)

func (*DiscoveryMaster) Delete

func (m *DiscoveryMaster) Delete(ctx context.Context, oldMember *cherryProto2.Member) (*cherryProto2.Response, error)

func (*DiscoveryMaster) Init

func (m *DiscoveryMaster) Init(app facade.IApplication, config jsoniter.Any, params ...interface{})

func (*DiscoveryMaster) Name

func (m *DiscoveryMaster) Name() string

func (*DiscoveryMaster) OnStop

func (m *DiscoveryMaster) OnStop()

func (*DiscoveryMaster) Register

func (m *DiscoveryMaster) Register(ctx context.Context, newMember *cherryProto2.Member) (*cherryProto2.MemberList, error)

func (*DiscoveryMaster) Unregister

func (m *DiscoveryMaster) Unregister(ctx context.Context, oldMember *cherryProto2.Member) (*cherryProto2.Response, error)