from checks.crons import CronsCheck
from checks.events import EventsCheck
from checks.hpsearch import HPSearchCheck
from checks.k8s_events import K8SEventsCheck
from checks.pipelines import PipelinesCheck
from checks.postgres import PostgresCheck
from checks.rabbitmq import RabbitMQCheck
from checks.redis import RedisCheck
from checks.scheduler import SchedulerCheck
from checks.streams import StreamsCheck


def get_status():
    status = {}
    status.update(CronsCheck.run())
    status.update(EventsCheck.run())
    status.update(K8SEventsCheck.run())
    status.update(HPSearchCheck.run())
    status.update(PipelinesCheck.run())
    status.update(PostgresCheck.run())
    status.update(RabbitMQCheck.run())
    status.update(RedisCheck.run())
    status.update(SchedulerCheck.run())
    status.update(StreamsCheck.run())
    return {k: v.to_dict() for k, v in status.items()}

from checks.crons import CronsCheck
from checks.events import EventsCheck
from checks.hpsearch import HPSearchCheck
from checks.k8s_events import K8SEventsCheck
from checks.logs import LogsCheck
from checks.pipelines import PipelinesCheck
from checks.postgres import PostgresCheck
from checks.rabbitmq import RabbitMQCheck
from checks.redis import RedisCheck
from checks.scheduler import SchedulerCheck
from checks.streams import StreamsCheck


def get_status():
    status = {}
    status.update(CronsCheck.run())
    status.update(EventsCheck.run())
    status.update(LogsCheck.run())
    status.update(K8SEventsCheck.run())
    status.update(HPSearchCheck.run())
    status.update(PipelinesCheck.run())
    status.update(PostgresCheck.run())
    status.update(RabbitMQCheck.run())
    status.update(RedisCheck.run())
    status.update(SchedulerCheck.run())
    status.update(StreamsCheck.run())
    return {k: v.to_dict() for k, v in status.items()}

Bump version to 0.2.9 (Add logs checks)