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