Rename mongo-livedata to redis-live in tests & stats

meteor · Jun 11, 2014 · 3bd1164 · 3bd1164
1 parent 25f71dd
commit 3bd1164
Show file tree

Hide file tree

Showing 7 changed files with 59 additions and 59 deletions.
diff --git a/doc_fetcher_tests.js b/doc_fetcher_tests.js
@@ -1,7 +1,7 @@
 var Fiber = Npm.require('fibers');
 var Future = Npm.require('fibers/future');
 
-testAsyncMulti("mongo-livedata - doc fetcher", [
+testAsyncMulti("redis-livedata - doc fetcher", [
   function (test, expect) {
     var self = this;
     var collName = "docfetcher-" + Random.id();

diff --git a/observe_multiplex.js b/observe_multiplex.js
@@ -7,7 +7,7 @@ ObserveMultiplexer = function (options) {
     throw Error("must specified ordered");
 
   Package.facts && Package.facts.Facts.incrementServerFact(
-    "mongo-livedata", "observe-multiplexers", 1);
+    "redis-livedata", "observe-multiplexers", 1);
 
   self._ordered = options.ordered;
   self._onStop = options.onStop || function () {};
@@ -42,7 +42,7 @@ _.extend(ObserveMultiplexer.prototype, {
     ++self._addHandleTasksScheduledButNotPerformed;
 
     Package.facts && Package.facts.Facts.incrementServerFact(
-      "mongo-livedata", "observe-handles", 1);
+      "redis-livedata", "observe-handles", 1);
 
     self._queue.runTask(function () {
       self._handles[handle._id] = handle;
@@ -73,7 +73,7 @@ _.extend(ObserveMultiplexer.prototype, {
     delete self._handles[id];
 
     Package.facts && Package.facts.Facts.incrementServerFact(
-      "mongo-livedata", "observe-handles", -1);
+      "redis-livedata", "observe-handles", -1);
 
     if (_.isEmpty(self._handles) &&
         self._addHandleTasksScheduledButNotPerformed === 0) {
@@ -91,7 +91,7 @@ _.extend(ObserveMultiplexer.prototype, {
     // callbacks and removes us from the connection's dictionary).
     self._onStop();
     Package.facts && Package.facts.Facts.incrementServerFact(
-      "mongo-livedata", "observe-multiplexers", -1);
+      "redis-livedata", "observe-multiplexers", -1);
 
     // Cause future addHandleAndSendInitialAdds calls to throw (but the onStop
     // callback should make our connection forget about us).

diff --git a/oplog_observe_driver.js b/oplog_observe_driver.js
@@ -77,7 +77,7 @@ OplogObserveDriver = function (options) {
   self._stopHandles = [];
 
   Package.facts && Package.facts.Facts.incrementServerFact(
-    "mongo-livedata", "observe-drivers-oplog", 1);
+    "redis-livedata", "observe-drivers-oplog", 1);
 
   self._registerPhaseChange(PHASE.QUERYING);
 
@@ -810,7 +810,7 @@ _.extend(OplogObserveDriver.prototype, {
     self._listenersHandle = null;
 
     Package.facts && Package.facts.Facts.incrementServerFact(
-      "mongo-livedata", "observe-drivers-oplog", -1);
+      "redis-livedata", "observe-drivers-oplog", -1);
   },
 
   _registerPhaseChange: function (phase) {
@@ -820,7 +820,7 @@ _.extend(OplogObserveDriver.prototype, {
     if (self._phase) {
       var timeDiff = now - self._phaseStartTime;
       Package.facts && Package.facts.Facts.incrementServerFact(
-        "mongo-livedata", "time-spent-in-" + self._phase + "-phase", timeDiff);
+        "redis-livedata", "time-spent-in-" + self._phase + "-phase", timeDiff);
     }
 
     self._phase = phase;

diff --git a/oplog_tailing.js b/oplog_tailing.js
@@ -39,7 +39,7 @@ OplogHandle = function (oplogUrl, dbName) {
   self._tailHandle = null;
   self._readyFuture = new Future();
   self._crossbar = new DDPServer._Crossbar({
-    factPackage: "mongo-livedata", factName: "oplog-watchers"
+    factPackage: "redis-livedata", factName: "oplog-watchers"
   });
   self._lastProcessedTS = null;
   self._baseOplogSelector = {

diff --git a/oplog_tests.js b/oplog_tests.js
@@ -1,6 +1,6 @@
 var OplogCollection = new Meteor.RedisCollection("oplog-" + Random.id());
 
-Tinytest.add("mongo-livedata - oplog - cursorSupported", function (test) {
+Tinytest.add("redis-livedata - oplog - cursorSupported", function (test) {
   var oplogEnabled =
         !!RedisInternals.defaultRemoteCollectionDriver().mongo._oplogHandle;
 

diff --git a/polling_observe_driver.js b/polling_observe_driver.js
@@ -71,7 +71,7 @@ PollingObserveDriver = function (options) {
   self._unthrottledEnsurePollIsScheduled();
 
   Package.facts && Package.facts.Facts.incrementServerFact(
-    "mongo-livedata", "observe-drivers-polling", 1);
+    "redis-livedata", "observe-drivers-polling", 1);
 };
 
 _.extend(PollingObserveDriver.prototype, {
@@ -188,6 +188,6 @@ _.extend(PollingObserveDriver.prototype, {
     self._stopped = true;
     _.each(self._stopCallbacks, function (c) { c(); });
     Package.facts && Package.facts.Facts.incrementServerFact(
-      "mongo-livedata", "observe-drivers-polling", -1);
+      "redis-livedata", "observe-drivers-polling", -1);
   }
 });