registry

Documentation

Index

• func ToConfigurators(urls []*common.URL, f func(url *common.URL) config_center.Configurator) []config_center.Configurator
• type BaseConfigurationListener
  • func (bcl *BaseConfigurationListener) Configurators() []config_center.Configurator
  • func (bcl *BaseConfigurationListener) InitWith(key string, listener config_center.ConfigurationListener, ...)
  • func (bcl *BaseConfigurationListener) OverrideUrl(url *common.URL)
  • func (bcl *BaseConfigurationListener) Process(event *config_center.ConfigChangeEvent)
• type Listener
• type MockRegistry
  • func (r *MockRegistry) Destroy()
  • func (r *MockRegistry) GetUrl() common.URL
  • func (r *MockRegistry) IsAvailable() bool
  • func (r *MockRegistry) MockEvent(event *ServiceEvent)
  • func (*MockRegistry) Register(url common.URL) error
  • func (r *MockRegistry) Subscribe(url *common.URL, notifyListener NotifyListener)
• type NotifyListener
• type Registry
  • func NewMockRegistry(url *common.URL) (Registry, error)
• type ServiceEvent
  • func (e ServiceEvent) String() string

Functions

func ToConfigurators

func ToConfigurators(urls []*common.URL, f func(url *common.URL) config_center.Configurator) []config_center.Configurator

Types

type BaseConfigurationListener

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

func (*BaseConfigurationListener) Configurators

func (bcl *BaseConfigurationListener) Configurators() []config_center.Configurator

func (*BaseConfigurationListener) InitWith

func (bcl *BaseConfigurationListener) InitWith(key string, listener config_center.ConfigurationListener, f func(url *common.URL) config_center.Configurator)

func (*BaseConfigurationListener) OverrideUrl

func (bcl *BaseConfigurationListener) OverrideUrl(url *common.URL)

func (*BaseConfigurationListener) Process

func (bcl *BaseConfigurationListener) Process(event *config_center.ConfigChangeEvent)

type Listener

type Listener interface {
	Next() (*ServiceEvent, error)
	Close()
}

Deprecated!

type MockRegistry

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

func (*MockRegistry) Destroy

func (r *MockRegistry) Destroy()

func (*MockRegistry) GetUrl

func (r *MockRegistry) GetUrl() common.URL

func (*MockRegistry) IsAvailable

func (r *MockRegistry) IsAvailable() bool

func (*MockRegistry) MockEvent

func (r *MockRegistry) MockEvent(event *ServiceEvent)

func (*MockRegistry) Register

func (*MockRegistry) Register(url common.URL) error

func (*MockRegistry) Subscribe

func (r *MockRegistry) Subscribe(url *common.URL, notifyListener NotifyListener)

type NotifyListener

type NotifyListener interface {
	Notify(*ServiceEvent)
}

type Registry

type Registry interface {
	common.Node
	//used for service provider calling , register services to registry
	//And it is also used for service consumer calling , register services cared about ,for dubbo's admin monitoring.
	Register(url common.URL) error

	//Will relace mode1 in dubbogo version v1.1.0
	//mode2 : callback mode, subscribe with notify(notify listener).
	Subscribe(*common.URL, NotifyListener)
}

Extension - Registry

func NewMockRegistry

func NewMockRegistry(url *common.URL) (Registry, error)

type ServiceEvent

type ServiceEvent struct {
	Action  remoting.EventType
	Service common.URL
}

func (ServiceEvent) String

func (e ServiceEvent) String() string