Method List

Classes Methods Files

Search:

#[] Pgbus::Event
acquire Pgbus::Concurrency::Semaphore
acquire! Pgbus::JobLock
acquire! Pgbus::Semaphore
acquire! Pgbus::UniquenessKey
acquire_enqueue_lock Pgbus::Uniqueness
acquire_execution_lock Pgbus::Uniqueness
#active? Pgbus::Process::Lifecycle
#allowed_global_id_models Pgbus::Configuration
apply Pgbus::ConfigLoader
apply_capsule_filter Pgbus::CLI
apply_role_filter Pgbus::CLI
apply_start_options Pgbus::CLI
#archive_batch Pgbus::Client
#archive_message Pgbus::Client
#archive_retention Pgbus::Configuration
#arguments Pgbus::Recurring::Task
#assert_no_pgbus_published Pgbus::Testing::Assertions
#assert_pgbus_published Pgbus::Testing::Assertions
auth_warned Pgbus::Web::Authentication
#available_capacity Pgbus::ExecutionPools::AsyncPool
#available_capacity Pgbus::ExecutionPools::ThreadPool
available_versions Pgbus::PgmqSchema
avg_duration_by_class Pgbus::JobStat
avg_latency_by_queue Pgbus::JobStat
#base_controller_class Pgbus::Configuration
#batch_id Pgbus::Batch
#beat Pgbus::Process::Heartbeat
#before_setup Pgbus::Testing::MinitestHelpers
#bind_topic Pgbus::Client
#broadcast Pgbus::Streams::Stream
#broadcast_stream_to Pgbus::Streams::TurboBroadcastable
build Pgbus::ExecutionPools
build_event_data Pgbus::EventBus::Publisher
#build_payload Pgbus::Recurring::Schedule
#call Pgbus::LogFormatter::Text
#call Pgbus::LogFormatter::JSON
#call Pgbus::Web::StreamApp
#call Pgbus::Streams::WatermarkCacheMiddleware
call_handler Pgbus::ErrorReporter
#can_process? Pgbus::Process::Lifecycle
#capacity Pgbus::ExecutionPools::AsyncPool
#capacity Pgbus::ExecutionPools::ThreadPool
#capsule Pgbus::Configuration
#capsule_named Pgbus::Configuration
#circuit_breaker_enabled Pgbus::Configuration
claim_for_execution! Pgbus::JobLock
#class_name Pgbus::Recurring::Task
cleanup Pgbus::Batch
cleanup! Pgbus::JobStat
cleanup! Pgbus::StreamStat
cleanup_expired! Pgbus::JobLock
#clear! Pgbus::Testing::EventStore
#clear! Pgbus::DedupCache
#clear! Pgbus::EventBus::Registry
clear! Pgbus::FailedEventRecorder
client Pgbus
#client Pgbus::ActiveJob::Executor
#close Pgbus::Client
#close Pgbus::Web::Streamer::Connection
#close Pgbus::Web::Streamer::FalconConnection
#command Pgbus::Recurring::Task
comment Pgbus::Streams::Envelope
compute_delay Pgbus::RetryBackoff
compute_delay_for_job Pgbus::RetryBackoff
#config Pgbus::Client
#config Pgbus::Outbox::Poller
#config Pgbus::Process::Worker
#config Pgbus::CircuitBreaker
#config Pgbus::Process::Consumer
#config Pgbus::Process::Dispatcher
#config Pgbus::Process::Supervisor
#config Pgbus::ActiveJob::Executor
#config Pgbus::Recurring::Scheduler
configuration Pgbus
configure Pgbus
#configure_active_job Pgbus::Generators::InstallGenerator
#configure_separate_database Pgbus::Generators::InstallGenerator
#connection Pgbus::Web::Streamer::StreamEventDispatcher::ConnectMessage
#connection Pgbus::Web::Streamer::StreamEventDispatcher::DisconnectMessage
#connection_options Pgbus::Configuration
#connection_params Pgbus::Configuration
#connections_for Pgbus::Web::Streamer::Registry
#connects_to Pgbus::Configuration
#context Pgbus::Web::Streamer::Connection
#context Pgbus::Web::Streamer::FalconConnection
#convert_yaml_if_present Pgbus::Generators::UpdateGenerator
#count Pgbus::RateCounter
#count Pgbus::Streams::Presence
count_for Pgbus::Concurrency::BlockedExecution
#counts Pgbus::RateCounter
#create_binstub Pgbus::Generators::InstallGenerator
#create_config_file Pgbus::Generators::InstallGenerator
#create_migration_file Pgbus::Generators::InstallGenerator
#create_migration_file Pgbus::Generators::AddOutboxGenerator
#create_migration_file Pgbus::Generators::AddPresenceGenerator
#create_migration_file Pgbus::Generators::UpgradePgmqGenerator
#create_migration_file Pgbus::Generators::AddJobLocksGenerator
#create_migration_file Pgbus::Generators::AddJobStatsGenerator
#create_migration_file Pgbus::Generators::AddRecurringGenerator
#create_migration_file Pgbus::Generators::TuneAutovacuumGenerator
#create_migration_file Pgbus::Generators::AddQueueStatesGenerator
#create_migration_file Pgbus::Generators::AddStreamStatsGenerator
#create_migration_file Pgbus::Generators::MigrateJobLocksGenerator
#create_migration_file Pgbus::Generators::AddJobStatsLatencyGenerator
#create_migration_file Pgbus::Generators::AddFailedEventsIndexGenerator
#create_migration_file Pgbus::Generators::AddJobStatsQueueIndexGenerator
#create_recurring_config Pgbus::Generators::AddRecurringGenerator
current Pgbus::Web::Streamer
current= Pgbus::Web::Streamer
current_context Pgbus::LogFormatter
#current_msg_id Pgbus::Streams::Stream
current_value Pgbus::Concurrency::Semaphore
#database_url Pgbus::Configuration
#dead? Pgbus::Web::Streamer::Connection
#dead? Pgbus::Web::Streamer::FalconConnection
#dead_letter_queue_name Pgbus::Configuration
dedup_cache Pgbus::EventBus::Handler
#default_priority Pgbus::Configuration
#default_queue Pgbus::Configuration
#delete_batch Pgbus::Client
#delete_message Pgbus::Client
#description Pgbus::Batch
#description Pgbus::Recurring::Task
deserialize_event Pgbus::Serializer
deserialize_job Pgbus::Serializer
#destroy Pgbus::QueuesController
#detect Pgbus::Generators::DatabaseTargetDetector
#detect_and_install_missing_migrations Pgbus::Generators::UpdateGenerator
detect_env Pgbus::Recurring::ConfigLoader
disabled! Pgbus::Testing
disabled? Pgbus::Testing
#discard Pgbus::JobsController
#discard Pgbus::LocksController
#discard Pgbus::EventsController
#discard Pgbus::DeadLetterController
#discard_all Pgbus::JobsController
#discard_all Pgbus::LocksController
#discard_all Pgbus::DeadLetterController
#discard_all_dlq Pgbus::Web::DataSource
#discard_all_enqueued Pgbus::Web::DataSource
#discard_all_enqueued Pgbus::JobsController
#discard_all_failed Pgbus::Web::DataSource
#discard_all_locks Pgbus::Web::DataSource
#discard_dlq_message Pgbus::Web::DataSource
#discard_event Pgbus::Web::DataSource
#discard_failed_event Pgbus::Web::DataSource
#discard_job Pgbus::Web::DataSource
#discard_lock Pgbus::Web::DataSource
#discard_locks Pgbus::Web::DataSource
#discard_message Pgbus::QueuesController
#discard_selected Pgbus::LocksController
#discard_selected Pgbus::EventsController
#discard_selected Pgbus::DeadLetterController
#discard_selected_enqueued Pgbus::JobsController
#discard_selected_events Pgbus::Web::DataSource
#discard_selected_failed Pgbus::JobsController
#dispatch_interval Pgbus::Configuration
#dispatch_queue Pgbus::Web::Streamer::Instance
#dispatcher Pgbus::Web::Streamer::Instance
#display_post_install Pgbus::Generators::UpdateGenerator
#display_post_install Pgbus::Generators::InstallGenerator
#display_post_install Pgbus::Generators::AddOutboxGenerator
#display_post_install Pgbus::Generators::AddPresenceGenerator
#display_post_install Pgbus::Generators::AddJobLocksGenerator
#display_post_install Pgbus::Generators::AddJobStatsGenerator
#display_post_install Pgbus::Generators::AddRecurringGenerator
#display_post_install Pgbus::Generators::TuneAutovacuumGenerator
#display_post_install Pgbus::Generators::AddQueueStatesGenerator
#display_post_install Pgbus::Generators::AddStreamStatsGenerator
#display_post_install Pgbus::Generators::MigrateJobLocksGenerator
#display_post_install Pgbus::Generators::AddJobStatsLatencyGenerator
#display_post_install Pgbus::Generators::AddFailedEventsIndexGenerator
#display_post_install Pgbus::Generators::AddJobStatsQueueIndexGenerator
#display_post_upgrade Pgbus::Generators::UpgradePgmqGenerator
#dlq_message_detail Pgbus::Web::DataSource
#dlq_messages Pgbus::Web::DataSource
#drain! Pgbus::Testing::EventStore
#draining? Pgbus::Process::Lifecycle
drop_pgmq_functions_sql Pgbus::PgmqSchema
#drop_queue Pgbus::Client
#drop_queue Pgbus::Web::DataSource
#due_tasks Pgbus::Recurring::Schedule
#each_connection Pgbus::Web::Streamer::Registry
#edit_event_payload Pgbus::Web::DataSource
#edit_payload Pgbus::EventsController
effective_polling_interval Pgbus::Process::ConsumerPriority
#empty? Pgbus::Web::Streamer::Registry
#enqueue Pgbus::Batch
#enqueue Pgbus::ActiveJob::Adapter
#enqueue Pgbus::Web::Streamer::Connection
#enqueue Pgbus::Web::Streamer::FalconConnection
#enqueue Pgbus::RecurringTasksController
#enqueue_after_transaction_commit? ActiveJob::QueueAdapters::PgbusAdapter
#enqueue_all Pgbus::ActiveJob::Adapter
#enqueue_at Pgbus::ActiveJob::Adapter
#enqueue_recurring_task_now Pgbus::Web::DataSource
#enqueue_task Pgbus::Recurring::Schedule
#enqueued_at Pgbus::Client::ReadAfter::Envelope
#enqueued_at Pgbus::Web::Streamer::StreamEventDispatcher::StreamEnvelope
#ensure! Pgbus::Streams::Stream
#ensure_all_queues Pgbus::Client
#ensure_dead_letter_queue Pgbus::Client
#ensure_listening Pgbus::Web::Streamer::Listener
#ensure_queue Pgbus::Client
#ensure_stream_queue Pgbus::Client::EnsureStreamQueue
#error_reporters Pgbus::Configuration
#errors Pgbus::Recurring::Task
#event_consumers Pgbus::Configuration
#event_id Pgbus::Event
#events Pgbus::Testing::EventStore
#execute Pgbus::ActiveJob::Executor
#execution_mode Pgbus::Configuration
#execution_mode Pgbus::Process::Worker
#execution_mode Pgbus::Process::Consumer
#execution_mode_for Pgbus::Configuration
exists? Pgbus::FailedEventRecorder
expire_stale Pgbus::Concurrency::Semaphore
expire_stale Pgbus::Concurrency::BlockedExecution
extract_key Pgbus::Uniqueness
extract_key Pgbus::Concurrency
extract_strategy Pgbus::Uniqueness
#failed_event Pgbus::Web::DataSource
#failed_events Pgbus::Web::DataSource
#failed_events_count Pgbus::Web::DataSource
fake! Pgbus::Testing
fake? Pgbus::Testing
filters Pgbus::Streams
find Pgbus::Batch
#flush Pgbus::StatBuffer
flush! Pgbus::Outbox
#flush_if_due Pgbus::StatBuffer
#flush_interval Pgbus::StatBuffer
#flush_size Pgbus::StatBuffer
for Pgbus::QueueFactory
from_configuration Pgbus::Recurring::Task
from_hash Pgbus::Generators::ConfigConverter
from_yaml Pgbus::Generators::ConfigConverter
#graceful_shutdown Pgbus::Outbox::Poller
#graceful_shutdown Pgbus::Process::Worker
#graceful_shutdown Pgbus::Process::Consumer
#graceful_shutdown Pgbus::Process::Dispatcher
#graceful_shutdown Pgbus::Process::Supervisor
#graceful_shutdown Pgbus::Recurring::Scheduler
#graceful_shutdown Pgbus::Process::SignalHandler
#handle Pgbus::EventBus::Handler
#handler_class Pgbus::EventBus::Subscriber
#handler_class_for_queue Pgbus::Web::DataSource
#handler_queue_physical_names Pgbus::Web::DataSource
#handlers_for Pgbus::EventBus::Registry
#headers Pgbus::Event
#heartbeat Pgbus::Web::Streamer::Instance
#held_queues Pgbus::Process::QueueLock
http_response_headers Pgbus::Streams::Envelope
#human_schedule Pgbus::Recurring::Task
#id Pgbus::Web::Streamer::Connection
#id Pgbus::Web::Streamer::FalconConnection
#idempotency_ttl Pgbus::Configuration
idempotent! Pgbus::EventBus::Handler
idempotent? Pgbus::EventBus::Handler
#idle? Pgbus::ExecutionPools::AsyncPool
#idle? Pgbus::ExecutionPools::ThreadPool
#idle_for Pgbus::Web::Streamer::Connection
#idle_for Pgbus::Web::Streamer::FalconConnection
#immediate_shutdown Pgbus::Outbox::Poller
#immediate_shutdown Pgbus::Process::Worker
#immediate_shutdown Pgbus::Process::Consumer
#immediate_shutdown Pgbus::Process::Dispatcher
#immediate_shutdown Pgbus::Process::Supervisor
#immediate_shutdown Pgbus::Recurring::Scheduler
#immediate_shutdown Pgbus::Process::SignalHandler
included Pgbus::Process::SignalHandler
#increment Pgbus::RateCounter
increment_counter! Pgbus::BatchEntry
#index Pgbus::JobsController
#index Pgbus::LocksController
#index Pgbus::EventsController
#index Pgbus::OutboxController
#index Pgbus::QueuesController
#index Pgbus::ProcessesController
#index Pgbus::DeadLetterController
#index Pgbus::RecurringTasksController
#initialize Pgbus::Batch
#initialize Pgbus::Event
#initialize Pgbus::Client
#initialize Pgbus::Streams::Stream
#initialize Pgbus::Testing::EventStore
#initialize Pgbus::DedupCache
#initialize Pgbus::StatBuffer
#initialize Pgbus::RateCounter
#initialize Pgbus::Configuration
#initialize Pgbus::Outbox::Poller
#initialize Pgbus::QueueFactory::StandardStrategy
#initialize Pgbus::QueueFactory::PriorityStrategy
#initialize Pgbus::Process::Worker
#initialize Pgbus::Recurring::Task
#initialize Pgbus::Web::StreamApp
#initialize Pgbus::CircuitBreaker
#initialize Pgbus::Streams::Filters
#initialize Pgbus::Web::DataSource
#initialize Pgbus::Process::Consumer
#initialize Pgbus::Streams::Presence
#initialize Pgbus::Process::Heartbeat
#initialize Pgbus::Process::Lifecycle
#initialize Pgbus::EventBus::Registry
#initialize Pgbus::Process::Dispatcher
#initialize Pgbus::Process::QueueLock
#initialize Pgbus::Process::Supervisor
#initialize Pgbus::Recurring::Schedule
#initialize Pgbus::ActiveJob::Executor
#initialize Pgbus::Process::WakeSignal
#initialize Pgbus::Recurring::Scheduler
#initialize Pgbus::EventBus::Subscriber
#initialize Pgbus::Web::Streamer::Instance
#initialize Pgbus::Web::Streamer::Listener
#initialize Pgbus::Web::Streamer::Registry
#initialize Pgbus::Web::MetricsSerializer
#initialize Pgbus::Web::Streamer::Heartbeat
#initialize Pgbus::Web::Streamer::Connection
#initialize Pgbus::Configuration::CapsuleDSL
#initialize Pgbus::ExecutionPools::AsyncPool
#initialize Pgbus::ExecutionPools::ThreadPool
#initialize Pgbus::Generators::ConfigConverter
#initialize Pgbus::Generators::MigrationDetector
#initialize Pgbus::Web::Streamer::FalconConnection
#initialize Pgbus::Streams::WatermarkCacheMiddleware
#initialize Pgbus::Generators::DatabaseTargetDetector
#initialize Pgbus::Web::Streamer::StreamEventDispatcher
inject_metadata Pgbus::Uniqueness
inject_metadata Pgbus::Concurrency
inline! Pgbus::Testing
inline? Pgbus::Testing
insert Pgbus::Concurrency::BlockedExecution
#insights_default_minutes Pgbus::Configuration
install_sql Pgbus::PgmqSchema
install_turbo_broadcastable_patch! Pgbus::Streams
install_turbo_stream_override! Pgbus::Streams
instrument Pgbus::Instrumentation
#interruptible_sleep Pgbus::Process::SignalHandler
#invalidate_cache Pgbus::CircuitBreaker
#io Pgbus::Web::Streamer::Connection
#io Pgbus::Web::Streamer::FalconConnection
#job_class Pgbus::Recurring::Task
job_completed Pgbus::Batch
#job_detail Pgbus::Web::DataSource
job_discarded Pgbus::Batch
#job_locks Pgbus::Web::DataSource
#job_stats_summary Pgbus::Web::DataSource
#job_status_counts Pgbus::Web::DataSource
#job_throughput Pgbus::Web::DataSource
#jobs Pgbus::Web::DataSource
#join Pgbus::Streams::Presence
js_modules Pgbus::FrontendsController
#key Pgbus::Recurring::Task
#kill Pgbus::ExecutionPools::AsyncPool
#kill Pgbus::ExecutionPools::ThreadPool
last_execution Pgbus::RecurringExecution
#last_msg_id_sent Pgbus::Web::Streamer::Connection
#last_msg_id_sent Pgbus::Web::Streamer::FalconConnection
#last_run_at Pgbus::Recurring::Scheduler
#latency_by_queue Pgbus::Web::DataSource
latency_columns? Pgbus::JobStat
latency_trend Pgbus::JobStat
#latency_trend Pgbus::Web::DataSource
latest_version Pgbus::PgmqSchema
#leave Pgbus::Streams::Presence
list_queues Pgbus::CLI
#list_queues Pgbus::Client
#listen_notify Pgbus::Configuration
#listener Pgbus::Web::Streamer::Instance
#listening_to Pgbus::Web::Streamer::Listener
load Pgbus::ConfigLoader
load Pgbus::Recurring::ConfigLoader
loader Pgbus
locate_global_id Pgbus::Serializer
locked? Pgbus::JobLock
#locked? Pgbus::Process::QueueLock
locked? Pgbus::UniquenessKey
log_error Pgbus::ErrorReporter
#log_format Pgbus::Configuration
logger Pgbus
#logger Pgbus::Configuration
logger= Pgbus
#lookup Pgbus::Streams::Filters
#lookup Pgbus::Web::Streamer::Registry
#mark! Pgbus::DedupCache
#mark_dead! Pgbus::Web::Streamer::Connection
#mark_dead! Pgbus::Web::Streamer::FalconConnection
#mark_event_handled Pgbus::Web::DataSource
#mark_handled Pgbus::EventsController
max_active_priority Pgbus::Process::ConsumerPriority
#max_jobs_per_worker Pgbus::Configuration
#max_memory_mb Pgbus::Configuration
#max_retries Pgbus::Configuration
#max_worker_lifetime Pgbus::Configuration
#members Pgbus::Streams::Presence
message Pgbus::Streams::Envelope
#message_exists? Pgbus::Client
#metadata Pgbus::ExecutionPools::AsyncPool
#metadata Pgbus::ExecutionPools::ThreadPool
#metrics Pgbus::Client
#metrics_enabled Pgbus::Configuration
#missing_migrations Pgbus::Generators::MigrationDetector
mode Pgbus::Testing
mode! Pgbus::Testing
models_loader Pgbus
#module Pgbus::FrontendsController
#move_to_dead_letter Pgbus::Client
#msg_id Pgbus::Client::ReadAfter::Envelope
#msg_id Pgbus::Web::Streamer::StreamEventDispatcher::StreamEnvelope
#mutex Pgbus::Web::Streamer::Connection
#mutex Pgbus::Web::Streamer::FalconConnection
#name Pgbus::Streams::Stream
name_from Pgbus::Streams::Stream
#names Pgbus::RateCounter
#next_time Pgbus::Recurring::Task
normalize Pgbus::Streams::Key
normalize Pgbus::QueueNameValidator
normalize_mode Pgbus::ExecutionPools
#notify! Pgbus::Process::WakeSignal
#on Pgbus::Process::Lifecycle
#on_discard Pgbus::Batch
#on_finish Pgbus::Batch
#on_success Pgbus::Batch
#outbox_batch_size Pgbus::Configuration
#outbox_enabled Pgbus::Configuration
#outbox_entries Pgbus::Web::DataSource
#outbox_poll_interval Pgbus::Configuration
#outbox_retention Pgbus::Configuration
#outbox_stats Pgbus::Web::DataSource
parse Pgbus::Streams::Cursor
parse Pgbus::Configuration::CapsuleDSL
#parse Pgbus::Configuration::CapsuleDSL
parse_start_options Pgbus::CLI
#parsed_schedule Pgbus::Recurring::Task
#pattern Pgbus::EventBus::Subscriber
#pause Pgbus::QueuesController
#pause! Pgbus::CircuitBreaker
pause! Pgbus::QueueState
#pause_queue Pgbus::Web::DataSource
#paused? Pgbus::CircuitBreaker
#paused? Pgbus::Process::Lifecycle
paused? Pgbus::QueueState
#payload Pgbus::Event
#payload Pgbus::Client::ReadAfter::Envelope
#payload Pgbus::Web::Streamer::StreamEventDispatcher::StreamEnvelope
#pending? Pgbus::Process::WakeSignal
#pending_events Pgbus::Web::DataSource
#perform Pgbus::Recurring::CommandJob
#perform_published_events Pgbus::Testing::Assertions
#pgbus Pgbus::ApplicationController
#pgbus_duration Pgbus::ApplicationHelper
#pgbus_json_preview Pgbus::ApplicationHelper
#pgbus_locale_flag Pgbus::ApplicationHelper
#pgbus_locale_name Pgbus::ApplicationHelper
#pgbus_mobile_nav_link Pgbus::ApplicationHelper
#pgbus_ms_duration Pgbus::ApplicationHelper
#pgbus_nav_link Pgbus::ApplicationHelper
#pgbus_number Pgbus::ApplicationHelper
#pgbus_parse_message Pgbus::ApplicationHelper
#pgbus_paused_badge Pgbus::ApplicationHelper
#pgbus_published_events Pgbus::Testing::Assertions
#pgbus_queue_badge Pgbus::ApplicationHelper
#pgbus_recurring_health_badge Pgbus::ApplicationHelper
#pgbus_refresh_interval Pgbus::ApplicationHelper
#pgbus_status_badge Pgbus::ApplicationHelper
#pgbus_stream_from Pgbus::StreamsHelper
#pgbus_time_ago Pgbus::ApplicationHelper
#pgbus_time_ago_future Pgbus::ApplicationHelper
#pgbus_time_range_label Pgbus::ApplicationHelper
#pgmq Pgbus::Client
#pgmq_schema_mode Pgbus::Configuration
#physical_queue_names Pgbus::QueueFactory::StandardStrategy
#physical_queue_names Pgbus::QueueFactory::PriorityStrategy
#poll_and_publish Pgbus::Outbox::Poller
#polling_interval Pgbus::Configuration
#pool_size Pgbus::Configuration
#pool_timeout Pgbus::Configuration
#post Pgbus::ExecutionPools::AsyncPool
#post Pgbus::ExecutionPools::ThreadPool
#prefetch_limit Pgbus::Configuration
#presence Pgbus::Streams::Stream
#previous_time Pgbus::Recurring::Task
print_help Pgbus::CLI
#priority Pgbus::Recurring::Task
#priority? Pgbus::QueueFactory::StandardStrategy
#priority? Pgbus::QueueFactory::PriorityStrategy
#priority_levels Pgbus::Configuration
#priority_queue_name Pgbus::Configuration
#priority_queue_names Pgbus::Configuration
#process Pgbus::EventBus::Handler
#process_entry Pgbus::Process::Heartbeat
#process_signals Pgbus::Process::SignalHandler
#processed_event Pgbus::Web::DataSource
#processed_events Pgbus::Web::DataSource
#processed_events_count Pgbus::Web::DataSource
#processes Pgbus::Web::DataSource
promote_next Pgbus::Concurrency::BlockedExecution
#properties Pgbus::Batch
publish Pgbus::Outbox
publish Pgbus::EventBus::Publisher
publish_event Pgbus::Outbox
publish_later Pgbus::EventBus::Publisher
#publish_to_topic Pgbus::Client
#published_at Pgbus::Event
#purge Pgbus::QueuesController
#purge_archive Pgbus::Client
#purge_queue Pgbus::Client
#purge_queue Pgbus::Web::DataSource
#push Pgbus::StatBuffer
#push_event Pgbus::Testing::EventStore
#queue_detail Pgbus::Web::DataSource
#queue_health_detail Pgbus::Web::DataSource
#queue_health_stats Pgbus::Web::DataSource
#queue_name Pgbus::Configuration
#queue_name Pgbus::Recurring::Task
#queue_name Pgbus::EventBus::Subscriber
#queue_name Pgbus::Web::Streamer::Listener::WakeMessage
queue_name_budget Pgbus::Streams::Key
#queue_paused? Pgbus::Web::DataSource
#queue_prefix Pgbus::Configuration
#queues Pgbus::Process::Worker
#queues_with_metrics Pgbus::Web::DataSource
#rate Pgbus::RateCounter
#rates Pgbus::RateCounter
#read_after Pgbus::Streams::Stream
#read_after Pgbus::Client::ReadAfter
#read_batch Pgbus::Client
#read_batch_prioritized Pgbus::Client
#read_message Pgbus::Client
#read_multi Pgbus::Client
#read_with_poll Pgbus::Client
reap_orphaned! Pgbus::JobLock
record Pgbus::RecurringExecution
record! Pgbus::JobStat
record! Pgbus::StreamStat
record! Pgbus::FailedEventRecorder
#record_failure Pgbus::CircuitBreaker
#record_success Pgbus::CircuitBreaker
#recurring_execution_retention Pgbus::Configuration
#recurring_schedule_interval Pgbus::Configuration
#recurring_task Pgbus::Web::DataSource
#recurring_tasks Pgbus::Configuration
#recurring_tasks Pgbus::Web::DataSource
#recurring_tasks_count Pgbus::Web::DataSource
#recurring_tasks_file Pgbus::Configuration
#register Pgbus::Streams::Filters
#register Pgbus::Web::Streamer::Instance
#register Pgbus::Web::Streamer::Registry
#registered_subscribers Pgbus::Web::DataSource
#registry Pgbus::Web::Streamer::Instance
release Pgbus::Concurrency::Semaphore
release! Pgbus::JobLock
release! Pgbus::UniquenessKey
release_lock Pgbus::Uniqueness
release_next Pgbus::Concurrency::BlockedExecution
release_next! Pgbus::BlockedExecution
#remove_listening Pgbus::Web::Streamer::Listener
#render Pgbus::Generators::ConfigConverter
#replay Pgbus::EventsController
#replay_event Pgbus::Web::DataSource
report Pgbus::ErrorReporter
#reroute Pgbus::EventsController
#reroute_event Pgbus::Web::DataSource
reset! Pgbus
reset! Pgbus::Web::Streamer
#reset! Pgbus::Process::WakeSignal
reset_client! Pgbus
reset_filters! Pgbus::Streams
resolve_key Pgbus::Uniqueness
resolve_key Pgbus::Concurrency
#resolved_pool_size Pgbus::Configuration
#restore_signals Pgbus::Process::SignalHandler
#resume Pgbus::QueuesController
#resume! Pgbus::CircuitBreaker
resume! Pgbus::QueueState
#resume_queue Pgbus::Web::DataSource
#retry Pgbus::JobsController
#retry Pgbus::DeadLetterController
#retry_all Pgbus::JobsController
#retry_all Pgbus::DeadLetterController
#retry_all_dlq Pgbus::Web::DataSource
#retry_all_failed Pgbus::Web::DataSource
#retry_backoff Pgbus::Configuration
#retry_backoff_jitter Pgbus::Configuration
#retry_backoff_max Pgbus::Configuration
retry_directive Pgbus::Streams::Envelope
#retry_dlq_message Pgbus::Web::DataSource
#retry_failed_event Pgbus::Web::DataSource
#retry_job Pgbus::Web::DataSource
#retry_message Pgbus::QueuesController
#return_to_app_url Pgbus::Configuration
#role_enabled? Pgbus::Configuration
#roles Pgbus::Configuration
#routing_key Pgbus::Event
#run Pgbus::Outbox::Poller
#run Pgbus::Process::Worker
#run Pgbus::Process::Consumer
#run Pgbus::Process::Dispatcher
#run Pgbus::Process::Supervisor
#run Pgbus::Recurring::Scheduler
#running? Pgbus::Process::Lifecycle
sanitize! Pgbus::QueueNameValidator
#schedule Pgbus::Recurring::Task
#schedule Pgbus::Recurring::Scheduler
#seen? Pgbus::DedupCache
#send_batch Pgbus::Client
#send_message Pgbus::Client
#serialize Pgbus::Web::MetricsSerializer
serialize_event Pgbus::Serializer
serialize_job Pgbus::Serializer
serialize_job_hash Pgbus::Serializer
#set_visibility_timeout Pgbus::Client
#setup! Pgbus::EventBus::Subscriber
#setup_all! Pgbus::EventBus::Registry
#setup_signals Pgbus::Process::SignalHandler
short_id Pgbus::Streams::Key
#short_id Pgbus::Streams::Streamable
should_yield? Pgbus::Process::ConsumerPriority
#show Pgbus::JobsController
#show Pgbus::EventsController
#show Pgbus::QueuesController
#show Pgbus::InsightsController
#show Pgbus::Api::StatsController
#show Pgbus::DashboardController
#show Pgbus::Api::MetricsController
#show Pgbus::DeadLetterController
#show Pgbus::Api::InsightsController
#show Pgbus::RecurringTasksController
show_status Pgbus::CLI
#shutdown Pgbus::ExecutionPools::AsyncPool
#shutdown Pgbus::ExecutionPools::ThreadPool
#shutdown! Pgbus::Web::Streamer::Instance
#shutdown? Pgbus::ExecutionPools::AsyncPool
sign Pgbus::Streams::SignedName
#size Pgbus::Testing::EventStore
#size Pgbus::DedupCache
#size Pgbus::StatBuffer
#size Pgbus::Web::Streamer::Registry
#skip_recurring Pgbus::Configuration
slowest_classes Pgbus::JobStat
#slowest_job_classes Pgbus::Web::DataSource
#snapshot! Pgbus::RateCounter
#source Pgbus::Client::ReadAfter::Envelope
#source Pgbus::Web::Streamer::StreamEventDispatcher::StreamEnvelope
sql_for_all_queues Pgbus::AutovacuumTuning
sql_for_high_churn_tables Pgbus::AutovacuumTuning
sql_for_queue Pgbus::AutovacuumTuning
sql_for_version Pgbus::PgmqSchema
sql_path Pgbus::PgmqSchema
start Pgbus::CLI
#start Pgbus::Process::Heartbeat
#start Pgbus::Web::Streamer::Instance
#start Pgbus::Web::Streamer::Listener
#start Pgbus::Web::Streamer::Heartbeat
#start Pgbus::Web::Streamer::StreamEventDispatcher
start_supervisor Pgbus::CLI
#starting? Pgbus::Process::Lifecycle
#state Pgbus::Process::Lifecycle
#static Pgbus::FrontendsController
#stats Pgbus::Process::Worker
#stats_enabled Pgbus::Configuration
#stats_retention Pgbus::Configuration
status_counts Pgbus::JobStat
#stop Pgbus::StatBuffer
#stop Pgbus::Process::Heartbeat
#stop Pgbus::Web::Streamer::Listener
#stop Pgbus::Web::Streamer::Heartbeat
#stop Pgbus::Web::Streamer::StreamEventDispatcher
#stopped? Pgbus::Process::Lifecycle
stopping Pgbus
#stopping? ActiveJob::QueueAdapters::PgbusAdapter
store Pgbus::Testing
stream Pgbus
#stream_current_msg_id Pgbus::Client::ReadAfter
stream_key Pgbus
stream_key Pgbus::Streams::Key
#stream_name Pgbus::Web::Streamer::Connection
#stream_name Pgbus::Web::Streamer::FalconConnection
#stream_oldest_msg_id Pgbus::Client::ReadAfter
#stream_stats_available? Pgbus::Web::DataSource
#stream_stats_summary Pgbus::Web::DataSource
#streams Pgbus::Web::Streamer::Registry
#streams_default_retention Pgbus::Configuration
#streams_enabled Pgbus::Configuration
#streams_falcon_streaming_body Pgbus::Configuration
#streams_heartbeat_interval Pgbus::Configuration
#streams_idle_timeout Pgbus::Configuration
#streams_listen_health_check_ms Pgbus::Configuration
#streams_max_connections Pgbus::Configuration
#streams_path Pgbus::Configuration
#streams_queue_prefix Pgbus::Configuration
#streams_retention Pgbus::Configuration
#streams_signed_name_secret Pgbus::Configuration
#streams_stats_enabled Pgbus::Configuration
#streams_test_mode Pgbus::Configuration
#streams_write_deadline_ms Pgbus::Configuration
#subscribe Pgbus::EventBus::Registry
#subscribers Pgbus::EventBus::Registry
summary Pgbus::JobStat
summary Pgbus::StreamStat
#summary_stats Pgbus::Web::DataSource
#sweep! Pgbus::Streams::Presence
sync_from_config! Pgbus::RecurringTask
table_exists? Pgbus::JobStat
table_exists? Pgbus::StreamStat
#target_queue Pgbus::QueueFactory::StandardStrategy
#target_queue Pgbus::QueueFactory::PriorityStrategy
#task_statuses Pgbus::Recurring::Scheduler
#tasks Pgbus::Recurring::Schedule
teardown_models_loader! Pgbus
#terminal? Pgbus::Process::Lifecycle
#threads Pgbus::Process::Worker
#threads Pgbus::Process::Consumer
throughput Pgbus::JobStat
throughput Pgbus::StreamStat
#tick Pgbus::Recurring::Scheduler
#tick Pgbus::Web::Streamer::Heartbeat
tid Pgbus::LogFormatter
#to_h Pgbus::Event
#to_h Pgbus::RateCounter
#to_h Pgbus::Recurring::Task
#to_stream_key Pgbus::Streams::Streamable
#toggle Pgbus::RecurringTasksController
#toggle_recurring_task Pgbus::Web::DataSource
#top_streams Pgbus::Web::DataSource
top_streams Pgbus::StreamStat
#topics Pgbus::Process::Consumer
#touch Pgbus::Streams::Presence
#transaction Pgbus::Client
#transition_to Pgbus::Process::Lifecycle
#transition_to! Pgbus::Process::Lifecycle
#try_lock Pgbus::Process::QueueLock
#turbo_stream_from Pgbus::Streams::TurboStreamOverride
uniqueness_config Pgbus::Uniqueness
#unlock Pgbus::Process::QueueLock
#unlock_all Pgbus::Process::QueueLock
#unregister Pgbus::Web::Streamer::Registry
#update Pgbus::LocaleController
#valid? Pgbus::Recurring::Task
#validate! Pgbus::Configuration
validate! Pgbus::QueueNameValidator
validate_name_length! Pgbus::Streams::Stream
#validate_streams! Pgbus::Configuration
verify! Pgbus::Streams::SignedName
version_tracking_extension_sql Pgbus::PgmqSchema
version_tracking_sql Pgbus::PgmqSchema
#visibility_timeout Pgbus::Configuration
#visible? Pgbus::Streams::Filters
#visible_to Pgbus::Web::Streamer::StreamEventDispatcher::StreamEnvelope
#wait Pgbus::Process::WakeSignal
#wait_for_termination Pgbus::ExecutionPools::AsyncPool
#wait_for_termination Pgbus::ExecutionPools::ThreadPool
#web_auth Pgbus::Configuration
#web_data_source Pgbus::Configuration
#web_live_updates Pgbus::Configuration
#web_per_page Pgbus::Configuration
#web_refresh_interval Pgbus::Configuration
with_context Pgbus::LogFormatter
#workers Pgbus::Configuration
write Pgbus::Web::Streamer::IoWriter
#write_comment Pgbus::Web::Streamer::Connection
#write_comment Pgbus::Web::Streamer::FalconConnection
#write_sentinel Pgbus::Web::Streamer::Connection
#write_sentinel Pgbus::Web::Streamer::FalconConnection
#zombie_detection Pgbus::Configuration