Method: Mongo::Cluster::CursorReaper#initialize

Defined in:
lib/mongo/cluster/reapers/cursor_reaper.rb

#initialize(cluster) ⇒ CursorReaper

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Create a cursor reaper.

Parameters:

  • cluster (Cluster) —

    The cluster.

Since:

  • 2.3.0



42
43
44
45
46
47
48
 
# File 'lib/mongo/cluster/reapers/cursor_reaper.rb', line 42

def initialize(cluster)
  @cluster = cluster
  @to_kill = {}
  @active_cursor_ids = Set.new
  @mutex = Mutex.new
  @kill_spec_queue = Queue.new
end