diff --git a/CHANGELOG.md b/CHANGELOG.md index 78c8af8..4f03d9b 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -12,6 +12,12 @@ Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to --> +## 1.1.4 - 2023-09-18 + +### Changed + +- Log everything health check related with `debug` level if `auto_subscribe` is `false`. + ## 1.1.3 - 2023-07-21 ### Added diff --git a/lib/beeline/health_checker/logger.ex b/lib/beeline/health_checker/logger.ex index 13992c2..0f1bea6 100644 --- a/lib/beeline/health_checker/logger.ex +++ b/lib/beeline/health_checker/logger.ex @@ -58,38 +58,35 @@ defmodule Beeline.HealthChecker.Logger do producer = inspect(metadata[:producer]) delta = metadata[:head_position] - metadata[:current_position] log_metadata = [delta: delta, event_listener: producer] + auto_subscribe? = metadata[:auto_subscribe] - case metadata[:status] do - :up_to_date -> - Logger.debug("#{producer} is up-to-date", log_metadata) - - # coveralls-ignore-start - :caught_up -> - Logger.info("#{producer} is caught up.", log_metadata) - - :falling_behind -> - Logger.warn("#{producer} is behind: #{delta} events.", log_metadata) - - :falling_behind_more -> - Logger.warn( - "#{producer} is behind more: #{delta} events.", - log_metadata - ) - - :catching_up -> - Logger.info( - "#{producer} is behind but catching up: #{delta} events.", - log_metadata - ) - - :stuck -> - Logger.error( - "#{producer} is stuck at #{metadata[:current_position]}: behind by #{delta} events.", - log_metadata - ) - - # coveralls-ignore-stop - end + {level, msg} = + case metadata[:status] do + :up_to_date -> + {:debug, "#{producer} is up-to-date"} + + # coveralls-ignore-start + :caught_up -> + {:info, "#{producer} is caught up."} + + :falling_behind -> + {:warning, "#{producer} is behind: #{delta} events."} + + :falling_behind_more -> + {:warning, "#{producer} is behind more: #{delta} events."} + + :catching_up -> + {:info, "#{producer} is behind but catching up: #{delta} events."} + + :stuck -> + {:error, + "#{producer} is stuck at #{metadata[:current_position]}: behind by #{delta} events."} + + # coveralls-ignore-stop + end + + level = if auto_subscribe?, do: level, else: :debug + Logger.log(level, msg, log_metadata) state end