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 70
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 54
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 24
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 44
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 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 66
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 90
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 98
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 94
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 74
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 58
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 82
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 111
def pull_envelopes(receiver_id)
  raise NotImplementedError
end
push_envelope(envelope) click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 115
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 102
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 78
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 62
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 86
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 107
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