Try omf rete

try_rete.rb

require 'pp' 
require 'omf_rete/store' 
 
N = 10 
 
s = OMF::Rete::Store.create 3 
(1..N).each do |i| 
  s.addTuple(["node_#{i}", 'status', (i % 2) == 0 ? 'ok' : 'failure']) 
end 
 
#tset = OMF::Rete::Store.create 3 
#s.registerTSet(tset, [:node?, 'status', 'ok']) 
pp s.find([:_, 'status', :_]).size 
pp s.find([:_, 'status', 'ok']).size 

s.subscribe(:check_nodes, [[:node?, 'status', 'ok']]) do |m| 
  puts "#{m[0]} ok" 
end

puts '...'
s.addTuple(["node_#{10 + 2}", 'status', 'ok'])