Class: GRPC::Kit::Workers

Inherits:
Thor
  • Object
show all
Defined in:
lib/grpc/kit/cli.rb

Instance Method Summary collapse

Instance Method Details

#list ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/grpc/kit/cli.rb', line 17

def list
  Dir.glob('lib/workers/**/*') do |file|
    require File.basename(file, File.extname(file))
  end

  workers = GRPC::Kit::Queue::Worker.list
  if workers.empty?
    puts 'No available workers'
  else
    workers.each do |worker|
      puts " - #{worker}"
    end
  end
end

#runner(worker, topic) ⇒ Object 



10
11
12
13
14
 
# File 'lib/grpc/kit/cli.rb', line 10

def runner(worker, topic)
  require worker.gsub(/(.)([A-Z])/,'\1_\2').downcase

  Queue::Worker::Runner.run! topic: topic, worker: worker
end