class

EventBus

Inherits /tmp/tmp.BeFPNK/src/src/eventbus/listener.cr::EventBusDBFuncs < /tmp/tmp.BeFPNK/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
close
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, ignore_update_columns : Array(String) | Nil = nil) : Bool
Source
ensure_cdc_for_all_tables
Source
on_error(handler : ErrHandlerType -> )
Source
remove_handler(*handler : EventHandler)
Source
replace_cdc_update_policy(table : String, ignore_update_columns : Array(String), expected_ignore_update_columns : Array(String)) : Bool

Replace a shared table policy only if the installed policy matches the expectation.

Source
start
Source
task_runner
Source

Nested types