diff options
Diffstat (limited to 'packages/plugins-queue-restate/src/idProvider.ts')
| -rw-r--r-- | packages/plugins-queue-restate/src/idProvider.ts | 21 |
1 files changed, 0 insertions, 21 deletions
diff --git a/packages/plugins-queue-restate/src/idProvider.ts b/packages/plugins-queue-restate/src/idProvider.ts deleted file mode 100644 index ee85f46f..00000000 --- a/packages/plugins-queue-restate/src/idProvider.ts +++ /dev/null @@ -1,21 +0,0 @@ -import { Context, object, ObjectContext } from "@restatedev/restate-sdk"; - -export const idProvider = object({ - name: "IdProvider", - handlers: { - get: async (ctx: ObjectContext<{ nextId: number }>): Promise<number> => { - const state = (await ctx.get("nextId")) ?? 0; - ctx.set("nextId", state + 1); - return state; - }, - }, - options: { - ingressPrivate: true, - }, -}); - -export async function genId(ctx: Context) { - return ctx - .objectClient<typeof idProvider>({ name: "IdProvider" }, "IdProvider") - .get(); -} |
