Class: SolidFlow::Stores::Base

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

Direct Known Subclasses

ActiveRecord

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(event_serializer:, time_provider:, logger:) ⇒ Base

Returns a new instance of Base.



6
7
8
9
10
 
# File 'lib/solid_flow/stores/base.rb', line 6

def initialize(event_serializer:, time_provider:, logger:)
  @event_serializer = event_serializer
  @time_provider = time_provider
  @logger = logger
end

Instance Attribute Details

#event_serializer ⇒ Object (readonly)

Returns the value of attribute event_serializer.



12
13
14
 
# File 'lib/solid_flow/stores/base.rb', line 12

def event_serializer
  @event_serializer
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



12
13
14
 
# File 'lib/solid_flow/stores/base.rb', line 12

def logger
  @logger
end

#time_provider ⇒ Object (readonly)

Returns the value of attribute time_provider.



12
13
14
 
# File 'lib/solid_flow/stores/base.rb', line 12

def time_provider
  @time_provider
end

Instance Method Details

#append_event(execution_id:, type:, payload:) ⇒ Object

Raises:

  • (NotImplementedError) 


34
35
36
 
# File 'lib/solid_flow/stores/base.rb', line 34

def append_event(execution_id:, type:, payload:)
  raise NotImplementedError
end

#enqueue_execution(execution_id:, reason:) ⇒ Object

Raises:

  • (NotImplementedError) 


46
47
48
 
# File 'lib/solid_flow/stores/base.rb', line 46

def enqueue_execution(execution_id:, reason:)
  raise NotImplementedError
end

#load_history(execution_id) ⇒ Object

Raises:

  • (NotImplementedError) 


30
31
32
 
# File 'lib/solid_flow/stores/base.rb', line 30

def load_history(execution_id)
  raise NotImplementedError
end

#mark_timer_fired(timer_id:) ⇒ Object

Raises:

  • (NotImplementedError) 


66
67
68
 
# File 'lib/solid_flow/stores/base.rb', line 66

def mark_timer_fired(timer_id:)
  raise NotImplementedError
end

#persist_context(execution_id:, ctx:) ⇒ Object

Raises:

  • (NotImplementedError) 


42
43
44
 
# File 'lib/solid_flow/stores/base.rb', line 42

def persist_context(execution_id:, ctx:)
  raise NotImplementedError
end

#persist_signal_consumed(execution_id:, signal_name:) ⇒ Object

Raises:

  • (NotImplementedError) 


70
71
72
 
# File 'lib/solid_flow/stores/base.rb', line 70

def persist_signal_consumed(execution_id:, signal_name:)
  raise NotImplementedError
end

#query_execution(execution_id:, workflow_class:) ⇒ Object

Raises:

  • (NotImplementedError) 


22
23
24
 
# File 'lib/solid_flow/stores/base.rb', line 22

def query_execution(execution_id:, workflow_class:)
  raise NotImplementedError
end

#record_compensation_failure(execution_id:, step:, compensation_task:, error:) ⇒ Object

Raises:

  • (NotImplementedError) 


82
83
84
 
# File 'lib/solid_flow/stores/base.rb', line 82

def record_compensation_failure(execution_id:, step:, compensation_task:, error:)
  raise NotImplementedError
end

#record_compensation_result(execution_id:, step:, compensation_task:, result:) ⇒ Object

Raises:

  • (NotImplementedError) 


78
79
80
 
# File 'lib/solid_flow/stores/base.rb', line 78

def record_compensation_result(execution_id:, step:, compensation_task:, result:)
  raise NotImplementedError
end

#record_task_failure(execution_id:, step:, attempt:, error:, retryable:) ⇒ Object

Raises:

  • (NotImplementedError) 


58
59
60
 
# File 'lib/solid_flow/stores/base.rb', line 58

def record_task_failure(execution_id:, step:, attempt:, error:, retryable:)
  raise NotImplementedError
end

#record_task_result(execution_id:, step:, result:, attempt:, ctx_snapshot:, idempotency_key:) ⇒ Object

Raises:

  • (NotImplementedError) 


54
55
56
 
# File 'lib/solid_flow/stores/base.rb', line 54

def record_task_result(execution_id:, step:, result:, attempt:, ctx_snapshot:, idempotency_key:)
  raise NotImplementedError
end

#schedule_compensation(execution_id:, workflow_class:, step:, compensation_task:, context:) ⇒ Object

Raises:

  • (NotImplementedError) 


74
75
76
 
# File 'lib/solid_flow/stores/base.rb', line 74

def schedule_compensation(execution_id:, workflow_class:, step:, compensation_task:, context:)
  raise NotImplementedError
end

#schedule_task(execution_id:, step:, task:, arguments:, headers:, run_at: nil) ⇒ Object

Raises:

  • (NotImplementedError) 


50
51
52
 
# File 'lib/solid_flow/stores/base.rb', line 50

def schedule_task(execution_id:, step:, task:, arguments:, headers:, run_at: nil)
  raise NotImplementedError
end

#schedule_timer(execution_id:, step:, run_at:, instruction:, metadata:) ⇒ Object

Raises:

  • (NotImplementedError) 


62
63
64
 
# File 'lib/solid_flow/stores/base.rb', line 62

def schedule_timer(execution_id:, step:, run_at:, instruction:, metadata:)
  raise NotImplementedError
end

#signal_execution(execution_id:, workflow_class:, signal_name:, payload:) ⇒ Object

Raises:

  • (NotImplementedError) 


18
19
20
 
# File 'lib/solid_flow/stores/base.rb', line 18

def signal_execution(execution_id:, workflow_class:, signal_name:, payload:)
  raise NotImplementedError
end

#start_execution(workflow_class:, input:, graph_signature:) ⇒ Object

Raises:

  • (NotImplementedError) 


14
15
16
 
# File 'lib/solid_flow/stores/base.rb', line 14

def start_execution(workflow_class:, input:, graph_signature:)
  raise NotImplementedError
end

#update_execution(execution_id:, attributes:) ⇒ Object

Raises:

  • (NotImplementedError) 


38
39
40
 
# File 'lib/solid_flow/stores/base.rb', line 38

def update_execution(execution_id:, attributes:)
  raise NotImplementedError
end

#with_execution(execution_id, lock: true) ⇒ Object

Raises:

  • (NotImplementedError) 


26
27
28
 
# File 'lib/solid_flow/stores/base.rb', line 26

def with_execution(execution_id, lock: true)
  raise NotImplementedError
end