Apio Gravity Client

Helps you to interact with Apio Gravity.

Usage

Package import

const GravityClient = require('@apio/gravity-worker')

.. or using ES6?

import GravityClient from '@apio/gravity-worker'

Usage

const client = new GravityClient({
  url: 'https://<my-gravity-url>',
  topic: '<my-topic>',
  scheduling: '*/5 * * * *'
})

client.on('job', async (job, c) => {
  console.log("New job received", job)

  // Complete with an output object
  await c.complete(job, { hello: "world" })

  // Fail with an error object
  await c.fail(job, { reason: "some_error" })

  // Return to queue as queued
  await c.return(job)
})