Contents

module ConsulStockpile
  module ConsulLock
    extend self

    def with_lock(key:)
      sessionid = nil
      locked = false
      sessionid = Diplomat::Session.create(Name: "#{key}.lock")
      locked = Diplomat::Lock.wait_to_acquire(key, sessionid)

      yield
    ensure
      if sessionid != nil
        Diplomat::Lock.release(key, sessionid) if locked
        Diplomat::Session.destroy(sessionid)
      end
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
consul_stockpile-0.1.5	lib/consul_stockpile/consul_lock.rb
consul_stockpile-0.1.2	lib/consul_stockpile/consul_lock.rb
consul_stockpile-0.1.1	lib/consul_stockpile/consul_lock.rb
consul_stockpile-0.1.0	lib/consul_stockpile/consul_lock.rb