class Concord::Thrift::ComputationService::Client
Public Instance Methods
boltMetadata()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 79 def boltMetadata() send_boltMetadata() return recv_boltMetadata() end
boltProcessRecords(records)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 47 def boltProcessRecords(records) send_boltProcessRecords(records) return recv_boltProcessRecords() end
boltProcessTimer(key, time)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 63 def boltProcessTimer(key, time) send_boltProcessTimer(key, time) return recv_boltProcessTimer() end
destroy()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 32 def destroy() send_destroy() recv_destroy() end
init()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 16 def init() send_init() return recv_init() end
recv_boltMetadata()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 88 def recv_boltMetadata() result = receive_message(BoltMetadata_result) return result.success unless result.success.nil? raise result.e unless result.e.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'boltMetadata failed: unknown result') end
recv_boltProcessRecords()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 56 def recv_boltProcessRecords() result = receive_message(BoltProcessRecords_result) return result.success unless result.success.nil? raise result.e unless result.e.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'boltProcessRecords failed: unknown result') end
recv_boltProcessTimer()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 72 def recv_boltProcessTimer() result = receive_message(BoltProcessTimer_result) return result.success unless result.success.nil? raise result.e unless result.e.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'boltProcessTimer failed: unknown result') end
recv_destroy()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 41 def recv_destroy() result = receive_message(Destroy_result) raise result.e unless result.e.nil? return end
recv_init()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 25 def recv_init() result = receive_message(Init_result) return result.success unless result.success.nil? raise result.e unless result.e.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'init failed: unknown result') end
send_boltMetadata()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 84 def send_boltMetadata() send_message('boltMetadata', BoltMetadata_args) end
send_boltProcessRecords(records)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 52 def send_boltProcessRecords(records) send_message('boltProcessRecords', BoltProcessRecords_args, :records => records) end
send_boltProcessTimer(key, time)
click to toggle source
# File lib/gen-rb/computation_service.rb, line 68 def send_boltProcessTimer(key, time) send_message('boltProcessTimer', BoltProcessTimer_args, :key => key, :time => time) end
send_destroy()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 37 def send_destroy() send_message('destroy', Destroy_args) end
send_init()
click to toggle source
# File lib/gen-rb/computation_service.rb, line 21 def send_init() send_message('init', Init_args) end