Class: Impala::Protocol::StateStoreService::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/impala/protocol/state_store_service.rb

Instance Method Summary collapse

Instance Method Details

#recv_RegisterService ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


25
26
27
28
29
 
# File 'lib/impala/protocol/state_store_service.rb', line 25

def recv_RegisterService()
  result = receive_message(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

Raises:

  • (::Thrift::ApplicationException) 


55
56
57
58
59
 
# File 'lib/impala/protocol/state_store_service.rb', line 55

def recv_RegisterSubscription()
  result = receive_message(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

Raises:

  • (::Thrift::ApplicationException) 


40
41
42
43
44
 
# File 'lib/impala/protocol/state_store_service.rb', line 40

def recv_UnregisterService()
  result = receive_message(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

Raises:

  • (::Thrift::ApplicationException) 


70
71
72
73
74
 
# File 'lib/impala/protocol/state_store_service.rb', line 70

def recv_UnregisterSubscription()
  result = receive_message(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)
  send_message('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)
  send_message('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)
  send_message('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)
  send_message('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