Class List
- ActiveJobTop Level Namespace
- QueueAdaptersActiveJob
- PgbusAdapter < ObjectActiveJob::QueueAdapters
- PgbusTop Level Namespace
- ActiveJobPgbus
- ApiPgbus
- InsightsController < ApplicationControllerPgbus::Api
- MetricsController < ApplicationControllerPgbus::Api
- StatsController < ApplicationControllerPgbus::Api
- ApplicationController < ObjectPgbus
- ApplicationHelperPgbus
- ApplicationRecord < BusRecordPgbus
- AutovacuumTuningPgbus
- Batch < ObjectPgbus
- BatchEntry < BusRecordPgbus
- BlockedExecution < BusRecordPgbus
- BusRecord < BasePgbus
- CLIPgbus
- CircuitBreaker < ObjectPgbus
- Client < ObjectPgbus
- EnsureStreamQueuePgbus::Client
- ReadAfterPgbus::Client
- Envelope < DataPgbus::Client::ReadAfter
- ConcurrencyPgbus
- BlockedExecutionPgbus::Concurrency
- SemaphorePgbus::Concurrency
- ConcurrencyLimitExceeded < ErrorPgbus
- ConfigLoaderPgbus
- Configuration < ObjectPgbus
- CapsuleDSL < ObjectPgbus::Configuration
- ParseError < ArgumentErrorPgbus::Configuration::CapsuleDSL
- ConfigurationError < ErrorPgbus
- DashboardController < ApplicationControllerPgbus
- DeadLetterController < ApplicationControllerPgbus
- DeadLetterError < ErrorPgbus
- DedupCache < ObjectPgbus
- Engine < EnginePgbus
- Error < StandardErrorPgbus
- ErrorReporterPgbus
- Event < ObjectPgbus
- EventBusPgbus
- Handler < ObjectPgbus::EventBus
- PublisherPgbus::EventBus
- Registry < ObjectPgbus::EventBus
- Subscriber < ObjectPgbus::EventBus
- EventsController < ApplicationControllerPgbus
- ExecutionPoolsPgbus
- AsyncPool < ObjectPgbus::ExecutionPools
- ThreadPool < ObjectPgbus::ExecutionPools
- FailedEventRecorder < ObjectPgbus
- FrontendsController < BasePgbus
- GeneratorsPgbus
- AddFailedEventsIndexGenerator < BasePgbus::Generators
- AddJobLocksGenerator < BasePgbus::Generators
- AddJobStatsGenerator < BasePgbus::Generators
- AddJobStatsLatencyGenerator < BasePgbus::Generators
- AddJobStatsQueueIndexGenerator < BasePgbus::Generators
- AddOutboxGenerator < BasePgbus::Generators
- AddPresenceGenerator < BasePgbus::Generators
- AddQueueStatesGenerator < BasePgbus::Generators
- AddRecurringGenerator < BasePgbus::Generators
- AddStreamStatsGenerator < BasePgbus::Generators
- ConfigConverter < ObjectPgbus::Generators
- Error < StandardErrorPgbus::Generators::ConfigConverter
- DatabaseTargetDetector < ObjectPgbus::Generators
- InstallGenerator < BasePgbus::Generators
- MigrateJobLocksGenerator < BasePgbus::Generators
- MigrationDetector < ObjectPgbus::Generators
- MigrationPathPgbus::Generators
- TuneAutovacuumGenerator < BasePgbus::Generators
- UpdateGenerator < BasePgbus::Generators
- UpgradePgmqGenerator < BasePgbus::Generators
- InsightsController < ApplicationControllerPgbus
- InstrumentationPgbus
- JobLock < BusRecordPgbus
- JobNotUnique < ErrorPgbus
- JobStat < BusRecordPgbus
- JobsController < ApplicationControllerPgbus
- LocaleController < ApplicationControllerPgbus
- LocksController < ApplicationControllerPgbus
- LogFormatterPgbus
- OutboxPgbus
- Poller < ObjectPgbus::Outbox
- OutboxController < ApplicationControllerPgbus
- OutboxEntry < BusRecordPgbus
- PgmqSchemaPgbus
- VersionNotFoundError < StandardErrorPgbus::PgmqSchema
- ProcessPgbus
- Consumer < ObjectPgbus::Process
- ConsumerPriorityPgbus::Process
- Dispatcher < ObjectPgbus::Process
- Heartbeat < ObjectPgbus::Process
- InvalidTransition < ErrorPgbus::Process
- Lifecycle < ObjectPgbus::Process
- QueueLock < ObjectPgbus::Process
- SignalHandlerPgbus::Process
- Supervisor < ObjectPgbus::Process
- WakeSignal < ObjectPgbus::Process
- Worker < ObjectPgbus::Process
- ProcessEntry < BusRecordPgbus
- ProcessedEvent < BusRecordPgbus
- ProcessesController < ApplicationControllerPgbus
- QueueFactoryPgbus
- PriorityStrategy < ObjectPgbus::QueueFactory
- StandardStrategy < ObjectPgbus::QueueFactory
- QueueNameValidatorPgbus
- QueueNotFoundError < ErrorPgbus
- QueueState < BusRecordPgbus
- QueuesController < ApplicationControllerPgbus
- RateCounter < ObjectPgbus
- RecurringPgbus
- AlreadyRecorded < ErrorPgbus::Recurring
- CommandJob < BasePgbus::Recurring
- ConfigLoaderPgbus::Recurring
- Schedule < ObjectPgbus::Recurring
- Scheduler < ObjectPgbus::Recurring
- Task < ObjectPgbus::Recurring
- RecurringExecution < BusRecordPgbus
- RecurringTask < BusRecordPgbus
- RecurringTasksController < ApplicationControllerPgbus
- RetryBackoffPgbus
- JobMixinPgbus::RetryBackoff
- SchemaNotReady < ErrorPgbus
- Semaphore < BusRecordPgbus
- SerializationError < ErrorPgbus
- SerializerPgbus
- StatBuffer < ObjectPgbus
- StreamStat < BusRecordPgbus
- StreamsPgbus
- CursorPgbus::Streams
- InvalidCursor < ArgumentErrorPgbus::Streams::Cursor
- EnvelopePgbus::Streams
- Filters < ObjectPgbus::Streams
- KeyPgbus::Streams
- Presence < ObjectPgbus::Streams
- SignedNamePgbus::Streams
- InvalidSignedName < StandardErrorPgbus::Streams::SignedName
- MissingSecret < StandardErrorPgbus::Streams::SignedName
- Stream < ObjectPgbus::Streams
- StreamNameTooLong < ArgumentErrorPgbus::Streams
- StreamablePgbus::Streams
- TurboBroadcastablePgbus::Streams
- TurboStreamOverridePgbus::Streams
- WatermarkCacheMiddleware < ObjectPgbus::Streams
- StreamsHelperPgbus
- TestingPgbus
- AssertionsPgbus::Testing
- EventStore < ObjectPgbus::Testing
- MinitestHelpersPgbus::Testing
- UniquenessPgbus
- UniquenessKey < BusRecordPgbus
- WebPgbus
- AuthenticationPgbus::Web
- DataSource < ObjectPgbus::Web
- MetricsSerializer < ObjectPgbus::Web
- StreamApp < ObjectPgbus::Web
- StreamerPgbus::Web
- Connection < ObjectPgbus::Web::Streamer
- FalconConnection < ObjectPgbus::Web::Streamer
- Heartbeat < ObjectPgbus::Web::Streamer
- Instance < ObjectPgbus::Web::Streamer
- IoWriterPgbus::Web::Streamer
- Listener < ObjectPgbus::Web::Streamer
- WakeMessage < DataPgbus::Web::Streamer::Listener
- Registry < ObjectPgbus::Web::Streamer
- StreamEventDispatcher < ObjectPgbus::Web::Streamer
- ConnectMessage < DataPgbus::Web::Streamer::StreamEventDispatcher
- DisconnectMessage < DataPgbus::Web::Streamer::StreamEventDispatcher
- StreamEnvelope < DataPgbus::Web::Streamer::StreamEventDispatcher