Class: PactBroker::DB::AdvisoryLock
- Inherits:
-
Object
- Object
- PactBroker::DB::AdvisoryLock
- Includes:
- Logging
- Defined in:
- lib/pact_broker/db/advisory_lock.rb
Instance Method Summary collapse
-
#initialize(database_connection, name, type = :pg_try_advisory_lock) ⇒ AdvisoryLock
constructor
A new instance of AdvisoryLock.
- #lock_obtained? ⇒ Boolean
- #with_lock ⇒ Object
Methods included from Logging
included, #log_error, #log_with_tag, #measure_info
Constructor Details
#initialize(database_connection, name, type = :pg_try_advisory_lock) ⇒ AdvisoryLock
Returns a new instance of AdvisoryLock.
20 21 22 23 24 25 26 |
# File 'lib/pact_broker/db/advisory_lock.rb', line 20 def initialize(database_connection, name, type = :pg_try_advisory_lock) @database_connection = database_connection @name = name @type = type @lock_obtained = false register_advisory_lock if postgres? end |
Instance Method Details
#lock_obtained? ⇒ Boolean
42 43 44 |
# File 'lib/pact_broker/db/advisory_lock.rb', line 42 def lock_obtained? @lock_obtained end |
#with_lock ⇒ Object
28 29 30 31 32 33 34 35 36 37 38 39 40 |
# File 'lib/pact_broker/db/advisory_lock.rb', line 28 def with_lock if postgres? @database_connection.with_advisory_lock(@name) do logger.debug("Lock #{@name} obtained") @lock_obtained = true yield end else logger.warn("Executing block without lock as this is not a Postgres database") @lock_obtained = true yield end end |