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