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