aboutsummaryrefslogtreecommitdiffstats
path: root/packages/plugins-queue-restate/src
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2025-10-19 16:27:09 +0000
committerMohamed Bassem <me@mbassem.com>2025-10-19 16:27:09 +0000
commitcdf8121338aae0aaf69edc9c8b4244ba493cb7fc (patch)
treec99fc6d627081964ed18d3232927b7431e42351e /packages/plugins-queue-restate/src
parent2defc2475fc36635c45a449a44669048871864f6 (diff)
downloadkarakeep-cdf8121338aae0aaf69edc9c8b4244ba493cb7fc.tar.zst
fix(restate): Ensure that the semaphore and idProvider services are ingress private
Diffstat (limited to '')
-rw-r--r--packages/plugins-queue-restate/src/idProvider.ts3
-rw-r--r--packages/plugins-queue-restate/src/semaphore.ts3
2 files changed, 6 insertions, 0 deletions
diff --git a/packages/plugins-queue-restate/src/idProvider.ts b/packages/plugins-queue-restate/src/idProvider.ts
index 72ebc860..ee85f46f 100644
--- a/packages/plugins-queue-restate/src/idProvider.ts
+++ b/packages/plugins-queue-restate/src/idProvider.ts
@@ -9,6 +9,9 @@ export const idProvider = object({
return state;
},
},
+ options: {
+ ingressPrivate: true,
+ },
});
export async function genId(ctx: Context) {
diff --git a/packages/plugins-queue-restate/src/semaphore.ts b/packages/plugins-queue-restate/src/semaphore.ts
index 253dbe33..eb78f6b6 100644
--- a/packages/plugins-queue-restate/src/semaphore.ts
+++ b/packages/plugins-queue-restate/src/semaphore.ts
@@ -41,6 +41,9 @@ export const semaphore = object({
setState(ctx, state);
},
},
+ options: {
+ ingressPrivate: true,
+ },
});
function selectAndPopItem(items: QueueItem[]): QueueItem {