Class WorkerService

The Worker service Registers worker functions and connects them to the mesh, using the target backend provider/s (Postgres, NATS, etc).

Example

import { MemFlow } from '@hotmeshio/hotmesh';
import { Client as Postgres } from 'pg';
import * as workflows from './workflows';

async function run() {
  const worker = await MemFlow.Worker.create({
    connection: {
      class: Postgres,
      options: { connectionString: 'postgres://user:password@localhost:5432/db' }
    },
    taskQueue: 'default',
    workflow: workflows.example,
  });

  await worker.run();
}
Copy