Class: Concord::Thrift::BoltProxyService::Client

Inherits:
MutableEphemeralStateService::Client show all
Includes:
Thrift::Client
Defined in:
lib/gen-rb/bolt_proxy_service.rb

Instance Method Summary collapse

Methods inherited from MutableEphemeralStateService::Client

#getState, #recv_getState, #recv_setState, #send_getState, #send_setState, #setState

Instance Method Details

#recv_updateSchedulerAddress ⇒ Object 



41
42
43
44
45
 
# 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 ⇒ Object 



26
27
28
29
30
 
# 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) ⇒ Object 



47
48
49
 
# File 'lib/gen-rb/bolt_proxy_service.rb', line 47

def registerWithScheduler(meta)
  send_registerWithScheduler(meta)
end

#send_registerWithScheduler(meta) ⇒ Object 



51
52
53
 
# 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) ⇒ Object 



37
38
39
 
# 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) ⇒ Object 



22
23
24
 
# File 'lib/gen-rb/bolt_proxy_service.rb', line 22

def send_updateTopology(topology)
  send_message('updateTopology', UpdateTopology_args, :topology => topology)
end

#updateSchedulerAddress(e) ⇒ Object 



32
33
34
35
 
# File 'lib/gen-rb/bolt_proxy_service.rb', line 32

def updateSchedulerAddress(e)
  send_updateSchedulerAddress(e)
  recv_updateSchedulerAddress()
end

#updateTopology(topology) ⇒ Object 



17
18
19
20
 
# File 'lib/gen-rb/bolt_proxy_service.rb', line 17

def updateTopology(topology)
  send_updateTopology(topology)
  recv_updateTopology()
end