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 64
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 48
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_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 60
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 84
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 68
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 52
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 76
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 97
def pull_envelopes(receiver_id)
  raise NotImplementedError
end
push_envelope(envelope) click to toggle source
# File lib/dynflow/persistence_adapters/abstract.rb, line 101
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 88
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 72
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 56
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 80
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 93
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