class EventBus

• EventBus
• Reference
• Object

Included Modules

• /srv/crystaldoc.info/github-spider-gazelle-eventbus-main/src/eventbus/listener.cr::EventBusDBFuncs
• /srv/crystaldoc.info/github-spider-gazelle-eventbus-main/src/eventbus/listener.cr::EventBusLogger

Defined in:

eventbus.cr
eventbus/event.cr
eventbus/init.cr
eventbus/listener.cr
eventbus/task.cr

Constant Summary

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

Constructors

• .new(url : URI, *handler : EventHandler)
• .new(url : String, **options)

Instance Method Summary

• #add_handler(*handler : EventHandler)
• #close : Nil
• #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.

• #ensure_cdc_for(table : String) : Bool
• #ensure_cdc_for_all_tables : Bool
• #on_error(handler : ErrHandlerType -> )
• #remove_handler(*handler : EventHandler)
• #run : Nil
• #start : Nil
• #task_runner : TaskRunner

Constructor Detail

Instance Method Detail