@ cadence- mq/ core

CadenceMQ的核心任务、工作、司机、客户和工人合同.

V1API正在积极开发中,目前还不稳定.

import { createCadence, defineHandler, defineTask } from '@cadence-mq/core';
import { memory } from '@cadence-mq/driver-memory';
import * as v from 'valibot';

const greet = defineTask({
  name: 'greet',
  schema: v.object({ name: v.string() }),
});

const cadence = createCadence({ driver: memory() });
const worker = cadence.createWorker({
  handlers: [
    defineHandler(greet, async ({ name }) => {
      await sendGreeting(name);
    }),
  ],
});

await cadence.enqueue(greet, { name: 'Ada' });
await worker.start();

// Stops this client's workers before closing its driver.
await cadence.close();

逾期未交的时间表

如果工期过后,该工人将为其长期工作创造一份工作 nextRunAt 财务报告和审定财务报表 在解剖学上将光标推到严格在驾驶员索赔后的第一次克龙事件 时间。 干扰被忽略的勾选会被跳过,而不是重放或搜索最近的事件 . 日程安排工作不会随着被忽略的滴数而增加.

测试驱动程序

驱动程序可运行专用测试中共享的高级行为套件 切入点 :

import { runDriverTestSuite } from '@cadence-mq/core/driver-test';
import { describe } from 'vitest';

describe('custom driver', () => {
  runDriverTestSuite({
    createDriver: () => createCustomDriver(),
  });
});

工厂每一次测试都必须返回一名新鲜而孤立的司机. 套房关闭每个司机 剧情结束了.

许可证

麻省理工学院