Class: ActiveSaga::Stores::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/active_saga/stores/base.rb

Overview

Base interface for persistence adapters.

Direct Known Subclasses

ActiveRecord

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(logger: ActiveSaga.configuration.logger, serializer: ActiveSaga.configuration.serializer, clock: ActiveSaga.configuration.clock) ⇒ Base

Returns a new instance of Base.



9
10
11
12
13
14
15
 
# File 'lib/active_saga/stores/base.rb', line 9

def initialize(logger: ActiveSaga.configuration.logger,
  serializer: ActiveSaga.configuration.serializer,
  clock: ActiveSaga.configuration.clock)
  @logger     = logger
  @serializer = serializer
  @clock      = clock
end

Instance Attribute Details

#clock ⇒ Object (readonly)

Returns the value of attribute clock.



7
8
9
 
# File 'lib/active_saga/stores/base.rb', line 7

def clock
  @clock
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



7
8
9
 
# File 'lib/active_saga/stores/base.rb', line 7

def logger
  @logger
end

#serializer ⇒ Object (readonly)

Returns the value of attribute serializer.



7
8
9
 
# File 'lib/active_saga/stores/base.rb', line 7

def serializer
  @serializer
end

Instance Method Details

#cancel_execution!(_execution_id, reason: nil) ⇒ Object

Raises:

  • (NotImplementedError) 


57
58
59
 
# File 'lib/active_saga/stores/base.rb', line 57

def cancel_execution!(_execution_id, reason: nil)
  raise NotImplementedError
end

#complete_step!(*_args) ⇒ Object

Raises:

  • (NotImplementedError) 


25
26
27
 
# File 'lib/active_saga/stores/base.rb', line 25

def complete_step!(*_args)
  raise NotImplementedError
end

#enqueue_runner(_execution_id, _step_name = nil) ⇒ Object

Raises:

  • (NotImplementedError) 


49
50
51
 
# File 'lib/active_saga/stores/base.rb', line 49

def enqueue_runner(_execution_id, _step_name = nil)
  raise NotImplementedError
end

#extend_timeout!(*_args) ⇒ Object

Raises:

  • (NotImplementedError) 


33
34
35
 
# File 'lib/active_saga/stores/base.rb', line 33

def extend_timeout!(*_args)
  raise NotImplementedError
end

#fail_step!(*_args) ⇒ Object

Raises:

  • (NotImplementedError) 


29
30
31
 
# File 'lib/active_saga/stores/base.rb', line 29

def fail_step!(*_args)
  raise NotImplementedError
end

#heartbeat!(*_args) ⇒ Object

Raises:

  • (NotImplementedError) 


37
38
39
 
# File 'lib/active_saga/stores/base.rb', line 37

def heartbeat!(*_args)
  raise NotImplementedError
end

#load_execution(_id) ⇒ Object

Raises:

  • (NotImplementedError) 


21
22
23
 
# File 'lib/active_saga/stores/base.rb', line 21

def load_execution(_id)
  raise NotImplementedError
end

#process_execution(_execution_id) ⇒ Object

Raises:

  • (NotImplementedError) 


45
46
47
 
# File 'lib/active_saga/stores/base.rb', line 45

def process_execution(_execution_id)
  raise NotImplementedError
end

#signal!(*_args) ⇒ Object

Raises:

  • (NotImplementedError) 


41
42
43
 
# File 'lib/active_saga/stores/base.rb', line 41

def signal!(*_args)
  raise NotImplementedError
end

#start_execution ⇒ Object

Raises:

  • (NotImplementedError) 


17
18
19
 
# File 'lib/active_saga/stores/base.rb', line 17

def start_execution(**)
  raise NotImplementedError
end

#with_execution_lock(_execution_id) ⇒ Object

Raises:

  • (NotImplementedError) 


53
54
55
 
# File 'lib/active_saga/stores/base.rb', line 53

def with_execution_lock(_execution_id)
  raise NotImplementedError
end