From 20c8bda33ae2b4f40d1f4463d1da809ea6d94b34 Mon Sep 17 00:00:00 2001 From: Diego Imbert Date: Wed, 28 May 2025 18:54:46 +0200 Subject: [PATCH] oss file for kafka triggers ee --- backend/windmill-api/src/kafka_triggers_oss.rs | 13 +++++++++++++ 1 file changed, 13 insertions(+) create mode 100644 backend/windmill-api/src/kafka_triggers_oss.rs diff --git a/backend/windmill-api/src/kafka_triggers_oss.rs b/backend/windmill-api/src/kafka_triggers_oss.rs new file mode 100644 index 0000000000..85e5a2166c --- /dev/null +++ b/backend/windmill-api/src/kafka_triggers_oss.rs @@ -0,0 +1,13 @@ +use crate::db::DB; +use axum::Router; + +pub fn workspaced_service() -> Router { + crate::kafka_triggers_ee::workspaced_service() +} + +pub fn start_kafka_consumers( + _db: DB, + mut _killpill_rx: tokio::sync::broadcast::Receiver<()>, +) -> () { + crate::kafka_triggers_ee::start_kafka_consumers(_db, _killpill_rx) +}