Class MeshCall

Connects and links a worker function to the mesh

Example

import { Client as Postgres } from 'pg';
import { MeshCall } from '@hotmesh/meshcall';

MeshCall.connect({
  topic: 'my.function',
  connection: {
    class: Postgres,
    options: { connectionString: 'postgresql://usr:pwd@localhost:5432/db' }
  },
  callback: async (arg1: any) => {
    //your code here...
  }
});
Copy

Schedules a cron job to run at a specified interval with optional args. Provided arguments are passed to the callback function each time the cron job runs. The id option is used to uniquely identify the cron job, allowing it to be interrupted at any time.

Example

import { Client as Postgres } from 'pg';
import { MeshCall } from '@hotmesh/meshcall';

MeshCall.cron({
  topic: 'my.cron.function',
  args: ['arg1', 'arg2'], //optionally pass args
  connection: {
    class: Postgres,
    options: { connectionString: 'postgresql://usr:pwd@localhost:5432/db' }
  },
  callback: async (arg1: any, arg2: any) => {
    //your code here...
  },
  options: { id: 'myDailyCron123', interval: '0 0 * * *' }
});
Copy

Calls a function and returns the response.

Example

const response = await MeshCall.exec({
  topic: 'my.function',
  args: [{ my: 'args' }],
  connection: {
    class: Postgres,
    options: { connectionString: 'postgresql://usr:pwd@localhost:5432/db' }
  }
});
Copy

Clears a cached function response.

Example

import { Client as Postgres } from 'pg';
import { MeshCall } from '@hotmesh/meshcall';

MeshCall.flush({
  topic: 'my.function',
  connection: {
    class: Postgres,
    options: { connectionString: 'postgresql://usr:pwd@localhost:5432/db' }
  },
  options: { id: 'myCachedExecFunctionId' }
});
Copy

connection re-use is important when making repeated calls, but only if the connection options are an exact match. this method hashes the connection options to ensure that the same connection

Interrupts a running cron job. Returns true if the job was successfully interrupted, or false if the job was not found.

Example

import { Client as Postgres } from 'pg';
import { MeshCall } from '@hotmesh/meshcall';

MeshCall.interrupt({
  topic: 'my.cron.function',
  connection: {
    class: Postgres,
    options: { connectionString: 'postgresql://usr:pwd@localhost:5432/db' }
  },
  options: { id: 'myDailyCron123' }
});
Copy

Shuts down all meshcall instances. Call this method from the SIGTERM handler in your application.