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
- type ServiceEvent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ToConfigurators ¶ added in v1.2.0
func ToConfigurators(urls []*common.URL, f func(url *common.URL) config_center.Configurator) []config_center.Configurator
Types ¶
type BaseConfigurationListener ¶ added in v1.2.0
type BaseConfigurationListener struct {
// contains filtered or unexported fields
}
func (*BaseConfigurationListener) Configurators ¶ added in v1.2.0
func (bcl *BaseConfigurationListener) Configurators() []config_center.Configurator
func (*BaseConfigurationListener) InitWith ¶ added in v1.2.0
func (bcl *BaseConfigurationListener) InitWith(key string, listener config_center.ConfigurationListener, f func(url *common.URL) config_center.Configurator)
func (*BaseConfigurationListener) OverrideUrl ¶ added in v1.2.0
func (bcl *BaseConfigurationListener) OverrideUrl(url *common.URL)
func (*BaseConfigurationListener) Process ¶ added in v1.2.0
func (bcl *BaseConfigurationListener) Process(event *config_center.ConfigChangeEvent)
type Listener ¶ added in v1.1.0
type Listener interface {
Next() (*ServiceEvent, error)
Close()
}
Deprecated!
type MockRegistry ¶ added in v1.1.0
type MockRegistry struct {
// contains filtered or unexported fields
}
func (*MockRegistry) Destroy ¶ added in v1.1.0
func (r *MockRegistry) Destroy()
func (*MockRegistry) GetUrl ¶ added in v1.1.0
func (r *MockRegistry) GetUrl() common.URL
func (*MockRegistry) IsAvailable ¶ added in v1.1.0
func (r *MockRegistry) IsAvailable() bool
func (*MockRegistry) MockEvent ¶ added in v1.1.0
func (r *MockRegistry) MockEvent(event *ServiceEvent)
func (*MockRegistry) Subscribe ¶ added in v1.1.0
func (r *MockRegistry) Subscribe(url *common.URL, notifyListener NotifyListener)
type NotifyListener ¶ added in v1.2.0
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
type ServiceEvent ¶ added in v1.1.0
func (ServiceEvent) String ¶ added in v1.1.0
func (e ServiceEvent) String() string
Source Files
¶
Click to show internal directories.
Click to hide internal directories.