aboutsummaryrefslogtreecommitdiffstats
path: root/packages/plugins/queue-restate/src/index.ts
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2025-12-21 22:02:05 +0000
committerMohamed Bassem <me@mbassem.com>2025-12-21 22:02:05 +0000
commitdc8ab86279e302c9865fb5d5b670a62280b097c6 (patch)
treed59739273af001b9a5626fc3d7761eb415a41134 /packages/plugins/queue-restate/src/index.ts
parent58eb6c0054e87a47457f0390319c0ca91b2714a5 (diff)
downloadkarakeep-dc8ab86279e302c9865fb5d5b670a62280b097c6.tar.zst
feat(restate): Add a var to control whether to expose core services or not
Diffstat (limited to 'packages/plugins/queue-restate/src/index.ts')
-rw-r--r--packages/plugins/queue-restate/src/index.ts5
1 files changed, 3 insertions, 2 deletions
diff --git a/packages/plugins/queue-restate/src/index.ts b/packages/plugins/queue-restate/src/index.ts
index fa636f87..07082955 100644
--- a/packages/plugins/queue-restate/src/index.ts
+++ b/packages/plugins/queue-restate/src/index.ts
@@ -134,8 +134,9 @@ class RestateQueueClient implements QueueClient {
port: envConfig.RESTATE_LISTEN_PORT ?? 0,
services: [
...[...this.services.values()].map((svc) => svc.def),
- semaphore,
- idProvider,
+ ...(envConfig.RESTATE_EXPOSE_CORE_SERVICES
+ ? [semaphore, idProvider]
+ : []),
],
identityKeys: envConfig.RESTATE_PUB_KEY
? [envConfig.RESTATE_PUB_KEY]