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