event

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 ProtocolPortsMetadataCustomizer
  • func (p *ProtocolPortsMetadataCustomizer) Customize(instance registry.ServiceInstance)
  • func (p *ProtocolPortsMetadataCustomizer) GetPriority() int

Functions

func ToConfigurators

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

ToConfigurators converts @urls by @f to config_center.Configurators

Types

type BaseConfigurationListener

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

nolint

func (*BaseConfigurationListener) Configurators

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

Configurators gets Configurator from config center

func (*BaseConfigurationListener) InitWith

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

InitWith will init BaseConfigurationListener by @key+@Listener+@f

func (*BaseConfigurationListener) OverrideUrl

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

OverrideUrl gets existing configuration rule and overrides provider url before exporting.

func (*BaseConfigurationListener) Process

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

Process the notification event once there's any change happens on the config.

type ProtocolPortsMetadataCustomizer

type ProtocolPortsMetadataCustomizer struct {
}

ProtocolPortsMetadataCustomizer will update the endpoints

func (*ProtocolPortsMetadataCustomizer) Customize

func (p *ProtocolPortsMetadataCustomizer) Customize(instance registry.ServiceInstance)

Customize put the the string like [{"protocol": "dubbo", "port": 123}] into instance's metadata

func (*ProtocolPortsMetadataCustomizer) GetPriority

func (p *ProtocolPortsMetadataCustomizer) GetPriority() int

GetPriority will return 0, which means it will be invoked at the beginning