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

PARALELL_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) : Nil
• #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