import {
  createWatchdogTimer,
} from 'watchdog-timer';
 
/**
 * @property destroy Called when `reset` is not called within `timeout` interval.
 * @property reset Sets the timer's start time to the current time, and reschedules the timer to call its callback at the previously specified duration adjusted to the current time.
 */
type WatchdogTimerType = {|
  +destroy: () => void,
  +reset: () => void,
|};
 
/**
 * @property consequentTimeouts Number of consequent timeouts. Calling `reset` resets `consequentTimeouts` to `0`.
 */
type TimeoutEventType = {|
  +consequentTimeouts: number,
|};
 
/**
 * @property onTimeout Called when `reset` is not called within `timeout` interval.
 * @property timeout Timeout interval (in milliseconds).
 */
type WatchdogTimerConfigurationInputType = {|
  +onTimeout: (event: TimeoutEventType) => void,
  +timeout: number,
|};
 
 
createWatchdogTimer(configuration: WatchdogTimerConfigurationInputType) => WatchdogTimerType;
 

import {
  createWatchdogTimer,
} from 'watchdog-timer';
 
const main = async () => {
  const watchdogTimer = createWatchdogTimer({
    onTimeout: () => {
      console.error('watchdog timer timeout; forcing program termination');
 
      process.nextTick(() => {
        process.exit(1);
      });
    },
    timeout: 1000,
  });
 
  while (true) {
    // Reset watchdog-timer on each loop.
    watchdogTimer.reset();
 
    // `foo` is an arbitrary routine that might hang indefinitely,
    // e.g. due to a hanging database connection socket.
    await foo();
  }
};
 
main();
 

import {
  createWatchdogTimer,
} from 'watchdog-timer';
import {
  createLightship,
} from 'lightship';
 
const main = async () => {
  const lightship = createLightship({
    timeout: 5 * 1000,
  });
 
  lightship.signalReady();
 
  lightship.registerShutdownHandler(async () => {
    console.log('shutting down');
  });
 
  const watchdogTimer = createWatchdogTimer({
    onTimeout: () => {
      // If you do not call `destroy()`, then
      // `onTimeout` is going to be called again on the next timeout.
      watchdogTimer.destroy();
 
      lightship.shutdown();
    },
    timeout: 1000,
  });
 
  while (true) {
    if (lightship.isServerShuttingDown()) {
      console.log('detected that the service is shutting down; terminating the event loop');
 
      break;
    }
 
    // Reset watchdog-timer on each loop.
    watchdogTimer.reset();
 
    // `foo` is an arbitrary routine that might hang indefinitely,
    // e.g. due to a hanging database connection socket.
    await foo();
  }
 
  watchdogTimer.destroy();
};
 
main();