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:41 UTC
[ignite] branch 6486 created (now d5e0c58)
This is an automated email from the ASF dual-hosted git repository.
shroman pushed a change to branch 6486
in repository https://gitbox.apache.org/repos/asf/ignite.git.
at d5e0c58 Adjusted to Ignite convensions.
This branch includes the following new commits:
new d5e0c58 Adjusted to Ignite convensions.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[ignite] 01/01: Adjusted to Ignite convensions.
Posted by sh...@apache.org.
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;
}