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