class Concord::Thrift::BoltSchedulerService::Processor

Public Instance Methods

process_deployComputation(seqid, iprot, oprot) click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 98
def process_deployComputation(seqid, iprot, oprot)
  args = read_args(iprot, DeployComputation_args)
  result = DeployComputation_result.new()
  begin
    @handler.deployComputation(args.request)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'deployComputation', seqid)
end
process_getComputationSlug(seqid, iprot, oprot) click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 109
def process_getComputationSlug(seqid, iprot, oprot)
  args = read_args(iprot, GetComputationSlug_args)
  result = GetComputationSlug_result.new()
  begin
    result.success = @handler.getComputationSlug(args.computationName)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'getComputationSlug', seqid)
end
process_killTask(seqid, iprot, oprot) click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 142
def process_killTask(seqid, iprot, oprot)
  args = read_args(iprot, KillTask_args)
  result = KillTask_result.new()
  begin
    @handler.killTask(args.taskId)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'killTask', seqid)
end
process_registerComputation(seqid, iprot, oprot) click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 120
def process_registerComputation(seqid, iprot, oprot)
  args = read_args(iprot, RegisterComputation_args)
  result = RegisterComputation_result.new()
  begin
    result.success = @handler.registerComputation(args.computation)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'registerComputation', seqid)
end
process_scaleComputation(seqid, iprot, oprot) click to toggle source
# File lib/gen-rb/bolt_scheduler_service.rb, line 131
def process_scaleComputation(seqid, iprot, oprot)
  args = read_args(iprot, ScaleComputation_args)
  result = ScaleComputation_result.new()
  begin
    @handler.scaleComputation(args.computationName, args.instances)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'scaleComputation', seqid)
end