- BASE_DATABASE_ADAPTERS =
%w[active_record sequel null].freeze
- BASE_PRODUCER_ADAPTERS =
%w[kafka null].freeze
- DEFAULT_PAYLOAD_BUILDER_BLOCK =
-> { _1 }- RUNNER_INIT_MONITOR_EVENT =
"runner.init"
- RUNNER_STOPPED_MONITOR_EVENT =
"runner.stopped"
- WORKER_RUN_MONITOR_EVENT =
"worker.run"
- WORKER_STOPPED_MONITOR_EVENT =
"worker.stopped"
- WORKER_EVENTS_PROCESSED_MONITOR_EVENT =
"worker.events.processed"
- WORKER_EXCEPTIONS_TOTAL_MONITOR_EVENT =
"worker.exceptions_total"
- EVENT_NEW_STATUS =
"new"
- EVENT_PROCESSING_STATUS =
"processing"