Contents

require 'spec_helper'

describe "nodelets" do
  before(:all) do
    nodelets = {}
    
    @node = run_reactor do
      routes_for :distributor do
        route :output, :zmq_push, rand_addr, :bind
      end
      routes_for :worker_cluster do
        route :worker1,     :zmq_pull, distributor_output.address, :connect
        route :worker2,     :zmq_pull, distributor_output.address, :connect
      end
      
      nodelet :distributor do |d|
        nodelets[:distributor] = d
      end
      
      nodelet :worker_cluster do |wc|
        nodelets[:worker_cluster] = wc
      end
    end
    
    @nodelets = nodelets
  end
  
  it "should create the nodelets" do
    @nodelets.length.should == 2
  end
  
  it "should pass a DripDrop::Node::Nodelet to the block" do
    @nodelets.values.each do |nlet|
      nlet.should be_instance_of(DripDrop::Node::Nodelet)
    end
  end
    
  it "should give access to the full routing table to nodelets" do
    @node.routing.each do |route_name,handler|
      @nodelets.values.each do |nlet|
        nlet.send(route_name).should == handler
      end
    end
  end
  
  it "should define prefix-less versions of nodelet specific routes" do
    {
      @nodelets[:worker_cluster] => {:worker1 => :worker_cluster_worker1, 
                                     :worker2 => :worker_cluster_worker2},
      @nodelets[:distributor]    => {:output  => :distributor_output}
    }.each do |nlet, mapping|
      mapping.each do |short,long|
        nlet.send(short).should == nlet.send(long)
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
dripdrop-0.6.0	spec/node/nodelet_spec.rb
dripdrop-0.5.0	spec/node/nodelet_spec.rb
dripdrop-0.4.2	spec/node/nodelet_spec.rb
dripdrop-0.4.1	spec/node/nodelet_spec.rb
dripdrop-0.4.0	spec/node/nodelet_spec.rb