Documentation by YARD 0.9.38

Alphabetic Index

File Listing

README

Namespace Listing A-Z

A

ActiveJob (Pgbus)
ActiveJob
Adapter (Pgbus::ActiveJob)
AddFailedEventsIndexGenerator (Pgbus::Generators)
AddJobLocksGenerator (Pgbus::Generators)
AddJobStatsGenerator (Pgbus::Generators)
AddJobStatsLatencyGenerator (Pgbus::Generators)
AddJobStatsQueueIndexGenerator (Pgbus::Generators)
AddOutboxGenerator (Pgbus::Generators)
AddPresenceGenerator (Pgbus::Generators)
AddQueueStatesGenerator (Pgbus::Generators)
AddRecurringGenerator (Pgbus::Generators)
AddStreamStatsGenerator (Pgbus::Generators)
AlreadyRecorded (Pgbus::Recurring)
Api (Pgbus)
ApplicationController (Pgbus)
ApplicationHelper (Pgbus)
ApplicationRecord (Pgbus)
Assertions (Pgbus::Testing)
AsyncPool (Pgbus::ExecutionPools)
Authentication (Pgbus::Web)
AutovacuumTuning (Pgbus)

B

Batch (Pgbus)
BatchEntry (Pgbus)
BlockedExecution (Pgbus)
BlockedExecution (Pgbus::Concurrency)
BusRecord (Pgbus)

C

CLI (Pgbus)
CapsuleDSL (Pgbus::Configuration)
CircuitBreaker (Pgbus)
Client (Pgbus)
CommandJob (Pgbus::Recurring)
Concurrency (Pgbus)
ConcurrencyLimitExceeded (Pgbus)
ConfigConverter (Pgbus::Generators)
ConfigLoader (Pgbus)
ConfigLoader (Pgbus::Recurring)
Configuration (Pgbus)
ConfigurationError (Pgbus)
ConnectMessage (Pgbus::Web::Streamer::StreamEventDispatcher)
Connection (Pgbus::Web::Streamer)
Consumer (Pgbus::Process)
ConsumerPriority (Pgbus::Process)
Cursor (Pgbus::Streams)

D

DashboardController (Pgbus)
DataSource (Pgbus::Web)
DatabaseTargetDetector (Pgbus::Generators)
DeadLetterController (Pgbus)
DeadLetterError (Pgbus)
DedupCache (Pgbus)
DisconnectMessage (Pgbus::Web::Streamer::StreamEventDispatcher)
Dispatcher (Pgbus::Process)

E

Engine (Pgbus)
EnsureStreamQueue (Pgbus::Client)
Envelope (Pgbus::Client::ReadAfter)
Envelope (Pgbus::Streams)
Error (Pgbus)
Error (Pgbus::Generators::ConfigConverter)
ErrorReporter (Pgbus)
Event (Pgbus)
EventBus (Pgbus)
EventStore (Pgbus::Testing)
EventsController (Pgbus)
ExecutionPools (Pgbus)
Executor (Pgbus::ActiveJob)

F

FailedEventRecorder (Pgbus)
FalconConnection (Pgbus::Web::Streamer)
Filters (Pgbus::Streams)
FrontendsController (Pgbus)

G

Generators (Pgbus)

H

Handler (Pgbus::EventBus)
Heartbeat (Pgbus::Process)
Heartbeat (Pgbus::Web::Streamer)

I

InsightsController (Pgbus)
InsightsController (Pgbus::Api)
InstallGenerator (Pgbus::Generators)
Instance (Pgbus::Web::Streamer)
Instrumentation (Pgbus)
InvalidCursor (Pgbus::Streams::Cursor)
InvalidSignedName (Pgbus::Streams::SignedName)
InvalidTransition (Pgbus::Process)
IoWriter (Pgbus::Web::Streamer)

J

JSON (Pgbus::LogFormatter)
JobLock (Pgbus)
JobMixin (Pgbus::RetryBackoff)
JobNotUnique (Pgbus)
JobStat (Pgbus)
JobsController (Pgbus)

K

Key (Pgbus::Streams)

L

Lifecycle (Pgbus::Process)
Listener (Pgbus::Web::Streamer)
LocaleController (Pgbus)
LocksController (Pgbus)
LogFormatter (Pgbus)

M

MetricsController (Pgbus::Api)
MetricsSerializer (Pgbus::Web)
MigrateJobLocksGenerator (Pgbus::Generators)
MigrationDetector (Pgbus::Generators)
MigrationPath (Pgbus::Generators)
MinitestHelpers (Pgbus::Testing)
MissingSecret (Pgbus::Streams::SignedName)

O

Outbox (Pgbus)
OutboxController (Pgbus)
OutboxEntry (Pgbus)

P

ParseError (Pgbus::Configuration::CapsuleDSL)
Pgbus
PgbusAdapter (ActiveJob::QueueAdapters)
PgmqSchema (Pgbus)
Poller (Pgbus::Outbox)
Presence (Pgbus::Streams)
PriorityStrategy (Pgbus::QueueFactory)
Process (Pgbus)
ProcessEntry (Pgbus)
ProcessedEvent (Pgbus)
ProcessesController (Pgbus)
Publisher (Pgbus::EventBus)

Q

QueueAdapters (ActiveJob)
QueueFactory (Pgbus)
QueueLock (Pgbus::Process)
QueueNameValidator (Pgbus)
QueueNotFoundError (Pgbus)
QueueState (Pgbus)
QueuesController (Pgbus)

R

RateCounter (Pgbus)
ReadAfter (Pgbus::Client)
Recurring (Pgbus)
RecurringExecution (Pgbus)
RecurringTask (Pgbus)
RecurringTasksController (Pgbus)
Registry (Pgbus::EventBus)
Registry (Pgbus::Web::Streamer)
RetryBackoff (Pgbus)

S

Schedule (Pgbus::Recurring)
Scheduler (Pgbus::Recurring)
SchemaNotReady (Pgbus)
Semaphore (Pgbus)
Semaphore (Pgbus::Concurrency)
SerializationError (Pgbus)
Serializer (Pgbus)
SignalHandler (Pgbus::Process)
SignedName (Pgbus::Streams)
StandardStrategy (Pgbus::QueueFactory)
StatBuffer (Pgbus)
StatsController (Pgbus::Api)
Stream (Pgbus::Streams)
StreamApp (Pgbus::Web)
StreamEnvelope (Pgbus::Web::Streamer::StreamEventDispatcher)
StreamEventDispatcher (Pgbus::Web::Streamer)
StreamNameTooLong (Pgbus::Streams)
StreamStat (Pgbus)
Streamable (Pgbus::Streams)
Streamer (Pgbus::Web)
Streams (Pgbus)
StreamsHelper (Pgbus)
Subscriber (Pgbus::EventBus)
Supervisor (Pgbus::Process)

T

Task (Pgbus::Recurring)
Testing (Pgbus)
Text (Pgbus::LogFormatter)
ThreadPool (Pgbus::ExecutionPools)
TuneAutovacuumGenerator (Pgbus::Generators)
TurboBroadcastable (Pgbus::Streams)
TurboStreamOverride (Pgbus::Streams)

U

Uniqueness (Pgbus)
UniquenessKey (Pgbus)
UpdateGenerator (Pgbus::Generators)
UpgradePgmqGenerator (Pgbus::Generators)

V

VersionNotFoundError (Pgbus::PgmqSchema)

W

WakeMessage (Pgbus::Web::Streamer::Listener)
WakeSignal (Pgbus::Process)
WatermarkCacheMiddleware (Pgbus::Streams)
Web (Pgbus)
Worker (Pgbus::Process)