Class: Flock::Edges::FlockDB::Client

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

Instance Method Summary collapse

Instance Method Details

#contains(source_id, graph_id, destination_id) ⇒ Object 



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

def contains(source_id, graph_id, destination_id)
  send_contains(source_id, graph_id, destination_id)
  return recv_contains()
end

#count(operations) ⇒ Object 



111
112
113
114
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 111

def count(operations)
  send_count(operations)
  return recv_count()
end

#count2(queries) ⇒ Object 



64
65
66
67
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 64

def count2(queries)
  send_count2(queries)
  return recv_count2()
end

#execute(operations) ⇒ Object 



96
97
98
99
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 96

def execute(operations)
  send_execute(operations)
  recv_execute()
end

#get(source_id, graph_id, destination_id) ⇒ Object 



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

def get(source_id, graph_id, destination_id)
  send_get(source_id, graph_id, destination_id)
  return recv_get()
end

#recv_contains ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


25
26
27
28
29
30
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 25

def recv_contains()
  result = receive_message(Contains_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'contains failed: unknown result')
end

#recv_count ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


120
121
122
123
124
125
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 120

def recv_count()
  result = receive_message(Count_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'count failed: unknown result')
end

#recv_count2 ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


73
74
75
76
77
78
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 73

def recv_count2()
  result = receive_message(Count2_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'count2 failed: unknown result')
end

#recv_execute ⇒ Object 



105
106
107
108
109
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 105

def recv_execute()
  result = receive_message(Execute_result)
  raise result.ex unless result.ex.nil?
  return
end

#recv_get ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


41
42
43
44
45
46
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 41

def recv_get()
  result = receive_message(Get_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get failed: unknown result')
end

#recv_select ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


136
137
138
139
140
141
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 136

def recv_select()
  result = receive_message(Select_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'select failed: unknown result')
end

#recv_select2 ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


57
58
59
60
61
62
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 57

def recv_select2()
  result = receive_message(Select2_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'select2 failed: unknown result')
end

#recv_select_edges ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


89
90
91
92
93
94
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 89

def recv_select_edges()
  result = receive_message(Select_edges_result)
  return result.success unless result.success.nil?
  raise result.ex unless result.ex.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'select_edges failed: unknown result')
end

#select(operations, page) ⇒ Object 



127
128
129
130
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 127

def select(operations, page)
  send_select(operations, page)
  return recv_select()
end

#select2(queries) ⇒ Object 



48
49
50
51
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 48

def select2(queries)
  send_select2(queries)
  return recv_select2()
end

#select_edges(queries) ⇒ Object 



80
81
82
83
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 80

def select_edges(queries)
  send_select_edges(queries)
  return recv_select_edges()
end

#send_contains(source_id, graph_id, destination_id) ⇒ Object 



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

def send_contains(source_id, graph_id, destination_id)
  send_message('contains', Contains_args, :source_id => source_id, :graph_id => graph_id, :destination_id => destination_id)
end

#send_count(operations) ⇒ Object 



116
117
118
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 116

def send_count(operations)
  send_message('count', Count_args, :operations => operations)
end

#send_count2(queries) ⇒ Object 



69
70
71
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 69

def send_count2(queries)
  send_message('count2', Count2_args, :queries => queries)
end

#send_execute(operations) ⇒ Object 



101
102
103
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 101

def send_execute(operations)
  send_message('execute', Execute_args, :operations => operations)
end

#send_get(source_id, graph_id, destination_id) ⇒ Object 



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

def send_get(source_id, graph_id, destination_id)
  send_message('get', Get_args, :source_id => source_id, :graph_id => graph_id, :destination_id => destination_id)
end

#send_select(operations, page) ⇒ Object 



132
133
134
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 132

def send_select(operations, page)
  send_message('select', Select_args, :operations => operations, :page => page)
end

#send_select2(queries) ⇒ Object 



53
54
55
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 53

def send_select2(queries)
  send_message('select2', Select2_args, :queries => queries)
end

#send_select_edges(queries) ⇒ Object 



85
86
87
 
# File 'lib/flock/gen-rb/flock_d_b.rb', line 85

def send_select_edges(queries)
  send_message('select_edges', Select_edges_args, :queries => queries)
end