An /admin/gossip/status endpoint

esatterwhite · Sep 30, 2015 · 77ebf04 · 77ebf04
1 parent 387f81d
commit 77ebf04
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 0 deletions.
diff --git a/lib/swim/gossip.js b/lib/swim/gossip.js
@@ -51,6 +51,10 @@ Gossip.prototype.computeProtocolRate = function computeProtocolRate() {
     return Math.max(observed, this.minProtocolPeriod);
 };
 
+Gossip.prototype.getStatus = function getStatus() {
+    return this.isStopped ? Gossip.Status.Stopped : Gossip.Status.Started;
+};
+
 Gossip.prototype.run = function run() {
     var self = this;
 
@@ -135,4 +139,9 @@ Gossip.Defaults = {
     minProtocolPeriod: 200
 };
 
+Gossip.Status = {
+    Started: 'started',
+    Stopped: 'stopped'
+};
+
 module.exports = Gossip;
diff --git a/server/admin/gossip.js b/server/admin/gossip.js
@@ -48,6 +48,14 @@ function createGossipTickHandler(ringpop) {
     };
 }
 
+function createGossipStatusHandler(ringpop) {
+    return function handleGossipStatus(arg1, arg2, hostInfo, callback) {
+        callback(null, null, JSON.stringify({
+            status: ringpop.gossip.getStatus()
+        }));
+    };
+}
+
 module.exports = {
     gossipStart: {
         endpoint: '/admin/gossip/start',
@@ -60,5 +68,9 @@ module.exports = {
     gossipTick: {
         endpoint: '/admin/gossip/tick',
         handler: createGossipTickHandler
+    },
+    gossipStatus: {
+        endpoint: '/admin/gossip/status',
+        handler: createGossipStatusHandler
     }
 };