Allowing a custom collection name for oplog tailing (some configs use…

… master/slave naming)
stripe-archive · Feb 28, 2013 · 2126492 · 2126492
1 parent f3f2a18
commit 2126492
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/mongoriver/tailer.rb b/lib/mongoriver/tailer.rb
@@ -3,10 +3,12 @@ class Tailer
     include Mongoriver::Logging
 
     attr_reader :upstream_conn
+    attr_reader :oplog
 
-    def initialize(upstreams, type)
+    def initialize(upstreams, type, oplog = "oplog.rs")
       @upstreams = upstreams
       @type = type
+      @oplog = oplog
       # This number seems high
       @conn_opts = {:op_timeout => 86400}
 
@@ -61,7 +63,7 @@ def parse_host_spec(host_spec)
     end
 
     def oplog_collection
-      @upstream_conn.db('local').collection('oplog.rs')
+      @upstream_conn.db('local').collection(oplog)
     end
 
     def tail_from(ts, opts = {})