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

#delete_context(context_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


62
63
64
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 62

def delete_context(context_id, reactor_class_name)
  raise NotImplementedError
end

#delete_correlation_id(correlation_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


58
59
60
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 58

def delete_correlation_id(correlation_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

#find_context_by_id(context_id) ⇒ Object

Raises:

  • (NotImplementedError) 


70
71
72
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 70

def find_context_by_id(context_id)
  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_context_id_by_correlation_id(correlation_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


54
55
56
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 54

def retrieve_context_id_by_correlation_id(correlation_id, reactor_class_name)
  raise NotImplementedError
end

#retrieve_map_element_context_ids(map_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


78
79
80
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 78

def retrieve_map_element_context_ids(map_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

#scan_reactors(pattern: "*", count: 50) ⇒ Object

Raises:

  • (NotImplementedError) 


66
67
68
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 66

def scan_reactors(pattern: "*", count: 50)
  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_correlation_id(correlation_id, context_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


50
51
52
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 50

def store_correlation_id(correlation_id, context_id, reactor_class_name)
  raise NotImplementedError
end

#store_map_element_context_id(map_id, context_id, reactor_class_name) ⇒ Object

Raises:

  • (NotImplementedError) 


74
75
76
 
# File 'lib/ruby_reactor/storage/adapter.rb', line 74

def store_map_element_context_id(map_id, context_id, 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