Class ClientService

Example

import { Durable } from '@hotmeshio/hotmesh';
import { Client as Postgres } from 'pg';

const client = new Durable.Client({
  connection: {
    class: Postgres,
    options: { connectionString: 'postgresql://usr:pwd@localhost:5432/db' },
  },
  // optional — wire lifecycle events
  events: {
    publish: (event) => {
      // event.type follows system.escalation.{id}.{verb}
      myEventBus.emit(event.type, event.data);
    },
  },
});

// Start a workflow and await its result
const handle = await client.workflow.start({
  args: ['order-123'],
  taskQueue: 'orders',
  workflowName: 'orderWorkflow',
  workflowId: Durable.guid(),
});
const result = await handle.result();

// Send a signal to a running workflow
await handle.signal('approval', { approved: true });

// Cancel a running workflow
await handle.cancel();
Copy