Module: Tarantool::BlockDB::CommonSpaceBlockingMethods

Included in:
SpaceArray, SpaceHash
Defined in:
lib/tarantool/block_db.rb

Instance Method Summary collapse

Instance Method Details

#_block_cb ⇒ Object 



102
103
104
 
# File 'lib/tarantool/block_db.rb', line 102

def _block_cb
  @_block_cb ||= method(:_raise_or_return)
end

#all_by_pks(pks, opts = {}) ⇒ Object 



106
107
108
 
# File 'lib/tarantool/block_db.rb', line 106

def all_by_pks(pks, opts={})
  all_by_pks_cb(pks, _block_cb, opts)
end

#by_pk(pk) ⇒ Object 



110
111
112
 
# File 'lib/tarantool/block_db.rb', line 110

def by_pk(pk)
  by_pk_cb(pk, _block_cb)
end

#call(func_name, values = [], opts = {}) ⇒ Object 



138
139
140
 
# File 'lib/tarantool/block_db.rb', line 138

def call(func_name, values = [], opts = {})
  call_cb(func_name, values, _block_cb, opts)
end

#delete(pk, opts = {}) ⇒ Object 



130
131
132
 
# File 'lib/tarantool/block_db.rb', line 130

def delete(pk, opts={})
  delete_cb(pk, _block_cb, opts)
end

#insert(tuple, opts = {}) ⇒ Object 



114
115
116
 
# File 'lib/tarantool/block_db.rb', line 114

def insert(tuple, opts={})
  insert_cb(tuple, _block_cb, opts)
end

#invoke(func_name, values = [], opts = {}) ⇒ Object 



134
135
136
 
# File 'lib/tarantool/block_db.rb', line 134

def invoke(func_name, values = [], opts = {})
  invoke_cb(func_name, values, _block_cb, opts)
end

#ping ⇒ Object 



142
143
144
 
# File 'lib/tarantool/block_db.rb', line 142

def ping
  ping_cb(_block_cb)
end

#replace(tuple, opts = {}) ⇒ Object 



118
119
120
 
# File 'lib/tarantool/block_db.rb', line 118

def replace(tuple, opts={})
  replace_cb(tuple, _block_cb, opts)
end

#store(tuple, opts = {}) ⇒ Object 



122
123
124
 
# File 'lib/tarantool/block_db.rb', line 122

def store(tuple, opts={})
  store_cb(tuple, _block_cb, opts)
end

#update(pk, operations, opts = {}) ⇒ Object 



126
127
128
 
# File 'lib/tarantool/block_db.rb', line 126

def update(pk, operations, opts={})
  update_cb(pk, operations, _block_cb, opts)
end