config_center

Documentation

Index

• Constants
• func GetRuleKey(url *common.URL) string
• type BaseDynamicConfiguration
  • func (bdc *BaseDynamicConfiguration) RemoveConfig(string, string) error
• type ConfigChangeEvent
  • func (c ConfigChangeEvent) String() string
• type ConfigurationListener
• type Configurator
• type DynamicConfiguration
• type DynamicConfigurationFactory
• type MockDynamicConfiguration
  • func (c *MockDynamicConfiguration) AddListener(key string, listener ConfigurationListener, _ ...Option)
  • func (c *MockDynamicConfiguration) GetConfig(_ string, _ ...Option) (string, error)
  • func (c *MockDynamicConfiguration) GetConfigKeysByGroup(group string) (*gxset.HashSet, error)
  • func (c *MockDynamicConfiguration) GetConfigs(key string, opts ...Option) (string, error)
  • func (c *MockDynamicConfiguration) GetInternalProperty(key string, opts ...Option) (string, error)
  • func (c *MockDynamicConfiguration) GetProperties(_ string, _ ...Option) (string, error)
  • func (c *MockDynamicConfiguration) GetRule(key string, opts ...Option) (string, error)
  • func (c *MockDynamicConfiguration) MockApplicationConfigEvent()
  • func (c *MockDynamicConfiguration) MockServiceConfigEvent()
  • func (c *MockDynamicConfiguration) Parser() parser.ConfigurationParser
  • func (c *MockDynamicConfiguration) PublishConfig(string, string, string) error
  • func (c *MockDynamicConfiguration) RemoveListener(_ string, _ ConfigurationListener, _ ...Option)
  • func (c *MockDynamicConfiguration) SetParser(p parser.ConfigurationParser)
• type MockDynamicConfigurationFactory
  • func (f *MockDynamicConfigurationFactory) GetDynamicConfiguration(_ *common.URL) (DynamicConfiguration, error)
• type Option
  • func WithGroup(group string) Option
  • func WithTimeout(time time.Duration) Option
• type Options

Constants

const (
	// DefaultGroup default group
	DefaultGroup = "dubbo"
	// DefaultConfigTimeout default config timeout
	DefaultConfigTimeout = "10s"
)

//////////////////////////////////////// DynamicConfiguration ////////////////////////////////////////

Functions

func GetRuleKey

func GetRuleKey(url *common.URL) string

GetRuleKey The format is '{interfaceName}:[version]:[group]'

Types

type BaseDynamicConfiguration

type BaseDynamicConfiguration struct{}

BaseDynamicConfiguration will default implementation DynamicConfiguration some method

func (*BaseDynamicConfiguration) RemoveConfig

func (bdc *BaseDynamicConfiguration) RemoveConfig(string, string) error

RemoveConfig

type ConfigChangeEvent

type ConfigChangeEvent struct {
	Key        string
	Value      interface{}
	ConfigType remoting.EventType
}

ConfigChangeEvent for changing listener's event

func (ConfigChangeEvent) String

func (c ConfigChangeEvent) String() string

type ConfigurationListener

type ConfigurationListener interface {
	// Process the notification event once there's any change happens on the config
	Process(*ConfigChangeEvent)
}

ConfigurationListener for changing listener's event

type Configurator

type Configurator interface {
	GetUrl() *common.URL
	Configure(url *common.URL)
}

Configurator supports GetUrl and constructor

type DynamicConfiguration

type DynamicConfiguration interface {
	Parser() parser.ConfigurationParser
	SetParser(parser.ConfigurationParser)
	AddListener(string, ConfigurationListener, ...Option)
	RemoveListener(string, ConfigurationListener, ...Option)
	// GetProperties get properties file
	GetProperties(string, ...Option) (string, error)

	// GetRule get Router rule properties file
	GetRule(string, ...Option) (string, error)

	// GetInternalProperty get value by key in Default properties file(dubbo.properties)
	GetInternalProperty(string, ...Option) (string, error)

	// PublishConfig will publish the config with the (key, group, value) pair
	// for zk: path is /$(group)/config/$(key) -> value
	// for nacos: group, key -> value
	PublishConfig(string, string, string) error

	// RemoveConfig will remove the config white the (key, group) pair
	RemoveConfig(string, string) error

	// GetConfigKeysByGroup will return all keys with the group
	GetConfigKeysByGroup(group string) (*gxset.HashSet, error)
}

DynamicConfiguration for modify listener and get properties file

type DynamicConfigurationFactory

type DynamicConfigurationFactory interface {
	GetDynamicConfiguration(*common.URL) (DynamicConfiguration, error)
}

DynamicConfigurationFactory gets the DynamicConfiguration

type MockDynamicConfiguration

type MockDynamicConfiguration struct {
	BaseDynamicConfiguration
	// contains filtered or unexported fields
}

MockDynamicConfiguration uses to parse content and defines listener

func (*MockDynamicConfiguration) AddListener

func (c *MockDynamicConfiguration) AddListener(key string, listener ConfigurationListener, _ ...Option)

AddListener adds a listener for MockDynamicConfiguration

func (*MockDynamicConfiguration) GetConfig

func (c *MockDynamicConfiguration) GetConfig(_ string, _ ...Option) (string, error)

GetConfig returns content of MockDynamicConfiguration

func (*MockDynamicConfiguration) GetConfigKeysByGroup

func (c *MockDynamicConfiguration) GetConfigKeysByGroup(group string) (*gxset.HashSet, error)

GetConfigKeysByGroup will return all keys with the group

func (*MockDynamicConfiguration) GetConfigs

func (c *MockDynamicConfiguration) GetConfigs(key string, opts ...Option) (string, error)

GetConfigs For zookeeper, getConfig and getConfigs have the same meaning.

func (*MockDynamicConfiguration) GetInternalProperty

func (c *MockDynamicConfiguration) GetInternalProperty(key string, opts ...Option) (string, error)

GetInternalProperty For zookeeper, getConfig and getConfigs have the same meaning.

func (*MockDynamicConfiguration) GetProperties

func (c *MockDynamicConfiguration) GetProperties(_ string, _ ...Option) (string, error)

GetProperties gets content of MockDynamicConfiguration

func (*MockDynamicConfiguration) GetRule

func (c *MockDynamicConfiguration) GetRule(key string, opts ...Option) (string, error)

GetRule gets properties of MockDynamicConfiguration

func (*MockDynamicConfiguration) MockApplicationConfigEvent

func (c *MockDynamicConfiguration) MockApplicationConfigEvent()

MockApplicationConfigEvent returns ConfiguratorConfig

func (*MockDynamicConfiguration) MockServiceConfigEvent

func (c *MockDynamicConfiguration) MockServiceConfigEvent()

MockServiceConfigEvent returns ConfiguratorConfig

func (*MockDynamicConfiguration) Parser

func (c *MockDynamicConfiguration) Parser() parser.ConfigurationParser

Parser returns a parser of MockDynamicConfiguration

func (*MockDynamicConfiguration) PublishConfig

func (c *MockDynamicConfiguration) PublishConfig(string, string, string) error

PublishConfig will publish the config with the (key, group, value) pair

func (*MockDynamicConfiguration) RemoveListener

func (c *MockDynamicConfiguration) RemoveListener(_ string, _ ConfigurationListener, _ ...Option)

RemoveListener removes the listener for MockDynamicConfiguration

func (*MockDynamicConfiguration) SetParser

func (c *MockDynamicConfiguration) SetParser(p parser.ConfigurationParser)

SetParser sets parser of MockDynamicConfiguration

type MockDynamicConfigurationFactory

type MockDynamicConfigurationFactory struct {
	Content string
}

MockDynamicConfigurationFactory defines content

func (*MockDynamicConfigurationFactory) GetDynamicConfiguration

func (f *MockDynamicConfigurationFactory) GetDynamicConfiguration(_ *common.URL) (DynamicConfiguration, error)

GetDynamicConfiguration returns a DynamicConfiguration

type Option

type Option func(*Options)

Option ...

func WithGroup

func WithGroup(group string) Option

WithGroup assigns group to opt.Group

func WithTimeout

func WithTimeout(time time.Duration) Option

WithTimeout assigns time to opt.Timeout

type Options

type Options struct {
	Group   string
	Timeout time.Duration
}

Options ...