Module: Tarantool::FiberDB::CommonSpaceFiberMethods

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

Instance Method Summary collapse

Instance Method Details

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



11
12
13
14
 
# File 'lib/tarantool/fiber_db.rb', line 11

def all_by_pks(pks, opts={})
  all_by_pks_cb(pks, ::Fiber.current, opts)
  _raise_or_return ::Fiber.yield
end

#by_pk(pk) ⇒ Object 



16
17
18
19
 
# File 'lib/tarantool/fiber_db.rb', line 16

def by_pk(pk)
  by_pk_cb(pk, ::Fiber.current)
  _raise_or_return ::Fiber.yield
end

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



51
52
53
54
 
# File 'lib/tarantool/fiber_db.rb', line 51

def call(func_name, values = [], opts = {})
  call_cb(func_name, values, ::Fiber.current, opts)
  _raise_or_return ::Fiber.yield
end

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



41
42
43
44
 
# File 'lib/tarantool/fiber_db.rb', line 41

def delete(pk, opts={})
  delete_cb(pk, ::Fiber.current, opts)
  _raise_or_return ::Fiber.yield
end

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



21
22
23
24
 
# File 'lib/tarantool/fiber_db.rb', line 21

def insert(tuple, opts={})
  insert_cb(tuple, ::Fiber.current, opts)
  _raise_or_return ::Fiber.yield
end

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



46
47
48
49
 
# File 'lib/tarantool/fiber_db.rb', line 46

def invoke(func_name, values = [], opts = {})
  invoke_cb(func_name, values, ::Fiber.current, opts)
  _raise_or_return ::Fiber.yield
end

#ping ⇒ Object 



56
57
58
59
 
# File 'lib/tarantool/fiber_db.rb', line 56

def ping
  ping_cb(::Fiber.current)
  _raise_or_return ::Fiber.yield
end

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



26
27
28
29
 
# File 'lib/tarantool/fiber_db.rb', line 26

def replace(tuple, opts={})
  replace_cb(tuple, ::Fiber.current, opts)
  _raise_or_return ::Fiber.yield
end

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



31
32
33
34
 
# File 'lib/tarantool/fiber_db.rb', line 31

def store(tuple, opts={})
  store_cb(tuple, ::Fiber.current, opts)
  _raise_or_return ::Fiber.yield
end

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



36
37
38
39
 
# File 'lib/tarantool/fiber_db.rb', line 36

def update(pk, operations, opts={})
  update_cb(pk, operations, ::Fiber.current, opts)
  _raise_or_return ::Fiber.yield
end