Skip to content
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

Jump to bottom

[improve] [client]Add new ServiceUrlProvider implementation: SameAuthParamsAutoClusterFailover #23129

Merged
merged 10 commits into from
Aug 12, 2024
Merged

[improve] [client]Add new ServiceUrlProvider implementation: SameAuthParamsAutoClusterFailover #23129

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift click to select a range
03f17b6
[improve] [client]Add new ServiceUrlProvider implementation: SameAuth…
poorbarcode Aug 6, 2024
2c08672
-
poorbarcode Aug 6, 2024
b366711
-
poorbarcode Aug 7, 2024
9764643
fix comment
poorbarcode Aug 7, 2024
37289e3
address comment
poorbarcode Aug 7, 2024
5c3c6e0
address comment
poorbarcode Aug 7, 2024
f4fb857
checkstyle
poorbarcode Aug 7, 2024
d554817
checkstyle
poorbarcode Aug 7, 2024
47ccb1e
checkstyle
poorbarcode Aug 7, 2024
ce9df7f
add a param check: does not support http protocol
poorbarcode Aug 12, 2024
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
Next Next commit
checkstyle
  • Loading branch information
@poorbarcode
poorbarcode committed Aug 7, 2024
commit f4fb857994427273012c445f7fb17238bcd7d65d
1 change: 1 addition & 0 deletions .../src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -147,6 147,7 @@ private void checkPulsarServices() {
case Failed: {
pulsarServiceStateArray[i] = PulsarServiceState.PreRecover;
checkCounterArray[i].setValue(1);
break;
}
case PreRecover: {
checkCounterArray[i].setValue(checkCounterArray[i].getValue() 1);
Expand Down
2 changes: 0 additions & 2 deletions pulsar-client/src/test/java/org/apache/pulsar/client/impl/AutoClusterFailoverTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 23,6 @@
import static org.testng.Assert.assertEquals;
import static org.testng.Assert.assertNull;
import static org.testng.Assert.assertTrue;
import java.io.IOException;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
Expand All @@ -32,7 31,6 @@
import lombok.extern.slf4j.Slf4j;
import org.apache.pulsar.client.api.Authentication;
import org.apache.pulsar.client.api.AuthenticationFactory;
import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.ServiceUrlProvider;
import org.apache.pulsar.client.impl.conf.ClientConfigurationData;
import org.awaitility.Awaitility;
Expand Down
1 change: 0 additions & 1 deletion pulsar-client/src/test/java/org/apache/pulsar/client/impl/ControlledClusterFailoverTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 18,6 @@
*/
package org.apache.pulsar.client.impl;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
Expand Down
Loading