Documentation
¶
Index ¶
- Variables
- func NewBuiltinRegistryResolver(r *BuiltinRegistry) (discovery.Resolver, error)
- type BuiltinKitexRegistryClient
- type 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
Constants ¶
This section is empty.
Variables ¶
View Source
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) Name ¶
func (r *BuiltinRegistryResolver) Name() string
func (*BuiltinRegistryResolver) Target ¶
func (r *BuiltinRegistryResolver) Target(_ context.Context, target rpcinfo.EndpointInfo) (description string)
Source Files
Click to show internal directories.
Click to hide internal directories.