Class: Impala::Protocol::StateStoreService::Client
- Inherits:
-
Object
- Object
- Impala::Protocol::StateStoreService::Client
- Includes:
- Thrift::Client
- Defined in:
- lib/impala/protocol/state_store_service.rb
Instance Method Summary collapse
- #recv_RegisterService ⇒ Object
- #recv_RegisterSubscription ⇒ Object
- #recv_UnregisterService ⇒ Object
- #recv_UnregisterSubscription ⇒ Object
- #RegisterService(request) ⇒ Object
- #RegisterSubscription(request) ⇒ Object
- #send_RegisterService(request) ⇒ Object
- #send_RegisterSubscription(request) ⇒ Object
- #send_UnregisterService(request) ⇒ Object
- #send_UnregisterSubscription(request) ⇒ Object
- #UnregisterService(request) ⇒ Object
- #UnregisterSubscription(request) ⇒ Object
Instance Method Details
#recv_RegisterService ⇒ Object
25 26 27 28 29 |
# File 'lib/impala/protocol/state_store_service.rb', line 25 def recv_RegisterService() result = (RegisterService_result) return result.success unless result.success.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RegisterService failed: unknown result') end |
#recv_RegisterSubscription ⇒ Object
55 56 57 58 59 |
# File 'lib/impala/protocol/state_store_service.rb', line 55 def recv_RegisterSubscription() result = (RegisterSubscription_result) return result.success unless result.success.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RegisterSubscription failed: unknown result') end |
#recv_UnregisterService ⇒ Object
40 41 42 43 44 |
# File 'lib/impala/protocol/state_store_service.rb', line 40 def recv_UnregisterService() result = (UnregisterService_result) return result.success unless result.success.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'UnregisterService failed: unknown result') end |
#recv_UnregisterSubscription ⇒ Object
70 71 72 73 74 |
# File 'lib/impala/protocol/state_store_service.rb', line 70 def recv_UnregisterSubscription() result = (UnregisterSubscription_result) return result.success unless result.success.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'UnregisterSubscription failed: unknown result') end |
#RegisterService(request) ⇒ Object
16 17 18 19 |
# File 'lib/impala/protocol/state_store_service.rb', line 16 def RegisterService(request) send_RegisterService(request) return recv_RegisterService() end |
#RegisterSubscription(request) ⇒ Object
46 47 48 49 |
# File 'lib/impala/protocol/state_store_service.rb', line 46 def RegisterSubscription(request) send_RegisterSubscription(request) return recv_RegisterSubscription() end |
#send_RegisterService(request) ⇒ Object
21 22 23 |
# File 'lib/impala/protocol/state_store_service.rb', line 21 def send_RegisterService(request) ('RegisterService', RegisterService_args, :request => request) end |
#send_RegisterSubscription(request) ⇒ Object
51 52 53 |
# File 'lib/impala/protocol/state_store_service.rb', line 51 def send_RegisterSubscription(request) ('RegisterSubscription', RegisterSubscription_args, :request => request) end |
#send_UnregisterService(request) ⇒ Object
36 37 38 |
# File 'lib/impala/protocol/state_store_service.rb', line 36 def send_UnregisterService(request) ('UnregisterService', UnregisterService_args, :request => request) end |
#send_UnregisterSubscription(request) ⇒ Object
66 67 68 |
# File 'lib/impala/protocol/state_store_service.rb', line 66 def send_UnregisterSubscription(request) ('UnregisterSubscription', UnregisterSubscription_args, :request => request) end |
#UnregisterService(request) ⇒ Object
31 32 33 34 |
# File 'lib/impala/protocol/state_store_service.rb', line 31 def UnregisterService(request) send_UnregisterService(request) return recv_UnregisterService() end |
#UnregisterSubscription(request) ⇒ Object
61 62 63 64 |
# File 'lib/impala/protocol/state_store_service.rb', line 61 def UnregisterSubscription(request) send_UnregisterSubscription(request) return recv_UnregisterSubscription() end |