Module: Tarantool::BlockDB::CommonSpaceBlockingMethods
- Included in:
- SpaceArray, SpaceHash
- Defined in:
- lib/tarantool/block_db.rb
Instance Method Summary collapse
- #_block_cb ⇒ Object
- #all_by_pks(pks, opts = {}) ⇒ Object
- #by_pk(pk) ⇒ Object
- #call(func_name, values = [], opts = {}) ⇒ Object
- #delete(pk, opts = {}) ⇒ Object
- #insert(tuple, opts = {}) ⇒ Object
- #invoke(func_name, values = [], opts = {}) ⇒ Object
- #ping ⇒ Object
- #replace(tuple, opts = {}) ⇒ Object
- #store(tuple, opts = {}) ⇒ Object
- #update(pk, operations, opts = {}) ⇒ Object
Instance Method Details
#_block_cb ⇒ Object
107 108 109 |
# File 'lib/tarantool/block_db.rb', line 107 def _block_cb @_block_cb ||= method(:_raise_or_return) end |
#all_by_pks(pks, opts = {}) ⇒ Object
111 112 113 |
# File 'lib/tarantool/block_db.rb', line 111 def all_by_pks(pks, opts={}) all_by_pks_cb(pks, _block_cb, opts) end |
#by_pk(pk) ⇒ Object
115 116 117 |
# File 'lib/tarantool/block_db.rb', line 115 def by_pk(pk) by_pk_cb(pk, _block_cb) end |
#call(func_name, values = [], opts = {}) ⇒ Object
143 144 145 |
# File 'lib/tarantool/block_db.rb', line 143 def call(func_name, values = [], opts = {}) call_cb(func_name, values, _block_cb, opts) end |
#delete(pk, opts = {}) ⇒ Object
135 136 137 |
# File 'lib/tarantool/block_db.rb', line 135 def delete(pk, opts={}) delete_cb(pk, _block_cb, opts) end |
#insert(tuple, opts = {}) ⇒ Object
119 120 121 |
# File 'lib/tarantool/block_db.rb', line 119 def insert(tuple, opts={}) insert_cb(tuple, _block_cb, opts) end |
#invoke(func_name, values = [], opts = {}) ⇒ Object
139 140 141 |
# File 'lib/tarantool/block_db.rb', line 139 def invoke(func_name, values = [], opts = {}) invoke_cb(func_name, values, _block_cb, opts) end |
#ping ⇒ Object
147 148 149 |
# File 'lib/tarantool/block_db.rb', line 147 def ping ping_cb(_block_cb) end |
#replace(tuple, opts = {}) ⇒ Object
123 124 125 |
# File 'lib/tarantool/block_db.rb', line 123 def replace(tuple, opts={}) replace_cb(tuple, _block_cb, opts) end |
#store(tuple, opts = {}) ⇒ Object
127 128 129 |
# File 'lib/tarantool/block_db.rb', line 127 def store(tuple, opts={}) store_cb(tuple, _block_cb, opts) end |
#update(pk, operations, opts = {}) ⇒ Object
131 132 133 |
# File 'lib/tarantool/block_db.rb', line 131 def update(pk, operations, opts={}) update_cb(pk, operations, _block_cb, opts) end |