FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
We should provides users with an ability to check application health in a some way. It can be reached by using multiple mechanism, so we can create a base Checker Protocol and use it the following way
We should provides users with an ability to check application health in a some way. It can be reached by using multiple mechanism, so we can create a base
Checker
Protocol and use it the following wayAnd check all of them by the same command
So, we can create multiple checkers for various cases and user can implement any checker by itself in the same time
broker.ping()
unified methodBaseCheker
usingbroker.ping()
HTTPChecker
(inheritor ofBaseCheker
)