+minRetryConcurrency |
+UInt32Value |
+
+ The minimum number of concurrent retries allowed for the retry budget.
+The limit on the number of active retries may never go below this number.
+This parameter is optional. Defaults to 3.
+
|
No
@@ -1655,6 +1707,18 @@ ConnectionPoolSettings.HTTPSettings
The maximum number of concurrent streams allowed for a peer on one HTTP/2 connection.
Defaults to 2^31-1.
+ |
+
+No
+ |
+
+
+retryBudget |
+RetryBudget |
+
+ The amount of concurrent retries allowed in the case of failure, a
+percentage of the active requests.
+
|
No
diff --git a/networking/v1alpha3/destination_rule.proto b/networking/v1alpha3/destination_rule.proto
index dadc379395b..31e472cb6ab 100644
--- a/networking/v1alpha3/destination_rule.proto
+++ b/networking/v1alpha3/destination_rule.proto
@@ -514,6 +514,8 @@ message LoadBalancerSettings {
// amount of requests.
// Currently this is only supported for ROUND_ROBIN and LEAST_REQUEST load balancers.
google.protobuf.Duration warmup_duration_secs = 4;
+
+ RetryBudget retry_budget = 5;
}
// Connection pool settings for an upstream host. The settings apply to
@@ -642,6 +644,10 @@ message ConnectionPoolSettings {
// The maximum number of concurrent streams allowed for a peer on one HTTP/2 connection.
// Defaults to 2^31-1.
int32 max_concurrent_streams = 8;
+
+ // The amount of concurrent retries allowed in the case of failure, a
+ // percentage of the active requests.
+ RetryBudget retry_budget = 9;
};
// Settings common to both HTTP and TCP upstream connections.
@@ -650,6 +656,20 @@ message ConnectionPoolSettings {
HTTPSettings http = 2;
}
+message RetryBudget {
+ // The limit on concurrent retries as a percentage of active requests and
+ // active pending requests.
+ // ex. if there are 100 active requests and the budget_percent is set
+ // to 25, there may be 25 active retries.
+ // This parameter is optional. Defaults to 20%.
+ Percent budget_percent = 1;
+
+ // The minimum number of concurrent retries allowed for the retry budget.
+ // The limit on the number of active retries may never go below this number.
+ // This parameter is optional. Defaults to 3.
+ google.protobuf.UInt32Value min_retry_concurrency = 2;
+}
+
// A Circuit breaker implementation that tracks the status of each
// individual host in the upstream service. Applicable to both HTTP and
// TCP services. For HTTP services, hosts that continually return 5xx
diff --git a/networking/v1alpha3/destination_rule_deepcopy.gen.go b/networking/v1alpha3/destination_rule_deepcopy.gen.go
index 597753faf14..769112c9fb4 100644
--- a/networking/v1alpha3/destination_rule_deepcopy.gen.go
+++ b/networking/v1alpha3/destination_rule_deepcopy.gen.go
@@ -320,6 +320,27 @@ func (in *ConnectionPoolSettings_HTTPSettings) DeepCopyInterface() interface{} {
return in.DeepCopy()
}
+// DeepCopyInto supports using RetryBudget within kubernetes types, where deepcopy-gen is used.
+func (in *RetryBudget) DeepCopyInto(out *RetryBudget) {
+ p := proto.Clone(in).(*RetryBudget)
+ *out = *p
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryBudget. Required by controller-gen.
+func (in *RetryBudget) DeepCopy() *RetryBudget {
+ if in == nil {
+ return nil
+ }
+ out := new(RetryBudget)
+ in.DeepCopyInto(out)
+ return out
+}
+
+// DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RetryBudget. Required by controller-gen.
+func (in *RetryBudget) DeepCopyInterface() interface{} {
+ return in.DeepCopy()
+}
+
// DeepCopyInto supports using OutlierDetection within kubernetes types, where deepcopy-gen is used.
func (in *OutlierDetection) DeepCopyInto(out *OutlierDetection) {
p := proto.Clone(in).(*OutlierDetection)
diff --git a/networking/v1alpha3/destination_rule_json.gen.go b/networking/v1alpha3/destination_rule_json.gen.go
index 377644a0f1c..e99969611a3 100644
--- a/networking/v1alpha3/destination_rule_json.gen.go
+++ b/networking/v1alpha3/destination_rule_json.gen.go
@@ -171,6 +171,17 @@ func (this *ConnectionPoolSettings_HTTPSettings) UnmarshalJSON(b []byte) error {
return DestinationRuleUnmarshaler.Unmarshal(bytes.NewReader(b), this)
}
+// MarshalJSON is a custom marshaler for RetryBudget
+func (this *RetryBudget) MarshalJSON() ([]byte, error) {
+ str, err := DestinationRuleMarshaler.MarshalToString(this)
+ return []byte(str), err
+}
+
+// UnmarshalJSON is a custom unmarshaler for RetryBudget
+func (this *RetryBudget) UnmarshalJSON(b []byte) error {
+ return DestinationRuleUnmarshaler.Unmarshal(bytes.NewReader(b), this)
+}
+
// MarshalJSON is a custom marshaler for OutlierDetection
func (this *OutlierDetection) MarshalJSON() ([]byte, error) {
str, err := DestinationRuleMarshaler.MarshalToString(this)
diff --git a/networking/v1beta1/destination_rule_alias.gen.go b/networking/v1beta1/destination_rule_alias.gen.go
index 46de656f5e6..58620b23109 100644
--- a/networking/v1beta1/destination_rule_alias.gen.go
+++ b/networking/v1beta1/destination_rule_alias.gen.go
@@ -270,6 +270,8 @@ const ConnectionPoolSettings_HTTPSettings_DO_NOT_UPGRADE ConnectionPoolSettings_
// This opt-in option overrides the default.
const ConnectionPoolSettings_HTTPSettings_UPGRADE ConnectionPoolSettings_HTTPSettings_H2UpgradePolicy = v1alpha3.ConnectionPoolSettings_HTTPSettings_UPGRADE
+type RetryBudget = v1alpha3.RetryBudget
+
// A Circuit breaker implementation that tracks the status of each
// individual host in the upstream service. Applicable to both HTTP and
// TCP services. For HTTP services, hosts that continually return 5xx
|