class Oplogjam::Oplog
Attributes
client[R]
Public Class Methods
new(client)
click to toggle source
# File lib/oplogjam/oplog.rb, line 7 def initialize(client) @client = client end
Public Instance Methods
operations(query = {})
click to toggle source
# File lib/oplogjam/oplog.rb, line 11 def operations(query = {}) Enumerator.new do |yielder| cursor = client.use(LOCAL)[OPLOG].find(query, cursor_type: :tailable_await).no_cursor_timeout cursor.each do |document| yielder << Operation.from(document) end end end