Class MeshFlow

The MeshFlow service is a collection of services that emulate Temporal's capabilities, but instead are backed by Redis, ValKey, DragonflyDB, etc (whatever your chosen backend). The following lifecycle example demonstrates how to start a new workflow, subscribe to the result, and shutdown the system.

Example

import { MeshFlow, HotMesh } from '@hotmeshio/hotmesh';
import * as Redis from 'redis';
import * as workflows from './workflows';

//1) Initialize the worker
await MeshFlow.Worker.create({
  connection: {
    class: Redis,
    options: { url: 'redis://:key_admin@redis:6379' }
  },
  taskQueue: 'default',
  namespace: 'MeshFlow',
  workflow: workflows.example,
  options: {
    backoffCoefficient: 2,
    maximumAttempts: 1_000,
    maximumInterval: '5 seconds'
  }
});

//2) initialize the client
const client = new MeshFlow.Client({
  connection: {
    class: Redis,
    options: { url: 'redis://:key_admin@redis:6379' }
  }
});

//3) start a new workflow
const handle = await client.workflow.start({
  args: ['HotMesh', 'es'],
  taskQueue: 'default',
  workflowName: 'example',
  workflowId: HotMesh.guid(),
  namespace: 'meshflow', //the app name in Redis
});

//4) subscribe to the eventual result
console.log('\nRESPONSE', await handle.result(), '\n');
//logs '¡Hola, HotMesh!'

//5) Shutdown (typically on sigint)
await MeshFlow.shutdown();
Copy