This module contains functions for RabbitMQ health checks.
Summary
Functions
Basic aliveness test. Declares a test queue, publishes and consumes a message.
Check if there are any resource alarms in the cluster.
Check if any TLS certificates expire within the given time window.
Check if there are any local resource alarms on the target node.
Check if there are classic mirrored queues without synchronised mirrors online.
Check if there is an active listener on the given port.
Check if there is an active listener for the given protocol.
Check if there are quorum queues with minimum online quorum.
Check if all virtual hosts and their resources are running.
Functions
@spec aliveness_test(client :: Tesla.Client.t(), vhost :: String.t()) :: {:ok, Tesla.Env.t()} | {:error, term()}
Basic aliveness test. Declares a test queue, publishes and consumes a message.
@spec check_alarms(client :: Tesla.Client.t()) :: {:ok, Tesla.Env.t()} | {:error, term()}
Check if there are any resource alarms in the cluster.
@spec check_certificate_expiration( client :: Tesla.Client.t(), within :: integer(), unit :: String.t() ) :: {:ok, Tesla.Env.t()} | {:error, term()}
Check if any TLS certificates expire within the given time window.
@spec check_local_alarms(client :: Tesla.Client.t()) :: {:ok, Tesla.Env.t()} | {:error, term()}
Check if there are any local resource alarms on the target node.
@spec check_mirror_sync_critical(client :: Tesla.Client.t()) :: {:ok, Tesla.Env.t()} | {:error, term()}
Check if there are classic mirrored queues without synchronised mirrors online.
@spec check_port_listener(client :: Tesla.Client.t(), port :: integer()) :: {:ok, Tesla.Env.t()} | {:error, term()}
Check if there is an active listener on the given port.
@spec check_protocol_listener(client :: Tesla.Client.t(), protocol :: String.t()) :: {:ok, Tesla.Env.t()} | {:error, term()}
Check if there is an active listener for the given protocol.
@spec check_quorum_critical(client :: Tesla.Client.t()) :: {:ok, Tesla.Env.t()} | {:error, term()}
Check if there are quorum queues with minimum online quorum.
@spec check_virtual_hosts(client :: Tesla.Client.t()) :: {:ok, Tesla.Env.t()} | {:error, term()}
Check if all virtual hosts and their resources are running.