Skip to content

Commit

Permalink
Update UseAsMetaReport and UseAsConfigCenter as String to prevent val…
Browse files Browse the repository at this point in the history
…ue override (#2693)
  • Loading branch information
AlbumenJ authored Jul 1, 2024
1 parent 33d76a1 commit a141f7e
Show file tree
Hide file tree
Showing 3 changed files with 15 additions and 7 deletions.
14 changes: 11 additions & 3 deletions config/registry_config.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,8 +55,8 @@ type RegistryConfig struct {
Weight int64 `yaml:"weight" json:"weight,omitempty" property:"weight"` // Affects traffic distribution among registriesConfig, useful when subscribe to multiple registriesConfig Take effect only when no preferred registry is specified.
Params map[string]string `yaml:"params" json:"params,omitempty" property:"params"`
RegistryType string `yaml:"registry-type"`
UseAsMetaReport bool `default:"true" yaml:"use-as-meta-report" json:"use-as-meta-report,omitempty" property:"use-as-meta-report"`
UseAsConfigCenter bool `default:"true" yaml:"use-as-config-center" json:"use-as-config-center,omitempty" property:"use-as-config-center"`
UseAsMetaReport string `yaml:"use-as-meta-report" json:"use-as-meta-report,omitempty" property:"use-as-meta-report"`
UseAsConfigCenter string `yaml:"use-as-config-center" json:"use-as-config-center,omitempty" property:"use-as-config-center"`
}

// Prefix dubbo.registries
Expand Down Expand Up @@ -93,7 +93,15 @@ func (c *RegistryConfig) getUrlMap(roleType common.RoleType) url.Values {

func (c *RegistryConfig) startRegistryConfig() error {
c.translateRegistryAddress()
if c.UseAsMetaReport && isValid(c.Address) {
useAsMetaReport := true
if len(c.UseAsMetaReport) > 0 {
var err error
useAsMetaReport, err = strconv.ParseBool(c.UseAsMetaReport)
if err != nil {
return perrors.Wrap(err, "Start RegistryConfig failed.")
}
}
if useAsMetaReport && isValid(c.Address) {
if tmpUrl, err := c.toMetadataReportUrl(); err == nil {
instance.SetMetadataReportInstanceByReg(tmpUrl)
} else {
Expand Down
4 changes: 2 additions & 2 deletions global/registry_config.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,8 @@ type RegistryConfig struct {
Weight int64 `yaml:"weight" json:"weight,omitempty" property:"weight"` // Affects traffic distribution among registriesConfig, useful when subscribe to multiple registriesConfig Take effect only when no preferred registry is specified.
Params map[string]string `yaml:"params" json:"params,omitempty" property:"params"`
RegistryType string `yaml:"registry-type"`
UseAsMetaReport bool `default:"true" yaml:"use-as-meta-report" json:"use-as-meta-report,omitempty" property:"use-as-meta-report"`
UseAsConfigCenter bool `default:"true" yaml:"use-as-config-center" json:"use-as-config-center,omitempty" property:"use-as-config-center"`
UseAsMetaReport string `yaml:"use-as-meta-report" json:"use-as-meta-report,omitempty" property:"use-as-meta-report"`
UseAsConfigCenter string `yaml:"use-as-config-center" json:"use-as-config-center,omitempty" property:"use-as-config-center"`
}

func DefaultRegistryConfig() *RegistryConfig {
Expand Down
4 changes: 2 additions & 2 deletions registry/options.go
Original file line number Diff line number Diff line change
Expand Up @@ -192,12 +192,12 @@ func WithRegisterInterface() Option {

func WithoutUseAsMetaReport() Option {
return func(opts *Options) {
opts.Registry.UseAsMetaReport = false
opts.Registry.UseAsMetaReport = "false"
}
}

func WithoutUseAsConfigCenter() Option {
return func(opts *Options) {
opts.Registry.UseAsConfigCenter = false
opts.Registry.UseAsConfigCenter = "false"
}
}

0 comments on commit a141f7e

Please sign in to comment.