class Concord::Thrift::BoltSchedulerService::Client
Public Instance Methods
deployComputation(request)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 16 def deployComputation(request) send_deployComputation(request) recv_deployComputation() end
getComputationSlug(computationName)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 31 def getComputationSlug(computationName) send_getComputationSlug(computationName) return recv_getComputationSlug() end
killTask(taskId)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 78 def killTask(taskId) send_killTask(taskId) recv_killTask() end
recv_deployComputation()
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 25 def recv_deployComputation() result = receive_message(DeployComputation_result) raise result.e unless result.e.nil? return end
recv_getComputationSlug()
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 40 def recv_getComputationSlug() result = receive_message(GetComputationSlug_result) return result.success unless result.success.nil? raise result.e unless result.e.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getComputationSlug failed: unknown result') end
recv_killTask()
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 87 def recv_killTask() result = receive_message(KillTask_result) raise result.e unless result.e.nil? return end
recv_registerComputation()
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 56 def recv_registerComputation() result = receive_message(RegisterComputation_result) return result.success unless result.success.nil? raise result.e unless result.e.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'registerComputation failed: unknown result') end
recv_scaleComputation()
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 72 def recv_scaleComputation() result = receive_message(ScaleComputation_result) raise result.e unless result.e.nil? return end
registerComputation(computation)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 47 def registerComputation(computation) send_registerComputation(computation) return recv_registerComputation() end
scaleComputation(computationName, instances)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 63 def scaleComputation(computationName, instances) send_scaleComputation(computationName, instances) recv_scaleComputation() end
send_deployComputation(request)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 21 def send_deployComputation(request) send_message('deployComputation', DeployComputation_args, :request => request) end
send_getComputationSlug(computationName)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 36 def send_getComputationSlug(computationName) send_message('getComputationSlug', GetComputationSlug_args, :computationName => computationName) end
send_killTask(taskId)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 83 def send_killTask(taskId) send_message('killTask', KillTask_args, :taskId => taskId) end
send_registerComputation(computation)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 52 def send_registerComputation(computation) send_message('registerComputation', RegisterComputation_args, :computation => computation) end
send_scaleComputation(computationName, instances)
click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 68 def send_scaleComputation(computationName, instances) send_message('scaleComputation', ScaleComputation_args, :computationName => computationName, :instances => instances) end