Function run

example/express.cluster.js:19–51

()

const terminus = require('../lib/terminus').createTerminus

function run () {
  const app = express()
  // Setup your express here
  // Last in line, nothing else responded
  app.use((req, res) => {
    res.status(404).send('Sorry!')
  })
  const server = http.createServer(app)
  const terminusOptions = {
    useExit0: true,
    beforeShutdown: () => {
      // https://github.com/godaddy/terminus#how-to-set-terminus-up-with-kubernetes
      const waitMS = 10_000 // default periodSeconds of livenessProbe
      console.log('received SIGTERM')
      console.log(`waiting ${waitMS} milliseconds for readinessCheck to fail`)
      return new Promise(resolve => {
        setTimeout(resolve, waitMS)
      })
    },
    onSignal: () => {
      console.log('starting cleanup')
      return Promise.resolve()
    },
    onShutdown: () => {
      console.log('BYE!')
      return Promise.resolve()
    }
  }
  terminus(server, terminusOptions)
  server.listen(8080, () => {
    console.log(`Express worker with PID: ${process.pid} started.`)
  })
}

/**
 * Shutdown the cluster workers properly