class Dynflow::PersistenceAdapters::Abstract
Attributes
logger[RW]
The logger is set by the world when used inside it
Public Instance Methods
abort_if_pending_migrations!()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 148 def abort_if_pending_migrations! raise NotImplementedError end
delete_delayed_plans(filters, batch_size = 1000)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 75 def delete_delayed_plans(filters, batch_size = 1000) raise NotImplementedError end
delete_execution_plans(filters, batch_size = 1000, backup_dir = nil)
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
@param backup_dir where the backup of deleted plans will be created.
Set to nil for no backup
# File lib/dynflow/persistence_adapters/abstract.rb, line 59 def delete_execution_plans(filters, batch_size = 1000, backup_dir = nil) raise NotImplementedError end
delete_output_chunks(execution_plan_id, action_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 119 def delete_output_chunks(execution_plan_id, action_id) raise NotImplementedError end
filtering_by()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 25 def filtering_by [] end
find_execution_plan_counts(options = {})
click to toggle source
@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 45 def find_execution_plan_counts(options = {}) filter(:execution_plan, options[:filters]).count end
find_execution_plan_statuses(options)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 49 def find_execution_plan_statuses(options) raise NotImplementedError 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 39 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 71 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 95 def load_action(execution_plan_id, action_id) raise NotImplementedError end
load_actions(execution_plan_id, action_ids)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 103 def load_actions(execution_plan_id, action_ids) raise NotImplementedError end
load_actions_attributes(execution_plan_id, attributes)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 99 def load_actions_attributes(execution_plan_id, attributes) raise NotImplementedError end
load_delayed_plan(execution_plan_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 79 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 63 def load_execution_plan(execution_plan_id) raise NotImplementedError end
load_output_chunks(execution_plan_id, action_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 115 def load_output_chunks(execution_plan_id, action_id) raise NotImplementedError end
load_step(execution_plan_id, step_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 87 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 13 def log(level, message) logger.send(level, message) if logger end
migrate_db()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 144 def migrate_db raise NotImplementedError end
ordering_by()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 29 def ordering_by [] end
pagination?()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 17 def pagination? false end
prune_envelopes(receiver_ids)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 136 def prune_envelopes(receiver_ids) raise NotImplementedError end
prune_undeliverable_envelopes()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 140 def prune_undeliverable_envelopes raise NotImplementedError end
pull_envelopes(receiver_id)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 128 def pull_envelopes(receiver_id) raise NotImplementedError end
push_envelope(envelope)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 132 def push_envelope(envelope) raise NotImplementedError end
register_world(world)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 9 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 107 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 83 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 67 def save_execution_plan(execution_plan_id, value) raise NotImplementedError end
save_output_chunks(execution_plan_id, action_id, chunks)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 111 def save_output_chunks(execution_plan_id, action_id, chunks) raise NotImplementedError end
save_step(execution_plan_id, step_id, value)
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 91 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 124 def to_hash raise NotImplementedError end
transaction()
click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 21 def transaction raise NotImplementedError end