Class: Concord::Thrift::ComputationService::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/gen-rb/computation_service.rb

Instance Method Summary collapse

Instance Method Details

#boltMetadata ⇒ Object 



79
80
81
82
 
# File 'lib/gen-rb/computation_service.rb', line 79

def boltMetadata()
  send_boltMetadata()
  return recv_boltMetadata()
end

#boltProcessRecords(records) ⇒ Object 



47
48
49
50
 
# File 'lib/gen-rb/computation_service.rb', line 47

def boltProcessRecords(records)
  send_boltProcessRecords(records)
  return recv_boltProcessRecords()
end

#boltProcessTimer(key, time) ⇒ Object 



63
64
65
66
 
# File 'lib/gen-rb/computation_service.rb', line 63

def boltProcessTimer(key, time)
  send_boltProcessTimer(key, time)
  return recv_boltProcessTimer()
end

#destroy ⇒ Object 



32
33
34
35
 
# File 'lib/gen-rb/computation_service.rb', line 32

def destroy()
  send_destroy()
  recv_destroy()
end

#init ⇒ Object 



16
17
18
19
 
# File 'lib/gen-rb/computation_service.rb', line 16

def init()
  send_init()
  return recv_init()
end

#recv_boltMetadata ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


88
89
90
91
92
93
 
# 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 ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


56
57
58
59
60
61
 
# 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 ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


72
73
74
75
76
77
 
# 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 ⇒ Object 



41
42
43
44
45
 
# 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 ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


25
26
27
28
29
30
 
# 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 ⇒ Object 



84
85
86
 
# File 'lib/gen-rb/computation_service.rb', line 84

def send_boltMetadata()
  send_message('boltMetadata', BoltMetadata_args)
end

#send_boltProcessRecords(records) ⇒ Object 



52
53
54
 
# 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) ⇒ Object 



68
69
70
 
# 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 ⇒ Object 



37
38
39
 
# File 'lib/gen-rb/computation_service.rb', line 37

def send_destroy()
  send_message('destroy', Destroy_args)
end

#send_init ⇒ Object 



21
22
23
 
# File 'lib/gen-rb/computation_service.rb', line 21

def send_init()
  send_message('init', Init_args)
end