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