cdiscovery

package

v1.0.15 Latest Latest Go to latest Published: Apr 12, 2026 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/actorgo-game/actorgo

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ETCDClient() *clientv3.Client
func Register(discovery cfacade.IDiscovery)
type Component
- func New() *Component
type DiscoveryDefault
type DiscoveryETCD
- func GetETCD() *DiscoveryETCD
- func NewDiscoveryETCD() *DiscoveryETCD
type DiscoveryNats
- func GetNats() *DiscoveryNats
- func NewDiscoveryNats() *DiscoveryNats

Constants ¶

View Source

const (
	Name = "discovery_component"
)

Variables ¶

This section is empty.

Functions ¶

func ETCDClient ¶ added in v1.0.12

func ETCDClient() *clientv3.Client

func Register ¶

func Register(discovery cfacade.IDiscovery)

Types ¶

type Component ¶

type Component struct {
	cfacade.Component
	cfacade.IDiscovery
}

func New ¶

func New() *Component

func (*Component) Init ¶

func (p *Component) Init()

func (*Component) Name ¶

func (*Component) Name() string

func (*Component) OnStop ¶

func (p *Component) OnStop()

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) Map ¶

func (n *DiscoveryDefault) Map() map[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) 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 DiscoveryETCD ¶ added in v1.0.12

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

DiscoveryETCD etcd方式发现服务

func GetETCD ¶ added in v1.0.12

func GetETCD() *DiscoveryETCD

func NewDiscoveryETCD ¶ added in v1.0.12

func NewDiscoveryETCD() *DiscoveryETCD

func (*DiscoveryETCD) GetEnvKeyPrefix ¶ added in v1.0.12

func (p *DiscoveryETCD) GetEnvKeyPrefix() string

func (*DiscoveryETCD) GetRisterKeyPrefix ¶ added in v1.0.12

func (p *DiscoveryETCD) GetRisterKeyPrefix(nodeId string) string

func (*DiscoveryETCD) Load ¶ added in v1.0.12

func (p *DiscoveryETCD) Load(app cfacade.IApplication)

func (*DiscoveryETCD) Name ¶ added in v1.0.12

func (p *DiscoveryETCD) Name() string

func (*DiscoveryETCD) Stop ¶ added in v1.0.12

func (p *DiscoveryETCD) Stop()

type DiscoveryNats ¶ added in v1.0.12

type DiscoveryNats struct {
	DiscoveryDefault
	// contains filtered or unexported fields
}

DiscoveryNats 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 GetNats ¶ added in v1.0.12

func GetNats() *DiscoveryNats

func NewDiscoveryNats ¶ added in v1.0.12

func NewDiscoveryNats() *DiscoveryNats

func (*DiscoveryNats) Load ¶ added in v1.0.12

func (m *DiscoveryNats) Load(app cfacade.IApplication)

func (*DiscoveryNats) Name ¶ added in v1.0.12

func (m *DiscoveryNats) Name() string

func (*DiscoveryNats) Stop ¶ added in v1.0.12

func (m *DiscoveryNats) Stop()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL