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