class GRPC::Kit::Workers

Public Instance Methods

list() click to toggle source
# 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) click to toggle source
# 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