Class: Mongoriver::Stream

Inherits:
Object
  • Object
show all
Includes:
Assertions, Logging
Defined in:
lib/mongoriver/stream.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Assertions

#assert

Methods included from Logging

#log

Constructor Details

#initialize(tailer, outlet) ⇒ Stream

Returns a new instance of Stream.



8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/mongoriver/stream.rb', line 8

def initialize(tailer, outlet)
  assert(tailer.is_a?(Tailer),
         "tailer must be a subclass/instance of Tailer")
  assert(outlet.is_a?(AbstractOutlet),
         "outlet must be a subclass (or instance) of AbstractOutlet")

  @tailer = tailer
  @outlet = outlet
  @stop = false
  @stats = {}
end

Instance Attribute Details

#outlet ⇒ Object

Returns the value of attribute outlet.



6
7
8
 
# File 'lib/mongoriver/stream.rb', line 6

def outlet
  @outlet
end

#tailer ⇒ Object

Returns the value of attribute tailer.



6
7
8
 
# File 'lib/mongoriver/stream.rb', line 6

def tailer
  @tailer
end

Instance Method Details

#run_forever(starting_timestamp = nil) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/mongoriver/stream.rb', line 24

def run_forever(starting_timestamp=nil)
  if starting_timestamp
    @tailer.tail(:from => optime_from_ts(starting_timestamp))
  else
    @tailer.tail
  end

  until @stop
    @tailer.stream do |op|
      handle_op(op)
    end
  end
end

#stats ⇒ Object 



20
21
22
 
# File 'lib/mongoriver/stream.rb', line 20

def stats
  @stats
end

#stop ⇒ Object 



38
39
40
41
 
# File 'lib/mongoriver/stream.rb', line 38

def stop
  @stop = true
  @tailer.stop
end