Skip to content

Commit b800128

Browse files
committed
support custom dubbo invoke retries times
1 parent 9fd3f9f commit b800128

File tree

2 files changed

+10
-5
lines changed

2 files changed

+10
-5
lines changed

pkg/client/dubbo/config.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,8 @@ type DubboProxyConfig struct {
3333
AutoResolve bool `yaml:"auto_resolve" json:"auto_resolve,omitempty"`
3434
// Protoset path to load protoset files
3535
Protoset []string `yaml:"protoset" json:"protoset,omitempty"`
36-
// Load
36+
// Load load balance
3737
LoadBalance string `yaml:"load_balance" json:"load_balance,omitempty"`
38+
// Retries number of retries
39+
Retries string `yaml:"retries" json:"retries,omitempty"`
3840
}

pkg/client/dubbo/dubbo.go

+7-4
Original file line numberDiff line numberDiff line change
@@ -319,12 +319,15 @@ func (dc *Client) create(key string, irequest fc.IntegrationRequest) *generic.Ge
319319
Version: irequest.DubboBackendConfig.Version,
320320
Group: irequest.Group,
321321
Loadbalance: dc.dubboProxyConfig.LoadBalance,
322+
Retries: dc.dubboProxyConfig.Retries,
322323
}
323324

324-
if len(irequest.DubboBackendConfig.Retries) == 0 {
325-
refConf.Retries = "3"
326-
} else {
327-
refConf.Retries = irequest.DubboBackendConfig.Retries
325+
if refConf.Retries == "" {
326+
if len(irequest.DubboBackendConfig.Retries) == 0 {
327+
refConf.Retries = "3"
328+
} else {
329+
refConf.Retries = irequest.DubboBackendConfig.Retries
330+
}
328331
}
329332

330333
if dc.dubboProxyConfig.Timeout != nil {

0 commit comments

Comments
 (0)