Contents

class FakeSlaveRPC

  def connection(host, port)
    @connections ||= {}
    @connections["#{host}:#{port}"] ||= Connection.new
  end

  class Connection

    def status=(val)
      @status = val
    end

    def status
      @status ||= {"joined" => false, "running_shards" => [], "available_shards" => {}}
    end

    def started_shards
      @started_shards ||= []
    end

    def start_shard(shard_number)
      started_shards << shard_number
    end

    def stopped_shards
      @stopped_shards ||= []
    end

    def stop_shard(shard_number)
      stopped_shards << shard_number
    end

  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
redis_ring-0.1.3	spec/fakes/fake_slave_rpc.rb
redis_ring-0.1.2	spec/fakes/fake_slave_rpc.rb
redis_ring-0.1.1	spec/fakes/fake_slave_rpc.rb
redis_ring-0.1.0	spec/fakes/fake_slave_rpc.rb