Renamed on containerHost/Port

Author: artem-v

cluster-api/src/main/java/io/scalecube/cluster/ClusterConfig.java

@@ -36,8 +36,8 @@ public final class ClusterConfig implements Cloneable {
   private MetadataDecoder metadataDecoder = MetadataDecoder.INSTANCE;
 
   private String memberAlias;
-  private String mappedHost;
-  private Integer mappedPort;
+  private String containerHost;
+  private Integer containerPort;
 
   private TransportConfig transportConfig = TransportConfig.defaultConfig();
   private FailureDetectorConfig failureDetectorConfig = FailureDetectorConfig.defaultConfig();
@@ -153,25 +153,25 @@ public ClusterConfig metadataDecoder(MetadataDecoder metadataDecoder) {
   }
 
   /**
-   * Deprecated since {@code 2.4.10} in favor of {@link #mappedHost()}.
+   * Deprecated since {@code 2.4.10} in favor of {@link #containerHost()}.
    *
    * @return member host
    */
   @Deprecated
   public String memberHost() {
-    return mappedHost;
+    return containerHost;
   }
 
   /**
-   * Deprecated since {@code 2.4.10} in favor of {@link #mappedHost(String)}.
+   * Deprecated since {@code 2.4.10} in favor of {@link #containerHost(String)}.
    *
    * @param memberHost member host
    * @return new {@code ClusterConfig} instance
    */
   @Deprecated
   public ClusterConfig memberHost(String memberHost) {
     ClusterConfig c = clone();
-    c.mappedHost = memberHost;
+    c.containerHost = memberHost;
     return c;
   }
 
@@ -182,8 +182,8 @@ public ClusterConfig memberHost(String memberHost) {
    *
    * @return mapped host
    */
-  public String mappedHost() {
-    return mappedHost;
+  public String containerHost() {
+    return containerHost;
   }
 
   /**
@@ -194,9 +194,9 @@ public String mappedHost() {
    * @param mappedHost mapped host
    * @return new {@code ClusterConfig} instance
    */
-  public ClusterConfig mappedHost(String mappedHost) {
+  public ClusterConfig containerHost(String mappedHost) {
     ClusterConfig c = clone();
-    c.mappedHost = mappedHost;
+    c.containerHost = mappedHost;
     return c;
   }
 
@@ -230,8 +230,8 @@ public ClusterConfig memberAlias(String memberAlias) {
    *
    * @return mapped port
    */
-  public Integer mappedPort() {
-    return mappedPort;
+  public Integer containerPort() {
+    return containerPort;
   }
 
   /**
@@ -242,32 +242,32 @@ public Integer mappedPort() {
    * @param mappedPort mapped port
    * @return new {@code ClusterConfig} instance
    */
-  public ClusterConfig mappedPort(Integer mappedPort) {
+  public ClusterConfig containerPort(Integer mappedPort) {
     ClusterConfig c = clone();
-    c.mappedPort = mappedPort;
+    c.containerPort = mappedPort;
     return c;
   }
 
   /**
-   * Deprecated since {@code 2.4.10} in favor of {@link #mappedPort()}.
+   * Deprecated since {@code 2.4.10} in favor of {@link #containerPort()}.
    *
    * @return member port
    */
   @Deprecated
   public Integer memberPort() {
-    return mappedPort;
+    return containerPort;
   }
 
   /**
-   * Deprecated since {@code 2.4.10} in favor of {@link #mappedPort(Integer)}.
+   * Deprecated since {@code 2.4.10} in favor of {@link #containerPort(Integer)}.
    *
    * @param memberPort member port
    * @return new {@code ClusterConfig} instance
    */
   @Deprecated
   public ClusterConfig memberPort(Integer memberPort) {
     ClusterConfig c = clone();
-    c.mappedPort = memberPort;
+    c.containerPort = memberPort;
     return c;
   }
 
@@ -357,8 +357,8 @@ public String toString() {
         .add("metadataEncoder=" + metadataEncoder)
         .add("metadataDecoder=" + metadataDecoder)
         .add("memberAlias='" + memberAlias + "'")
-        .add("mappedHost='" + mappedHost + "'")
-        .add("mappedPort=" + mappedPort)
+        .add("containerHost='" + containerHost + "'")
+        .add("containerPort=" + containerPort)
         .add("transportConfig=" + transportConfig)
         .add("failureDetectorConfig=" + failureDetectorConfig)
         .add("gossipConfig=" + gossipConfig)

cluster/src/main/java/io/scalecube/cluster/ClusterImpl.java

@@ -354,11 +354,11 @@ private Flux<MembershipEvent> listenMembership() {
    * @return local cluster member with cluster address and cluster member id
    */
   private Member createLocalMember(Address address) {
-    int port = Optional.ofNullable(config.mappedPort()).orElse(address.port());
+    int port = Optional.ofNullable(config.containerPort()).orElse(address.port());
 
     // calculate local member cluster address
     Address memberAddress =
-        Optional.ofNullable(config.mappedHost())
+        Optional.ofNullable(config.containerHost())
             .map(host -> Address.create(host, port))
             .orElseGet(() -> Address.create(address.host(), port));
 

cluster/src/test/java/io/scalecube/cluster/ClusterTest.java

@@ -138,7 +138,7 @@ public void testJoinLocalhostIgnoredWithOverride() throws InterruptedException {
 
     // Start seed node
     Cluster seedNode =
-        new ClusterImpl(new ClusterConfig().mappedHost("localhost").mappedPort(7878))
+        new ClusterImpl(new ClusterConfig().containerHost("localhost").containerPort(7878))
             .transport(opts -> opts.port(7878).connectTimeout(CONNECT_TIMEOUT))
             .membership(opts -> opts.seedMembers(addresses))
             .startAwait();

cluster/src/test/java/io/scalecube/cluster/membership/MembershipProtocolTest.java

@@ -751,19 +751,19 @@ public void testOverrideMemberAddress() throws UnknownHostException {
     NetworkEmulatorTransport e = createTransport();
 
     MembershipProtocolImpl cmA =
-        createMembership(a, testConfig(Collections.emptyList()).mappedHost(localAddress));
+        createMembership(a, testConfig(Collections.emptyList()).containerHost(localAddress));
     MembershipProtocolImpl cmB =
         createMembership(
-            b, testConfig(Collections.singletonList(a.address())).mappedHost(localAddress));
+            b, testConfig(Collections.singletonList(a.address())).containerHost(localAddress));
     MembershipProtocolImpl cmC =
         createMembership(
-            c, testConfig(Collections.singletonList(a.address())).mappedHost(localAddress));
+            c, testConfig(Collections.singletonList(a.address())).containerHost(localAddress));
     MembershipProtocolImpl cmD =
         createMembership(
-            d, testConfig(Collections.singletonList(b.address())).mappedHost(localAddress));
+            d, testConfig(Collections.singletonList(b.address())).containerHost(localAddress));
     MembershipProtocolImpl cmE =
         createMembership(
-            e, testConfig(Collections.singletonList(b.address())).mappedHost(localAddress));
+            e, testConfig(Collections.singletonList(b.address())).containerHost(localAddress));
 
     try {
       awaitSeconds(3);