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 132
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 71
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 55
def delete_execution_plans(filters, batch_size = 1000, backup_dir = nil)
  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_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 67
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 91
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 99
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 95
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 75
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 59
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 83
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 128
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 120
def prune_envelopes(receiver_ids)
  raise NotImplementedError
end
prune_undeliverable_envelopes() click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 124
def prune_undeliverable_envelopes
  raise NotImplementedError
end
pull_envelopes(receiver_id) click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 112
def pull_envelopes(receiver_id)
  raise NotImplementedError
end
push_envelope(envelope) click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 116
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 103
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 79
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 63
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 87
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 108
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