class Concord::Thrift::BoltProxyService::Client

Public Instance Methods

recv_updateSchedulerAddress() click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 41
def recv_updateSchedulerAddress()
  result = receive_message(UpdateSchedulerAddress_result)
  raise result.e unless result.e.nil?
  return
end
recv_updateTopology() click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 26
def recv_updateTopology()
  result = receive_message(UpdateTopology_result)
  raise result.e unless result.e.nil?
  return
end
registerWithScheduler(meta) click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 47
def registerWithScheduler(meta)
  send_registerWithScheduler(meta)
end
send_registerWithScheduler(meta) click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 51
def send_registerWithScheduler(meta)
  send_oneway_message('registerWithScheduler', RegisterWithScheduler_args, :meta => meta)
end
send_updateSchedulerAddress(e) click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 37
def send_updateSchedulerAddress(e)
  send_message('updateSchedulerAddress', UpdateSchedulerAddress_args, :e => e)
end
send_updateTopology(topology) click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 22
def send_updateTopology(topology)
  send_message('updateTopology', UpdateTopology_args, :topology => topology)
end
updateSchedulerAddress(e) click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 32
def updateSchedulerAddress(e)
  send_updateSchedulerAddress(e)
  recv_updateSchedulerAddress()
end
updateTopology(topology) click to toggle source
# File lib/gen-rb/bolt_proxy_service.rb, line 17
def updateTopology(topology)
  send_updateTopology(topology)
  recv_updateTopology()
end