class

EventBus

Inherits /tmp/tmp.jIjPEO/src/src/eventbus/listener.cr::EventBusDBFuncs < /tmp/tmp.jIjPEO/src/src/eventbus/listener.cr::EventBusLogger < Reference < Object

Constants

PARALLEL_JOBS = ((ENV["PARALLEL_JOBS"]? || ENV["PARALELL_JOBS"]?) || 1).to_i

Constructors

new(url : URI, *handler : EventHandler)

Source

new(url : String, **options)

Source

Instance methods

add_handler(*handler : EventHandler)

Source

disable_cdc_for(table : String, force : Bool = false) : Nil

No-op unless force is set: the CDC trigger is shared infrastructure that other services rely on, and dropping it takes an ACCESS EXCLUSIVE lock that queues every read on the table behind it. Pass force: true only to genuinely uninstall.

Source

ensure_cdc_for(table : String) : Bool

Source

ensure_cdc_for_all_tables

Source

on_error(handler : ErrHandlerType -> )

Source

remove_handler(*handler : EventHandler)

Source

run

Source

start