packages/plugins/queue-restate/index.ts


1
2
3
4
5
6
7
8
9
10
11
12

// Auto-register the Restate queue provider when this package is imported
import { PluginManager, PluginType } from "@karakeep/shared/plugins";

import { RestateQueueProvider } from "./src";

if (RestateQueueProvider.isConfigured()) {
  PluginManager.register({
    type: PluginType.Queue,
    name: "Restate",
    provider: new RestateQueueProvider(),
  });
}