Class: Impala::Protocol::StateStoreService::Processor

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

Instance Method Summary collapse

Instance Method Details

#process_RegisterService(seqid, iprot, oprot) ⇒ Object 



81
82
83
84
85
86
 
# File 'lib/impala/protocol/state_store_service.rb', line 81

def process_RegisterService(seqid, iprot, oprot)
  args = read_args(iprot, RegisterService_args)
  result = RegisterService_result.new()
  result.success = @handler.RegisterService(args.request)
  write_result(result, oprot, 'RegisterService', seqid)
end

#process_RegisterSubscription(seqid, iprot, oprot) ⇒ Object 



95
96
97
98
99
100
 
# File 'lib/impala/protocol/state_store_service.rb', line 95

def process_RegisterSubscription(seqid, iprot, oprot)
  args = read_args(iprot, RegisterSubscription_args)
  result = RegisterSubscription_result.new()
  result.success = @handler.RegisterSubscription(args.request)
  write_result(result, oprot, 'RegisterSubscription', seqid)
end

#process_UnregisterService(seqid, iprot, oprot) ⇒ Object 



88
89
90
91
92
93
 
# File 'lib/impala/protocol/state_store_service.rb', line 88

def process_UnregisterService(seqid, iprot, oprot)
  args = read_args(iprot, UnregisterService_args)
  result = UnregisterService_result.new()
  result.success = @handler.UnregisterService(args.request)
  write_result(result, oprot, 'UnregisterService', seqid)
end

#process_UnregisterSubscription(seqid, iprot, oprot) ⇒ Object 



102
103
104
105
106
107
 
# File 'lib/impala/protocol/state_store_service.rb', line 102

def process_UnregisterSubscription(seqid, iprot, oprot)
  args = read_args(iprot, UnregisterSubscription_args)
  result = UnregisterSubscription_result.new()
  result.success = @handler.UnregisterSubscription(args.request)
  write_result(result, oprot, 'UnregisterSubscription', seqid)
end