You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gossip.apache.org by ec...@apache.org on 2016/11/09 18:50:08 UTC
incubator-gossip git commit: GOSSIP-32 Javadoc errors blocking release
Repository: incubator-gossip
Updated Branches:
refs/heads/master 5352dc57f -> 42e4ac786
GOSSIP-32 Javadoc errors blocking release
Project: http://git-wip-us.apache.org/repos/asf/incubator-gossip/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gossip/commit/42e4ac78
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gossip/tree/42e4ac78
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gossip/diff/42e4ac78
Branch: refs/heads/master
Commit: 42e4ac786d2c2515836b9d96a262342fcfc31d32
Parents: 5352dc5
Author: Edward Capriolo <ed...@gmail.com>
Authored: Wed Nov 9 13:49:30 2016 -0500
Committer: Edward Capriolo <ed...@gmail.com>
Committed: Wed Nov 9 13:49:30 2016 -0500
----------------------------------------------------------------------
pom.xml | 7 +++----
src/main/java/org/apache/gossip/GossipMember.java | 5 +++--
src/main/java/org/apache/gossip/GossipService.java | 16 +++++++++++-----
.../java/org/apache/gossip/LocalGossipMember.java | 1 +
4 files changed, 18 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/42e4ac78/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 0c5d4e2..e4c82df 100644
--- a/pom.xml
+++ b/pom.xml
@@ -16,8 +16,7 @@
See the License for the specific language governing permissions and
limitations under the License.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
@@ -29,7 +28,7 @@
<groupId>org.apache.gossip</groupId>
<artifactId>gossip</artifactId>
<name>gossip</name>
- <version>0.1.0-incubating-SNAPSHOT</version>
+ <version>0.1.0-incubating</version>
<packaging>jar</packaging>
<description>A peer to peer cluster discovery service</description>
<url>http://gossip.incubator.apache.org/</url>
@@ -66,7 +65,7 @@
<connection>scm:git:git@github.com:apache/incubator-gossip.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-gossip.git</developerConnection>
<url>scm:git:git@github.com:apache/incubator-gossip.git</url>
- <tag>HEAD</tag>
+ <tag>gossip-0.1.0-incubating</tag>
</scm>
<issueManagement>
http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/42e4ac78/src/main/java/org/apache/gossip/GossipMember.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/gossip/GossipMember.java b/src/main/java/org/apache/gossip/GossipMember.java
index 58b1e91..7ae4d81 100644
--- a/src/main/java/org/apache/gossip/GossipMember.java
+++ b/src/main/java/org/apache/gossip/GossipMember.java
@@ -23,7 +23,6 @@ import java.net.URI;
/**
* A abstract class representing a gossip member.
*
- * @author joshclemm, harmenw
*/
public abstract class GossipMember implements Comparable<GossipMember> {
@@ -44,6 +43,8 @@ public abstract class GossipMember implements Comparable<GossipMember> {
/**
* Constructor.
*
+ * @param clusterName
+ * The name of the cluster
* @param uri
* A URI object containing IP/hostname and port
* @param heartbeat
@@ -69,7 +70,7 @@ public abstract class GossipMember implements Comparable<GossipMember> {
/**
- * The member address in the form IP/host:port Similar to the toString in
+ * @return The member address in the form IP/host:port Similar to the toString in
* {@link InetSocketAddress}
*/
public String getAddress() {
http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/42e4ac78/src/main/java/org/apache/gossip/GossipService.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/gossip/GossipService.java b/src/main/java/org/apache/gossip/GossipService.java
index e50f260..80c01ca 100644
--- a/src/main/java/org/apache/gossip/GossipService.java
+++ b/src/main/java/org/apache/gossip/GossipService.java
@@ -84,8 +84,9 @@ public class GossipService {
}
/**
- * Gossip data in a namespace that is per-node { node-id { key->value } }
+ * Gossip data in a namespace that is per-node { node-id { key, value } }
* @param message
+ * message to be gossip'ed across the cluster
*/
public void gossipPerNodeData(GossipDataMessage message){
gossipManager.gossipPerNodeData(message);
@@ -93,17 +94,21 @@ public class GossipService {
/**
* Retrieve per-node gossip data by key
+ *
* @param nodeId
+ * the id of the node that owns the data
* @param key
- * @return return the value if found or null if not found or expired
+ * the key in the per-node map to find the data
+ * @return the value if found or null if not found or expired
*/
public GossipDataMessage findPerNodeData(String nodeId, String key){
return getGossipManager().findPerNodeGossipData(nodeId, key);
}
/**
- * Gossip shared data
+ *
* @param message
+ * Shared data to gossip around the cluster
*/
public void gossipSharedData(SharedGossipDataMessage message){
gossipManager.gossipSharedData(message);
@@ -111,8 +116,9 @@ public class GossipService {
/**
*
- * @param key the key to search for
- * @return
+ * @param key
+ * the key to search for
+ * @return the value associated with given key
*/
public SharedGossipDataMessage findSharedData(String key){
return getGossipManager().findSharedGossipData(key);
http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/42e4ac78/src/main/java/org/apache/gossip/LocalGossipMember.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/gossip/LocalGossipMember.java b/src/main/java/org/apache/gossip/LocalGossipMember.java
index d7e9f4e..97f4ab6 100644
--- a/src/main/java/org/apache/gossip/LocalGossipMember.java
+++ b/src/main/java/org/apache/gossip/LocalGossipMember.java
@@ -37,6 +37,7 @@ public class LocalGossipMember extends GossipMember {
* @param uri
* The uri of the member
* @param id
+ * id of the node
* @param heartbeat
* The current heartbeat.
* @param notificationListener