Contents

def mq
  @mq ||= Skynet::MessageQueue.new
end                       

def stats
  mq.stats
end

def increment_worker_version
  mq.increment_worker_version
end

def get_worker_version
  mq.get_worker_version
end

def set_worker_version(*args)
  mq.set_worker_version(*args)
end

def manager
  @manager ||= DRbObject.new(nil,Skynet::CONFIG[:SKYNET_LOCAL_MANAGER_URL])
end

def add_lib(lib)
  manager.required_libs << File.expand_path(lib)
  manager.restart_workers
end                      

def restart_workers
  manager.restart_workers
end

def add_workers(num)
  manager.add_workers(num)
end

def remove_workers(num)
  manager.remove_workers(num)
end

# ===============
# = Doesnt work =
# ===============
# def help
#   puts <<-HELP
#    mq
#    stats
#    increment_worker_version
#    get_worker_version
#    set_worker_version(version)
#    manager
#    add_lib(library_to_include)  -- forces a restart
#    restart_workers
#    add_workers(number_of_workers)
#    remove_workers(number_of_workers)
#   HELP
# end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
skynet-0.9.1	lib/skynet/skynet_console_helper.rb