registry

Documentation

Index

• Constants
• type Registry
  • func NewConfigRegistry(ctx context.Context, config *gira.EtcdConfig) (*Registry, error)
  • func (r *Registry) GetPeer(fullName string) *gira.Peer
  • func (r *Registry) ListLocalUser() []string
  • func (r *Registry) LockLocalUser(userId string) (*gira.Peer, error)
  • func (r *Registry) NewServiceName(serviceName string, opt ...service_options.RegisterOption) string
  • func (r *Registry) RangePeers(f func(k any, v any) bool)
  • func (r *Registry) RegisterService(serviceName string, opt ...service_options.RegisterOption) (*gira.Peer, error)
  • func (r *Registry) SelfPeer() *gira.Peer
  • func (r *Registry) StartAsMember() error
  • func (r *Registry) StartReslover() error
  • func (r *Registry) Stop() error
  • func (r *Registry) UnlockLocalUser(userId string) (*gira.Peer, error)
  • func (r *Registry) UnregisterService(serviceName string) (*gira.Peer, error)
  • func (r *Registry) Watch(peerWatchHandlers []gira.PeerWatchHandler, ...) error
  • func (r *Registry) WhereIsPeer(appFullName string) (*gira.Peer, error)
  • func (r *Registry) WhereIsService(serviceName string, opt ...service_options.WhereOption) ([]*gira.Peer, error)
  • func (r *Registry) WhereIsUser(userId string) (*gira.Peer, error)

Constants

const (
	GRPC_KEY string = "grpc"
)

const (
	PeerScheme string = "peer"
)

Types

type Registry

type Registry struct {
	// contains filtered or unexported fields
}

func NewConfigRegistry

func NewConfigRegistry(ctx context.Context, config *gira.EtcdConfig) (*Registry, error)

func (*Registry) GetPeer

func (r *Registry) GetPeer(fullName string) *gira.Peer

根据app名查找节点 协程安全

func (*Registry) ListLocalUser

func (r *Registry) ListLocalUser() []string

func (*Registry) LockLocalUser

func (r *Registry) LockLocalUser(userId string) (*gira.Peer, error)

锁定玩家

func (*Registry) NewServiceName

func (r *Registry) NewServiceName(serviceName string, opt ...service_options.RegisterOption) string

func (*Registry) RangePeers

func (r *Registry) RangePeers(f func(k any, v any) bool)

func (*Registry) RegisterService

func (r *Registry) RegisterService(serviceName string, opt ...service_options.RegisterOption) (*gira.Peer, error)

注册服务

func (*Registry) SelfPeer

func (r *Registry) SelfPeer() *gira.Peer

func (*Registry) StartAsMember

func (r *Registry) StartAsMember() error

作为其中一个节点来启动 会将自己注册进去

func (*Registry) StartReslover

func (r *Registry) StartReslover() error

开启resolver

func (*Registry) Stop

func (r *Registry) Stop() error

关闭，释放资源

func (*Registry) UnlockLocalUser

func (r *Registry) UnlockLocalUser(userId string) (*gira.Peer, error)

解锁玩家

func (*Registry) UnregisterService

func (r *Registry) UnregisterService(serviceName string) (*gira.Peer, error)

反注册服务

func (*Registry) Watch

func (r *Registry) Watch(peerWatchHandlers []gira.PeerWatchHandler, localPlayerWatchHandlers []gira.LocalPlayerWatchHandler, serviceWatchHandlers []gira.ServiceWatchHandler) error

func (*Registry) WhereIsPeer

func (r *Registry) WhereIsPeer(appFullName string) (*gira.Peer, error)

查找节点

func (*Registry) WhereIsService

func (r *Registry) WhereIsService(serviceName string, opt ...service_options.WhereOption) ([]*gira.Peer, error)

查找服务

func (*Registry) WhereIsUser

func (r *Registry) WhereIsUser(userId string) (*gira.Peer, error)

查找玩家