bin/agent bin/mapper docs/JamesRH_Lisa.pdf lib/nanite/actor.rb lib/nanite/agent.rb lib/nanite/answer.rb lib/nanite/dispatcher.rb lib/nanite/mapper.rb lib/nanite/op.rb lib/nanite/reducer.rb lib/nanite/resource.rb lib/nanite/result.rb @@ -1,6 +1,34 @@ +require 'rubygems' +require 'amqp' +require 'mq' +$:.unshift File.dirname(__FILE__) +require 'nanite/resource' +require 'nanite/result' +require 'nanite/op' +require 'nanite/answer' + module Nanite class << self attr_accessor :identity + + attr_accessor :default_resources + + def mapper + Thread.current[:mapper] ||= MQ.new.rpc('mapper') + end + + def amq + Thread.current[:mq] ||= MQ.new + end + + def pending + @pending ||= {} + end + + def results + @results ||= {} + end + def gen_token values = [ rand(0x0010000), lib/nanite.rb lib/actor.rb lib/agent.rb lib/answer.rb lib/dispatcher.rb lib/mapper.rb lib/op.rb lib/reducer.rb lib/resource.rb lib/result.rb 2980915a3e266071bd61a6777387db75634467eb Ezra Zygmuntowicz ez@engineyard.com http://github.com/ezmobius/nanite/commit/bbc651df633ac2a9c599e3bb3f9cea5acbd5cc2d bbc651df633ac2a9c599e3bb3f9cea5acbd5cc2d 2008-08-12T16:37:13-07:00 2008-08-12T16:37:13-07:00 reformat repo layout 090c12c23671d87b61afc131c2ec75ff26f96af3 Ezra Zygmuntowicz ez@engineyard.com