@@ -58,38 +58,35 @@ defmodule Beeline.HealthChecker.Logger do
58
58
producer = inspect ( metadata [ :producer ] )
59
59
delta = metadata [ :head_position ] - metadata [ :current_position ]
60
60
log_metadata = [ delta: delta , event_listener: producer ]
61
+ auto_subscribe? = metadata [ :auto_subscribe ]
61
62
62
- case metadata [ :status ] do
63
- :up_to_date ->
64
- Logger . debug ( "#{ producer } is up-to-date" , log_metadata )
65
-
66
- # coveralls-ignore-start
67
- :caught_up ->
68
- Logger . info ( "#{ producer } is caught up." , log_metadata )
69
-
70
- :falling_behind ->
71
- Logger . warn ( "#{ producer } is behind: #{ delta } events." , log_metadata )
72
-
73
- :falling_behind_more ->
74
- Logger . warn (
75
- "#{ producer } is behind more: #{ delta } events." ,
76
- log_metadata
77
- )
78
-
79
- :catching_up ->
80
- Logger . info (
81
- "#{ producer } is behind but catching up: #{ delta } events." ,
82
- log_metadata
83
- )
84
-
85
- :stuck ->
86
- Logger . error (
87
- "#{ producer } is stuck at #{ metadata [ :current_position ] } : behind by #{ delta } events." ,
88
- log_metadata
89
- )
90
-
91
- # coveralls-ignore-stop
92
- end
63
+ { level , msg } =
64
+ case metadata [ :status ] do
65
+ :up_to_date ->
66
+ { :debug , "#{ producer } is up-to-date" }
67
+
68
+ # coveralls-ignore-start
69
+ :caught_up ->
70
+ { :info , "#{ producer } is caught up." }
71
+
72
+ :falling_behind ->
73
+ { :warning , "#{ producer } is behind: #{ delta } events." }
74
+
75
+ :falling_behind_more ->
76
+ { :warning , "#{ producer } is behind more: #{ delta } events." }
77
+
78
+ :catching_up ->
79
+ { :info , "#{ producer } is behind but catching up: #{ delta } events." }
80
+
81
+ :stuck ->
82
+ { :error ,
83
+ "#{ producer } is stuck at #{ metadata [ :current_position ] } : behind by #{ delta } events." }
84
+
85
+ # coveralls-ignore-stop
86
+ end
87
+
88
+ level = if auto_subscribe? , do: level , else: :debug
89
+ Logger . log ( level , msg , log_metadata )
93
90
94
91
state
95
92
end
0 commit comments