Class: Pacer::Pipes::BloomFilter::RejectPipe

Inherits:
SideliningPipe
  • Object
show all
Defined in:
lib/pacer/pipe/bloomfilter_reject.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(false_pos_prob, expected_count, sideline_pipe = nil) ⇒ RejectPipe

Returns a new instance of RejectPipe.



38
39
40
41
 
# File 'lib/pacer/pipe/bloomfilter_reject.rb', line 38

def initialize(false_pos_prob, expected_count, sideline_pipe = nil)
  super(sideline_pipe)
  @filter = BloomFilter.new(false_pos_prob, expected_count)
end

Instance Attribute Details

#filter ⇒ Object

Returns the value of attribute filter.



36
37
38
 
# File 'lib/pacer/pipe/bloomfilter_reject.rb', line 36

def filter
  @filter
end

Instance Method Details

#accumulate ⇒ Object 



47
48
49
 
# File 'lib/pacer/pipe/bloomfilter_reject.rb', line 47

def accumulate
  @accumulate = true
end

#addAll(elements) ⇒ Object 



43
44
45
 
# File 'lib/pacer/pipe/bloomfilter_reject.rb', line 43

def addAll(elements)
  @filter.addAll(elements)
end