Skip to content

Add retry support for blocking LoadBalancer #832

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
OlgaMaciaszek merged 11 commits into from
Sep 24, 2020
Merged

Add retry support for blocking LoadBalancer #832

Changes from 1 commit
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
1d44150
Add LoadBalancerProperties and BlockingLoadBalancedRetryPolicy. Add s…
OlgaMaciaszek Sep 22, 2020
08d6fd8
Add BlockingLoadBalancedRetryFactory
OlgaMaciaszek Sep 22, 2020
2e07d26
Move retry properties to LoadBalancerRetryProperties.
OlgaMaciaszek Sep 22, 2020
8cb08d5
Refactor and remove deprecations, fix checkstyle.
OlgaMaciaszek Sep 22, 2020
c84fa6a
Add BlockingLoadBalancedRetryPolicy to autoconfiguration. Set default…
OlgaMaciaszek Sep 23, 2020
f0d4bcc
Allow using @Order on LoadBalancedRetryFactory beans.
OlgaMaciaszek Sep 23, 2020
f8e0ab2
Add tests. Reformat tests. Add explanatory comments.
OlgaMaciaszek Sep 23, 2020
cde8b47
Add documentation.
OlgaMaciaszek Sep 23, 2020
ed8b59f
Fix javadoc.
OlgaMaciaszek Sep 23, 2020
e5e1f84
Fix docs after review.
OlgaMaciaszek Sep 24, 2020
e14e2e4
Change field name.
OlgaMaciaszek Sep 24, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Change field name.
  • Loading branch information
@OlgaMaciaszek
OlgaMaciaszek committed Sep 24, 2020
commit e14e2e49a679199dc8b1a0fb876464daa856eadb
8 changes: 4 additions & 4 deletions ...rg/springframework/cloud/loadbalancer/blocking/retry/BlockingLoadBalancedRetryPolicy.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ public class BlockingLoadBalancedRetryPolicy implements LoadBalancedRetryPolicy

private final LoadBalancerRetryProperties retryProperties;

private final ServiceInstanceChooser loadBalancerClient;
private final ServiceInstanceChooser serviceInstanceChooser;

private final String serviceId;

Expand All @@ -44,10 +44,10 @@ public class BlockingLoadBalancedRetryPolicy implements LoadBalancedRetryPolicy
private int nextServerCount = 0;

public BlockingLoadBalancedRetryPolicy(String serviceId,
ServiceInstanceChooser loadBalancerClient,
ServiceInstanceChooser serviceInstanceChooser,
LoadBalancerRetryProperties retryProperties) {
this.serviceId = serviceId;
this.loadBalancerClient = loadBalancerClient;
this.serviceInstanceChooser = serviceInstanceChooser;
this.retryProperties = retryProperties;
}

Expand Down Expand Up @@ -84,7 +84,7 @@ public void registerThrowable(LoadBalancedRetryContext context, Throwable throwa
context.setExhaustedOnly();
}
else {
context.setServiceInstance(loadBalancerClient.choose(serviceId));
context.setServiceInstance(serviceInstanceChooser.choose(serviceId));
}
}
else {
Expand Down