You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sh...@apache.org on 2019/06/14 09:00:42 UTC
[ignite] 01/01: Adjusted to Ignite convensions.
This is an automated email from the ASF dual-hosted git repository.
shroman pushed a commit to branch 6486
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit d5e0c58859263aa2bcbeabcff9e7d9c65d4f86ba
Author: shroman <rs...@yahoo.com>
AuthorDate: Fri Jun 14 17:59:45 2019 +0900
Adjusted to Ignite convensions.
---
.../ipfinder/kubernetes/TcpDiscoveryKubernetesIpFinder.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/modules/kubernetes/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/kubernetes/TcpDiscoveryKubernetesIpFinder.java b/modules/kubernetes/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/kubernetes/TcpDiscoveryKubernetesIpFinder.java
index 0741fcf..b24a972 100644
--- a/modules/kubernetes/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/kubernetes/TcpDiscoveryKubernetesIpFinder.java
+++ b/modules/kubernetes/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/kubernetes/TcpDiscoveryKubernetesIpFinder.java
@@ -65,7 +65,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
* <li>The Kubernetes service namespace for IP addresses lookup (see {@link #setNamespace(String)}</li>
* <li>The host name of the Kubernetes API server (see {@link #setMasterUrl(String)})</li>
* <li>Path to the service token (see {@link #setAccountToken(String)}</li>
- * <li>To include not-ready pods (see {@link #setIncludeNotReadyAddresses(boolean)}</li>
+ * <li>To include not-ready pods (see {@link #includeNotReadyAddresses(boolean)}</li>
* </ul>
* <p>
* Both {@link #registerAddresses(Collection)} and {@link #unregisterAddresses(Collection)} have no effect.
@@ -121,7 +121,7 @@ public class TcpDiscoveryKubernetesIpFinder extends TcpDiscoveryIpFinderAdapter
/** SSL context */
private SSLContext ctx;
- /** Whether addresses of pods in not-ready state should be included */
+ /** Whether addresses of pods in not-ready state should be included. */
private boolean includeNotReadyAddresses;
/**
@@ -156,9 +156,9 @@ public class TcpDiscoveryKubernetesIpFinder extends TcpDiscoveryIpFinderAdapter
if (endpoints != null && endpoints.subsets != null && !endpoints.subsets.isEmpty()) {
for (Subset subset : endpoints.subsets) {
addrs.addAll(parseAddresses(subset.addresses));
- if (includeNotReadyAddresses) {
+
+ if (includeNotReadyAddresses)
addrs.addAll(parseAddresses(subset.notReadyAddresses));
- }
}
}
}
@@ -238,7 +238,7 @@ public class TcpDiscoveryKubernetesIpFinder extends TcpDiscoveryIpFinderAdapter
*
* @param includeNotReadyAddresses Flag to include not-ready pods.
*/
- public void setIncludeNotReadyAddresses(boolean includeNotReadyAddresses) {
+ public void includeNotReadyAddresses(boolean includeNotReadyAddresses) {
this.includeNotReadyAddresses = includeNotReadyAddresses;
}