Versions in this module Expand all Collapse all v0 v0.1.1 Jun 14, 2021 v0.1.0 May 27, 2021 Changes in this version + const AnnotationsKeyMetadata + const AnnotationsKeyProtocolMap + const LabelsKeyServiceID + const LabelsKeyServiceName + const LabelsKeyServiceVersion + const ServiceAccountNamespacePath + var ErrIteratorClosed = errors.New("iterator closed") + func GetNamespace() string + func GetPodName() string + func LoadNamespace() string + type ErrorHandleResource struct + Name string + Namespace string + Reason error + func (err *ErrorHandleResource) Error() string + type Iterator struct + func NewIterator(channel chan []*registry.ServiceInstance, stopCh chan struct{}) *Iterator + func (iter *Iterator) Next() ([]*registry.ServiceInstance, error) + func (iter *Iterator) Stop() error + type Registry struct + func NewRegistry(clientSet *kubernetes.Clientset) *Registry + func (s *Registry) Close() + func (s *Registry) Deregister(service *registry.ServiceInstance) error + func (s *Registry) Register(service *registry.ServiceInstance) error + func (s *Registry) Service(name string) ([]*registry.ServiceInstance, error) + func (s *Registry) Start() + func (s *Registry) Watch(name string) (registry.Watcher, error)
Go to main page