Class: Tarantool::BlockDB::Query
- Inherits:
-
Query
- Object
- Query
- Tarantool::BlockDB::Query
show all
- Defined in:
- lib/tarantool/block_db.rb
Constant Summary
Constants included
from Request
Request::BINARY, Request::BOX_ADD, Request::BOX_REPLACE, Request::BOX_RETURN_TUPLE, Request::CALL_HEADER, Request::DELETE_HEADER, Request::EMPTY, Request::INSERT_HEADER, Request::INT32_0, Request::INT32_1, Request::LEST_INT32, Request::MAX_BYTE_SIZE, Request::ONE, Request::PACK_STRING, Request::REQUEST_CALL, Request::REQUEST_DELETE, Request::REQUEST_INSERT, Request::REQUEST_PING, Request::REQUEST_SELECT, Request::REQUEST_UPDATE, Request::SELECT_HEADER, Request::TYPES_AUTO, Request::TYPES_FALLBACK, Request::TYPES_STR_AUTO, Request::TYPES_STR_STR, Request::UPDATE_FIELDNO_OP, Request::UPDATE_HEADER, Request::UPDATE_OPS, Request::ZERO
Constants included
from Serializers
Serializers::MAP
Util::Packer::INT16, Util::Packer::INT32, Util::Packer::INT64, Util::Packer::INT8, Util::Packer::MAX_INT16, Util::Packer::MAX_INT32, Util::Packer::MAX_INT64, Util::Packer::MAX_INT8, Util::Packer::MAX_SINT16, Util::Packer::MAX_SINT32, Util::Packer::MAX_SINT64, Util::Packer::MAX_SINT8, Util::Packer::MIN_INT, Util::Packer::MIN_SINT16, Util::Packer::MIN_SINT32, Util::Packer::MIN_SINT64, Util::Packer::MIN_SINT8, Util::Packer::SINT16, Util::Packer::SINT32, Util::Packer::SINT64, Util::Packer::SINT8
Instance Attribute Summary
Attributes included from Request
#insert_with_shards_count, #previous_shards_count, #shard_proc, #shards_count
Instance Method Summary
collapse
-
#_block_cb ⇒ Object
-
#all(space_no, index_no, keys, opts = {}) ⇒ Object
-
#call(func_name, values, opts = {}) ⇒ Object
-
#delete(space_no, pk, opts = {}) ⇒ Object
-
#first(space_no, index_no, key, opts = {}) ⇒ Object
-
#insert(space_no, tuple, opts = {}) ⇒ Object
-
#invoke(func_name, values, opts = {}) ⇒ Object
-
#ping ⇒ Object
-
#replace(space_no, tuple, opts = {}) ⇒ Object
-
#select(space_no, index_no, keys, offset, limit, opts = {}) ⇒ Object
-
#store(space_no, tuple, opts = {}) ⇒ Object
-
#update(space_no, pk, operation, opts = {}) ⇒ Object
Methods inherited from Query
#all_blk, #all_cb, #call_blk, #call_cb, #delete_blk, #delete_cb, #first_blk, #first_cb, #initialize, #insert_blk, #insert_cb, #invoke_blk, #invoke_cb, #ping_blk, #replace_blk, #replace_cb, #select_blk, #select_cb, #store_blk, #store_cb, #update_blk, #update_cb
Methods included from Request
#_all_shards, #_call, #_delete, #_detect_shard, #_detect_shard_for_insert, #_detect_shards, #_detect_shards_for_insert, #_detect_shards_for_key, #_detect_shards_for_keys, #_detect_type, #_detect_types, #_flat_uniq, #_get_shard_nums, #_init_shard_vars, #_insert, #_modify_request, #_pack_operations, #_parse_hash_definition, #_ping, #_raise_integer_overflow, #_raise_or_return, #_select, #_send_request, #_space_call_fix_values, #_update, #all_shards, #detect_shard, #detect_shard_for_insert, #detect_shards, #detect_shards_for_insert, #pack_field, #pack_tuple, #shard
#check_type, #get_serializer
Instance Method Details
#_block_cb ⇒ Object
189
190
191
|
# File 'lib/tarantool/block_db.rb', line 189
def _block_cb
@_block_cb ||= method(:_raise_or_return)
end
|
#all(space_no, index_no, keys, opts = {}) ⇒ Object
197
198
199
|
# File 'lib/tarantool/block_db.rb', line 197
def all(space_no, index_no, keys, opts={})
all_cb(space_no, index_no, keys, _block_cb, opts)
end
|
#call(func_name, values, opts = {}) ⇒ Object
229
230
231
|
# File 'lib/tarantool/block_db.rb', line 229
def call(func_name, values, opts={})
call_cb(func_name, values, _block_cb, opts)
end
|
#delete(space_no, pk, opts = {}) ⇒ Object
221
222
223
|
# File 'lib/tarantool/block_db.rb', line 221
def delete(space_no, pk, opts={})
delete_cb(space_no, pk, _block_cb, opts)
end
|
#first(space_no, index_no, key, opts = {}) ⇒ Object
201
202
203
|
# File 'lib/tarantool/block_db.rb', line 201
def first(space_no, index_no, key, opts={})
first_cb(space_no, index_no, key, _block_cb, opts)
end
|
#insert(space_no, tuple, opts = {}) ⇒ Object
205
206
207
|
# File 'lib/tarantool/block_db.rb', line 205
def insert(space_no, tuple, opts={})
insert_cb(space_no, tuple, _block_cb, opts)
end
|
#invoke(func_name, values, opts = {}) ⇒ Object
225
226
227
|
# File 'lib/tarantool/block_db.rb', line 225
def invoke(func_name, values, opts={})
invoke_cb(func_name, values, _block_cb, opts)
end
|
#ping ⇒ Object
233
234
235
|
# File 'lib/tarantool/block_db.rb', line 233
def ping
ping_cb(_block_cb)
end
|
#replace(space_no, tuple, opts = {}) ⇒ Object
209
210
211
|
# File 'lib/tarantool/block_db.rb', line 209
def replace(space_no, tuple, opts={})
replace_cb(space_no, tuple, _block_cb, opts)
end
|
#select(space_no, index_no, keys, offset, limit, opts = {}) ⇒ Object
193
194
195
|
# File 'lib/tarantool/block_db.rb', line 193
def select(space_no, index_no, keys, offset, limit, opts={})
select_cb(space_no, index_no, keys, offset, limit, _block_cb, opts)
end
|
#store(space_no, tuple, opts = {}) ⇒ Object
213
214
215
|
# File 'lib/tarantool/block_db.rb', line 213
def store(space_no, tuple, opts={})
store_cb(space_no, tuple, _block_cb, opts)
end
|
#update(space_no, pk, operation, opts = {}) ⇒ Object
217
218
219
|
# File 'lib/tarantool/block_db.rb', line 217
def update(space_no, pk, operation, opts={})
update_cb(space_no, pk, operation, _block_cb, opts)
end
|