Module: Skynet::ConsoleHelper

Defined in:
lib/skynet/console_helper.rb

Instance Method Summary collapse

Instance Method Details

#add_lib(lib) ⇒ Object



32
33
34
35
# File 'lib/skynet/console_helper.rb', line 32

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

#add_workers(num) ⇒ Object



41
42
43
# File 'lib/skynet/console_helper.rb', line 41

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

#get_worker_versionObject



20
21
22
# File 'lib/skynet/console_helper.rb', line 20

def get_worker_version
  mq.get_worker_version
end

#increment_worker_versionObject



16
17
18
# File 'lib/skynet/console_helper.rb', line 16

def increment_worker_version
  mq.increment_worker_version
end

#logObject

All of these commands can be run at the ‘skynet console’.



4
5
6
# File 'lib/skynet/console_helper.rb', line 4

def log
  Skynet::Logger.get
end

#managerObject



28
29
30
# File 'lib/skynet/console_helper.rb', line 28

def manager
  @manager ||= Skynet::Manager.get
end

#mqObject



8
9
10
# File 'lib/skynet/console_helper.rb', line 8

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

#remove_workers(num) ⇒ Object



45
46
47
# File 'lib/skynet/console_helper.rb', line 45

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

#restart_workersObject



37
38
39
# File 'lib/skynet/console_helper.rb', line 37

def restart_workers
  manager.restart_workers
end

#set_worker_version(*args) ⇒ Object



24
25
26
# File 'lib/skynet/console_helper.rb', line 24

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

#statsObject



12
13
14
# File 'lib/skynet/console_helper.rb', line 12

def stats
  mq.stats
end