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 



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