registry

Documentation

Index

• type Registry
  • func NewRegistry(store storage.RegistryStore) *Registry
  • func (r *Registry) Get(key string) (*models.ServiceInfo, bool)
  • func (r *Registry) GetAllServices() []*models.ServiceInfo
  • func (r *Registry) GetByServiceName(serviceName string) []*models.ServiceInfo
  • func (r *Registry) GetSubscriberServices(serviceName string) []*models.ServiceInfo
  • func (r *Registry) GetSubscribers(serviceName string) []string
  • func (r *Registry) Register(reg *models.ServiceRegistration) *models.ServiceInfo
  • func (r *Registry) Unregister(serviceName, podName string) *models.ServiceInfo
  • func (r *Registry) UpdateHealthStatus(key string, status models.ServiceStatus) bool

Types

type Registry

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

Registry manages all registered services using a pluggable storage backend No locks needed because it's accessed only by single event queue worker

func NewRegistry

func NewRegistry(store storage.RegistryStore) *Registry

NewRegistry creates a new registry with the given storage backend

func (*Registry) Get

func (r *Registry) Get(key string) (*models.ServiceInfo, bool)

Get retrieves a service by key

func (*Registry) GetAllServices

func (r *Registry) GetAllServices() []*models.ServiceInfo

GetAllServices returns all registered services

func (*Registry) GetByServiceName

func (r *Registry) GetByServiceName(serviceName string) []*models.ServiceInfo

GetByServiceName returns all pods of a service

func (*Registry) GetSubscriberServices

func (r *Registry) GetSubscriberServices(serviceName string) []*models.ServiceInfo

GetSubscriberServices returns all ServiceInfo of subscribers for a given service name

func (*Registry) GetSubscribers

func (r *Registry) GetSubscribers(serviceName string) []string

GetSubscribers returns all subscriber keys for a given service name

func (*Registry) Register

func (r *Registry) Register(reg *models.ServiceRegistration) *models.ServiceInfo

Register adds or updates a service in the registry

func (*Registry) Unregister

func (r *Registry) Unregister(serviceName, podName string) *models.ServiceInfo

Unregister removes a service from the registry

func (*Registry) UpdateHealthStatus

func (r *Registry) UpdateHealthStatus(key string, status models.ServiceStatus) bool

UpdateHealthStatus updates the health status of a service