✨ rxjs-probe ✨

rxjs-probe provides an interface similar to Kubernetes probes using RxJS to detect service health.

🔗 Link

Github
npm

📥 Install

npm i rxjs @rxjs-probe/core

🔑 Usage

import { Probe, ProbePerformer } from '@rxjs-probe/core';
import axios from 'axios';

const probe = new Probe({
  performer: new ProbePerformer(async timeoutSeconds => {
    await axios({
      url: 'https://github.com/a179346/rxjs-probe',
      timeout: timeoutSeconds * 1000,
      validateStatus: status => status === 200,
    });
  }),
  initialDelaySeconds: 3,
  periodSeconds: 2,
  timeoutSeconds: 1,
  successThreshold: 1,
  failureThreshold: 3,
});

const probeObservable = probe.createObservable();

probeObservable is an RxJS Observable. You can subscribe to it to get the probe status.

Check the RxJS documentation - Observable for more information.

📖 Examples

You can find more examples on how to use rxjs-probe in rxjs-probe-examples GitHub repository.

🔎 Probe Performers

Probe Performer - The customizable health check performer
Http Probe Performer - Sending HTTP GET requests to perform the health check.

🤝 Contributing

Contributions, issues and feature requests are welcome!
Feel free to check issues page.

🌟 Show your support

Give a ⭐️ if this project helped you!

📝 License

This README was generated with ❤️ by readme-md-generator