Class: Pgbus::BusRecord

Inherits:

ActiveRecord::Base

• Object
• ActiveRecord::Base
• Pgbus::BusRecord

Defined in:

lib/pgbus/bus_record.rb

Overview

Base class for all Pgbus ActiveRecord models.

Lives in lib/pgbus/ so the main Zeitwerk gem loader picks it up regardless of Rails engine boot order. This avoids the NameError that occurs when a host app uses selective railtie requires (require "rails" + individual railties instead of require "rails/all") and the engine's app/models path isn't registered yet.

Direct Known Subclasses

ApplicationRecord, BatchEntry, BlockedExecution, JobStat, OutboxEntry, ProcessEntry, ProcessedEvent, QueueState, RecurringExecution, RecurringTask, Semaphore, StreamQueue, StreamStat, UniquenessKey

Class Method Summary

• .disconnect_all_pools! ⇒ Object

  Disconnects every pool owned by this class — the pools connects_to creates when pgbus runs on a dedicated database — across all roles.

Class Method Details

.disconnect_all_pools! ⇒ Object

Disconnects every pool owned by this class — the pools connects_to creates when pgbus runs on a dedicated database — across all roles. When pgbus runs in the primary database there is no BusRecord-owned pool and this is a no-op; ActiveRecord::Base's pool is never touched.

Called by Pgbus::DatabaseTasksGuard before every database purge/drop so an idle boot-time session on the pgbus database can never block that same process's DROP DATABASE (issue #409). Safe to call at any time: the next checkout after a disconnect reconnects transparently.

# File 'lib/pgbus/bus_record.rb', line 25

def self.disconnect_all_pools!
  connection_handler.connection_pool_list(:all).each do |pool|
    pool.disconnect! if owns_pool?(pool)
  end
end