watcher

Documentation

Index

• type NamespaceWatcher
  • func NewNamespaceWatcher(nacosAddr, namespace string, notifyChan chan<- []common.DubboServiceInstance) (*NamespaceWatcher, error)
  • func (w *NamespaceWatcher) Run(stop <-chan struct{})

Types

type NamespaceWatcher

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

NamespaceWatcher contains the runtime configuration for a Nacos Namespace Watcher

func NewNamespaceWatcher

func NewNamespaceWatcher(nacosAddr, namespace string, notifyChan chan<- []common.DubboServiceInstance) (
	*NamespaceWatcher, error)

NewNamespaceWatcher creates a Namespace Watcher

func (*NamespaceWatcher) Run

func (w *NamespaceWatcher) Run(stop <-chan struct{})

Run until a signal is received, this function blocks