class Concord::Thrift::BoltProxyService::Processor
Public Instance Methods
process_registerWithScheduler(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 81 def process_registerWithScheduler(seqid, iprot, oprot) args = read_args(iprot, RegisterWithScheduler_args) @handler.registerWithScheduler(args.meta) return end
process_updateSchedulerAddress(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 70 def process_updateSchedulerAddress(seqid, iprot, oprot) args = read_args(iprot, UpdateSchedulerAddress_args) result = UpdateSchedulerAddress_result.new() begin @handler.updateSchedulerAddress(args.e) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'updateSchedulerAddress', seqid) end
process_updateTopology(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 59 def process_updateTopology(seqid, iprot, oprot) args = read_args(iprot, UpdateTopology_args) result = UpdateTopology_result.new() begin @handler.updateTopology(args.topology) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'updateTopology', seqid) end