Sha256: 3f7e34bce8b16cc1a41bb2fb314a16229abb29285e482f0587b16c660a691d2c
Contents?: true
Size: 857 Bytes
Versions: 45
Compression:
Stored size: 857 Bytes
Contents
module Dynflow
module CoordinatorAdapters
class Sequel < Abstract
def initialize(world)
super
@sequel_adapter = world.persistence.adapter
Type! @sequel_adapter, PersistenceAdapters::Sequel
end
def create_record(record)
@sequel_adapter.insert_coordinator_record(record.to_hash)
rescue ::Sequel::UniqueConstraintViolation
raise Coordinator::DuplicateRecordError.new(record)
end
def update_record(record)
@sequel_adapter.update_coordinator_record(record.class.name, record.id, record.to_hash)
end
def delete_record(record)
@sequel_adapter.delete_coordinator_record(record.class.name, record.id)
end
def find_records(filter_options)
@sequel_adapter.find_coordinator_records(filters: filter_options)
end
end
end
end
Version data entries
45 entries across 45 versions & 1 rubygems