Class: Blur::Blur::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/active_blur/thrift/blur.rb

Instance Method Summary collapse

Instance Method Details

#cancelQuery(table, uuid) ⇒ Object 



127
128
129
130
 
# File 'lib/active_blur/thrift/blur.rb', line 127

def cancelQuery(table, uuid)
  send_cancelQuery(table, uuid)
  recv_cancelQuery()
end

#controllerServerList ⇒ Object 



47
48
49
50
 
# File 'lib/active_blur/thrift/blur.rb', line 47

def controllerServerList()
  send_controllerServerList()
  return recv_controllerServerList()
end

#createTable(tableDescriptor) ⇒ Object 



268
269
270
271
 
# File 'lib/active_blur/thrift/blur.rb', line 268

def createTable(tableDescriptor)
  send_createTable(tableDescriptor)
  recv_createTable()
end

#currentQueries(table) ⇒ Object 



142
143
144
145
 
# File 'lib/active_blur/thrift/blur.rb', line 142

def currentQueries(table)
  send_currentQueries(table)
  return recv_currentQueries()
end

#describe(table) ⇒ Object 



95
96
97
98
 
# File 'lib/active_blur/thrift/blur.rb', line 95

def describe(table)
  send_describe(table)
  return recv_describe()
end

#disableTable(table) ⇒ Object 



298
299
300
301
 
# File 'lib/active_blur/thrift/blur.rb', line 298

def disableTable(table)
  send_disableTable(table)
  recv_disableTable()
end

#enableTable(table) ⇒ Object 



283
284
285
286
 
# File 'lib/active_blur/thrift/blur.rb', line 283

def enableTable(table)
  send_enableTable(table)
  recv_enableTable()
end

#fetchRow(table, selector) ⇒ Object 



222
223
224
225
 
# File 'lib/active_blur/thrift/blur.rb', line 222

def fetchRow(table, selector)
  send_fetchRow(table, selector)
  return recv_fetchRow()
end

#getTableStats(table) ⇒ Object 



174
175
176
177
 
# File 'lib/active_blur/thrift/blur.rb', line 174

def getTableStats(table)
  send_getTableStats(table)
  return recv_getTableStats()
end

#mutate(mutation) ⇒ Object 



238
239
240
241
 
# File 'lib/active_blur/thrift/blur.rb', line 238

def mutate(mutation)
  send_mutate(mutation)
  recv_mutate()
end

#mutateBatch(mutations) ⇒ Object 



253
254
255
256
 
# File 'lib/active_blur/thrift/blur.rb', line 253

def mutateBatch(mutations)
  send_mutateBatch(mutations)
  recv_mutateBatch()
end

#query(table, blurQuery) ⇒ Object 



111
112
113
114
 
# File 'lib/active_blur/thrift/blur.rb', line 111

def query(table, blurQuery)
  send_query(table, blurQuery)
  return recv_query()
end

#recordFrequency(table, columnFamily, columnName, value) ⇒ Object 



206
207
208
209
 
# File 'lib/active_blur/thrift/blur.rb', line 206

def recordFrequency(table, columnFamily, columnName, value)
  send_recordFrequency(table, columnFamily, columnName, value)
  return recv_recordFrequency()
end

#recv_cancelQuery ⇒ Object 



136
137
138
139
140
 
# File 'lib/active_blur/thrift/blur.rb', line 136

def recv_cancelQuery()
  result = receive_message(CancelQuery_result)
  raise result.ex unless result.ex.nil?
  return
end

#recv_controllerServerList ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


56
57
58
59
60
61
 
# File 'lib/active_blur/thrift/blur.rb', line 56

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

#recv_createTable ⇒ Object 



277
278
279
280
281
 
# File 'lib/active_blur/thrift/blur.rb', line 277

def recv_createTable()
  result = receive_message(CreateTable_result)
  raise result.ex unless result.ex.nil?
  return
end

#recv_currentQueries ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


151
152
153
154
155
156
 
# File 'lib/active_blur/thrift/blur.rb', line 151

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

#recv_describe ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


104
105
106
107
108
109
 
# File 'lib/active_blur/thrift/blur.rb', line 104

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

#recv_disableTable ⇒ Object 



307
308
309
310
311
 
# File 'lib/active_blur/thrift/blur.rb', line 307

def recv_disableTable()
  result = receive_message(DisableTable_result)
  raise result.ex unless result.ex.nil?
  return
end

#recv_enableTable ⇒ Object 



292
293
294
295
296
 
# File 'lib/active_blur/thrift/blur.rb', line 292

def recv_enableTable()
  result = receive_message(EnableTable_result)
  raise result.ex unless result.ex.nil?
  return
end

#recv_fetchRow ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


231
232
233
234
235
236
 
# File 'lib/active_blur/thrift/blur.rb', line 231

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

#recv_getTableStats ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


183
184
185
186
187
188
 
# File 'lib/active_blur/thrift/blur.rb', line 183

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

#recv_mutate ⇒ Object 



247
248
249
250
251
 
# File 'lib/active_blur/thrift/blur.rb', line 247

def recv_mutate()
  result = receive_message(Mutate_result)
  raise result.ex unless result.ex.nil?
  return
end

#recv_mutateBatch ⇒ Object 



262
263
264
265
266
 
# File 'lib/active_blur/thrift/blur.rb', line 262

def recv_mutateBatch()
  result = receive_message(MutateBatch_result)
  raise result.ex unless result.ex.nil?
  return
end

#recv_query ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


120
121
122
123
124
125
 
# File 'lib/active_blur/thrift/blur.rb', line 120

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

#recv_recordFrequency ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


215
216
217
218
219
220
 
# File 'lib/active_blur/thrift/blur.rb', line 215

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

#recv_removeTable ⇒ Object 



322
323
324
325
326
 
# File 'lib/active_blur/thrift/blur.rb', line 322

def recv_removeTable()
  result = receive_message(RemoveTable_result)
  raise result.ex unless result.ex.nil?
  return
end

#recv_schema ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


167
168
169
170
171
172
 
# File 'lib/active_blur/thrift/blur.rb', line 167

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

#recv_shardClusterList ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


24
25
26
27
28
29
 
# File 'lib/active_blur/thrift/blur.rb', line 24

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

#recv_shardServerLayout ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


72
73
74
75
76
77
 
# File 'lib/active_blur/thrift/blur.rb', line 72

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

#recv_shardServerList ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


40
41
42
43
44
45
 
# File 'lib/active_blur/thrift/blur.rb', line 40

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

#recv_tableList ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


88
89
90
91
92
93
 
# File 'lib/active_blur/thrift/blur.rb', line 88

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

#recv_terms ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


199
200
201
202
203
204
 
# File 'lib/active_blur/thrift/blur.rb', line 199

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

#removeTable(table, deleteIndexFiles) ⇒ Object 



313
314
315
316
 
# File 'lib/active_blur/thrift/blur.rb', line 313

def removeTable(table, deleteIndexFiles)
  send_removeTable(table, deleteIndexFiles)
  recv_removeTable()
end

#schema(table) ⇒ Object 



158
159
160
161
 
# File 'lib/active_blur/thrift/blur.rb', line 158

def schema(table)
  send_schema(table)
  return recv_schema()
end

#send_cancelQuery(table, uuid) ⇒ Object 



132
133
134
 
# File 'lib/active_blur/thrift/blur.rb', line 132

def send_cancelQuery(table, uuid)
  send_message('cancelQuery', CancelQuery_args, :table => table, :uuid => uuid)
end

#send_controllerServerList ⇒ Object 



52
53
54
 
# File 'lib/active_blur/thrift/blur.rb', line 52

def send_controllerServerList()
  send_message('controllerServerList', ControllerServerList_args)
end

#send_createTable(tableDescriptor) ⇒ Object 



273
274
275
 
# File 'lib/active_blur/thrift/blur.rb', line 273

def send_createTable(tableDescriptor)
  send_message('createTable', CreateTable_args, :tableDescriptor => tableDescriptor)
end

#send_currentQueries(table) ⇒ Object 



147
148
149
 
# File 'lib/active_blur/thrift/blur.rb', line 147

def send_currentQueries(table)
  send_message('currentQueries', CurrentQueries_args, :table => table)
end

#send_describe(table) ⇒ Object 



100
101
102
 
# File 'lib/active_blur/thrift/blur.rb', line 100

def send_describe(table)
  send_message('describe', Describe_args, :table => table)
end

#send_disableTable(table) ⇒ Object 



303
304
305
 
# File 'lib/active_blur/thrift/blur.rb', line 303

def send_disableTable(table)
  send_message('disableTable', DisableTable_args, :table => table)
end

#send_enableTable(table) ⇒ Object 



288
289
290
 
# File 'lib/active_blur/thrift/blur.rb', line 288

def send_enableTable(table)
  send_message('enableTable', EnableTable_args, :table => table)
end

#send_fetchRow(table, selector) ⇒ Object 



227
228
229
 
# File 'lib/active_blur/thrift/blur.rb', line 227

def send_fetchRow(table, selector)
  send_message('fetchRow', FetchRow_args, :table => table, :selector => selector)
end

#send_getTableStats(table) ⇒ Object 



179
180
181
 
# File 'lib/active_blur/thrift/blur.rb', line 179

def send_getTableStats(table)
  send_message('getTableStats', GetTableStats_args, :table => table)
end

#send_mutate(mutation) ⇒ Object 



243
244
245
 
# File 'lib/active_blur/thrift/blur.rb', line 243

def send_mutate(mutation)
  send_message('mutate', Mutate_args, :mutation => mutation)
end

#send_mutateBatch(mutations) ⇒ Object 



258
259
260
 
# File 'lib/active_blur/thrift/blur.rb', line 258

def send_mutateBatch(mutations)
  send_message('mutateBatch', MutateBatch_args, :mutations => mutations)
end

#send_query(table, blurQuery) ⇒ Object 



116
117
118
 
# File 'lib/active_blur/thrift/blur.rb', line 116

def send_query(table, blurQuery)
  send_message('query', Query_args, :table => table, :blurQuery => blurQuery)
end

#send_recordFrequency(table, columnFamily, columnName, value) ⇒ Object 



211
212
213
 
# File 'lib/active_blur/thrift/blur.rb', line 211

def send_recordFrequency(table, columnFamily, columnName, value)
  send_message('recordFrequency', RecordFrequency_args, :table => table, :columnFamily => columnFamily, :columnName => columnName, :value => value)
end

#send_removeTable(table, deleteIndexFiles) ⇒ Object 



318
319
320
 
# File 'lib/active_blur/thrift/blur.rb', line 318

def send_removeTable(table, deleteIndexFiles)
  send_message('removeTable', RemoveTable_args, :table => table, :deleteIndexFiles => deleteIndexFiles)
end

#send_schema(table) ⇒ Object 



163
164
165
 
# File 'lib/active_blur/thrift/blur.rb', line 163

def send_schema(table)
  send_message('schema', Schema_args, :table => table)
end

#send_shardClusterList ⇒ Object 



20
21
22
 
# File 'lib/active_blur/thrift/blur.rb', line 20

def send_shardClusterList()
  send_message('shardClusterList', ShardClusterList_args)
end

#send_shardServerLayout(table) ⇒ Object 



68
69
70
 
# File 'lib/active_blur/thrift/blur.rb', line 68

def send_shardServerLayout(table)
  send_message('shardServerLayout', ShardServerLayout_args, :table => table)
end

#send_shardServerList(cluster) ⇒ Object 



36
37
38
 
# File 'lib/active_blur/thrift/blur.rb', line 36

def send_shardServerList(cluster)
  send_message('shardServerList', ShardServerList_args, :cluster => cluster)
end

#send_tableList ⇒ Object 



84
85
86
 
# File 'lib/active_blur/thrift/blur.rb', line 84

def send_tableList()
  send_message('tableList', TableList_args)
end

#send_terms(table, columnFamily, columnName, startWith, size) ⇒ Object 



195
196
197
 
# File 'lib/active_blur/thrift/blur.rb', line 195

def send_terms(table, columnFamily, columnName, startWith, size)
  send_message('terms', Terms_args, :table => table, :columnFamily => columnFamily, :columnName => columnName, :startWith => startWith, :size => size)
end

#shardClusterList ⇒ Object 



15
16
17
18
 
# File 'lib/active_blur/thrift/blur.rb', line 15

def shardClusterList()
  send_shardClusterList()
  return recv_shardClusterList()
end

#shardServerLayout(table) ⇒ Object 



63
64
65
66
 
# File 'lib/active_blur/thrift/blur.rb', line 63

def shardServerLayout(table)
  send_shardServerLayout(table)
  return recv_shardServerLayout()
end

#shardServerList(cluster) ⇒ Object 



31
32
33
34
 
# File 'lib/active_blur/thrift/blur.rb', line 31

def shardServerList(cluster)
  send_shardServerList(cluster)
  return recv_shardServerList()
end

#tableList ⇒ Object 



79
80
81
82
 
# File 'lib/active_blur/thrift/blur.rb', line 79

def tableList()
  send_tableList()
  return recv_tableList()
end

#terms(table, columnFamily, columnName, startWith, size) ⇒ Object 



190
191
192
193
 
# File 'lib/active_blur/thrift/blur.rb', line 190

def terms(table, columnFamily, columnName, startWith, size)
  send_terms(table, columnFamily, columnName, startWith, size)
  return recv_terms()
end