class Dynflow::PersistenceAdapters::Abstract
Attributes
logger[RW]
The logger is set by the world when used inside it
Public Instance Methods
delete_delayed_plans(filters, batch_size = 1000)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 62 def delete_delayed_plans(filters, batch_size = 1000) raise NotImplementedError end
delete_execution_plans(filters, batch_size = 1000)
click to toggle source
@param filters [Hash{ String => Object }] filters to determine
what to delete
@param batch_size the size of the chunks to iterate over when
performing the deletion
# File lib/dynflow/persistence_adapters/abstract.rb, line 46 def delete_execution_plans(filters, batch_size = 1000) raise NotImplementedError end
filtering_by()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 24 def filtering_by [] end
find_execution_plans(options = {})
click to toggle source
@option options [Integer] page index of the page (starting at 0) @option options [Integer] per_page the number of the items on page @option options [Symbol] order_by name of the column to use for ordering @option options [true, false] desc set to true if order should be descending @option options [Hash{ String => Object,Array<object> }] filters hash represents
set of allowed values for a given key representing column
# File lib/dynflow/persistence_adapters/abstract.rb, line 38 def find_execution_plans(options = {}) raise NotImplementedError end
find_past_delayed_plans(options = {})
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 58 def find_past_delayed_plans(options = {}) raise NotImplementedError end
load_action(execution_plan_id, action_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 82 def load_action(execution_plan_id, action_id) raise NotImplementedError end
load_delayed_plan(execution_plan_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 66 def load_delayed_plan(execution_plan_id) raise NotImplementedError end
load_execution_plan(execution_plan_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 50 def load_execution_plan(execution_plan_id) raise NotImplementedError end
load_step(execution_plan_id, step_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 74 def load_step(execution_plan_id, step_id) raise NotImplementedError end
log(level, message)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 12 def log(level, message) logger.send(level, message) if logger end
ordering_by()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 28 def ordering_by [] end
pagination?()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 16 def pagination? false end
pull_envelopes(receiver_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 95 def pull_envelopes(receiver_id) raise NotImplementedError end
push_envelope(envelope)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 99 def push_envelope(envelope) raise NotImplementedError end
register_world(world)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 8 def register_world(world) @logger ||= world.logger end
save_action(execution_plan_id, action_id, value)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 86 def save_action(execution_plan_id, action_id, value) raise NotImplementedError end
save_delayed_plan(execution_plan_id, value)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 70 def save_delayed_plan(execution_plan_id, value) raise NotImplementedError end
save_execution_plan(execution_plan_id, value)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 54 def save_execution_plan(execution_plan_id, value) raise NotImplementedError end
save_step(execution_plan_id, step_id, value)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 78 def save_step(execution_plan_id, step_id, value) raise NotImplementedError end
to_hash()
click to toggle source
for debug purposes
# File lib/dynflow/persistence_adapters/abstract.rb, line 91 def to_hash raise NotImplementedError end
transaction()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 20 def transaction raise NotImplementedError end