Class: RubyReactor::Storage::Adapter

Inherits:
Object
  • Object
show all
Defined in:
lib/ruby_reactor/storage/adapter.rb

Direct Known Subclasses

RedisAdapter

Instance Method Summary collapse

Instance Method Details

#decrement_map_counter(map_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


34
35
36
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 34

def decrement_map_counter(map_id, reactor_class_name)
  raise NotImplementedError
end

#expire(key, seconds) ⇒ Object

Raises:

  • (NotImplementedError) 


46
47
48
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 46

def expire(key, seconds)
  raise NotImplementedError
end

#increment_map_counter(map_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


30
31
32
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 30

def increment_map_counter(map_id, reactor_class_name)
  raise NotImplementedError
end

#initialize_map_operation(map_id, count, reactor_class_info:, strict_ordering: true) ⇒ Object

Raises:

  • (NotImplementedError) 


26
27
28
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 26

def initialize_map_operation(map_id, count, reactor_class_info:, strict_ordering: true)
  raise NotImplementedError
end

#publish(channel, message) ⇒ Object

Raises:

  • (NotImplementedError) 


42
43
44
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 42

def publish(channel, message)
  raise NotImplementedError
end

#retrieve_context(context_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


10
11
12
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 10

def retrieve_context(context_id, reactor_class_name)
  raise NotImplementedError
end

#retrieve_map_results(map_id, reactor_class_name, strict_ordering: true) ⇒ Object

Raises:

  • (NotImplementedError) 


18
19
20
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 18

def retrieve_map_results(map_id, reactor_class_name, strict_ordering: true)
  raise NotImplementedError
end

#set_map_counter(map_id, count, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


22
23
24
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 22

def set_map_counter(map_id, count, reactor_class_name)
  raise NotImplementedError
end

#store_context(context_id, serialized_context, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


6
7
8
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 6

def store_context(context_id, serialized_context, reactor_class_name)
  raise NotImplementedError
end

#store_map_result(map_id, index, serialized_result, reactor_class_name, strict_ordering: true) ⇒ Object

Raises:

  • (NotImplementedError) 


14
15
16
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 14

def store_map_result(map_id, index, serialized_result, reactor_class_name, strict_ordering: true)
  raise NotImplementedError
end

#subscribe(channel, &block) ⇒ Object

Raises:

  • (NotImplementedError) 


38
39
40
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 38

def subscribe(channel, &block)
  raise NotImplementedError
end