registry

Documentation

Index

• Variables
• func NewBuiltinRegistryResolver(r *BuiltinRegistry) (discovery.Resolver, error)
• type BuiltinKitexRegistryClient
  • func NewBuiltinKitexRegistryClient(addr string) (*BuiltinKitexRegistryClient, error)
  • func (rc *BuiltinKitexRegistryClient) Deregister(info *kitexregistry.Info) error
  • func (rc *BuiltinKitexRegistryClient) Register(info *kitexregistry.Info) error
  • func (rc *BuiltinKitexRegistryClient) Update(serviceId string) error
• type BuiltinRegistry
  • func NewBuiltinRegistry(rdb redis.UniversalClient) *BuiltinRegistry
  • func (r *BuiltinRegistry) Count() int
  • func (r *BuiltinRegistry) Deregister(serviceId string) error
  • func (r *BuiltinRegistry) GetAllService() ([]*service.Service, error)
  • func (r *BuiltinRegistry) GetServiceById(serviceId string) (*service.Service, error)
  • func (r *BuiltinRegistry) Register(serviceId, host string, port int) error
  • func (r *BuiltinRegistry) ServiceExists(serviceId string) bool
  • func (r *BuiltinRegistry) StartSync()
  • func (r *BuiltinRegistry) Update(serviceId string) error
• type BuiltinRegistryResolver
  • func (r *BuiltinRegistryResolver) Diff(cacheKey string, prev, next discovery.Result) (discovery.Change, bool)
  • func (r *BuiltinRegistryResolver) Name() string
  • func (r *BuiltinRegistryResolver) Resolve(_ context.Context, _ string) (discovery.Result, error)
  • func (r *BuiltinRegistryResolver) Target(_ context.Context, target rpcinfo.EndpointInfo) (description string)
• type IRegistry

Variables

var ErrServiceNotFound = errors.New("service not found")

Functions

func NewBuiltinRegistryResolver

func NewBuiltinRegistryResolver(r *BuiltinRegistry) (discovery.Resolver, error)

Types

type BuiltinKitexRegistryClient

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

func NewBuiltinKitexRegistryClient

func NewBuiltinKitexRegistryClient(addr string) (*BuiltinKitexRegistryClient, error)

func (*BuiltinKitexRegistryClient) Deregister

func (rc *BuiltinKitexRegistryClient) Deregister(info *kitexregistry.Info) error

func (*BuiltinKitexRegistryClient) Register

func (rc *BuiltinKitexRegistryClient) Register(info *kitexregistry.Info) error

func (*BuiltinKitexRegistryClient) Update

func (rc *BuiltinKitexRegistryClient) Update(serviceId string) error

type BuiltinRegistry

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

func NewBuiltinRegistry

func NewBuiltinRegistry(rdb redis.UniversalClient) *BuiltinRegistry

func (*BuiltinRegistry) Count

func (r *BuiltinRegistry) Count() int

func (*BuiltinRegistry) Deregister

func (r *BuiltinRegistry) Deregister(serviceId string) error

func (*BuiltinRegistry) GetAllService

func (r *BuiltinRegistry) GetAllService() ([]*service.Service, error)

func (*BuiltinRegistry) GetServiceById

func (r *BuiltinRegistry) GetServiceById(serviceId string) (*service.Service, error)

func (*BuiltinRegistry) Register

func (r *BuiltinRegistry) Register(serviceId, host string, port int) error

func (*BuiltinRegistry) ServiceExists

func (r *BuiltinRegistry) ServiceExists(serviceId string) bool

func (*BuiltinRegistry) StartSync

func (r *BuiltinRegistry) StartSync()

func (*BuiltinRegistry) Update

func (r *BuiltinRegistry) Update(serviceId string) error

type BuiltinRegistryResolver

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

func (*BuiltinRegistryResolver) Diff

func (r *BuiltinRegistryResolver) Diff(cacheKey string, prev, next discovery.Result) (discovery.Change, bool)

func (*BuiltinRegistryResolver) Name

func (r *BuiltinRegistryResolver) Name() string

func (*BuiltinRegistryResolver) Resolve

func (r *BuiltinRegistryResolver) Resolve(_ context.Context, _ string) (discovery.Result, error)

func (*BuiltinRegistryResolver) Target

func (r *BuiltinRegistryResolver) Target(_ context.Context, target rpcinfo.EndpointInfo) (description string)

type IRegistry

type IRegistry interface {
	GetAllService() ([]*service.Service, error)
	Count() int // get current service num in registry
	GetServiceById(string) (*service.Service, error)
	ServiceExists(string) bool
}