lib/karafka/web/processing/consumers/contracts/aggregated_stats.rb in karafka-web-0.7.10 vs lib/karafka/web/processing/consumers/contracts/aggregated_stats.rb in karafka-web-0.8.0.rc1

@@ -18,13 +18,17 @@
             required(:busy) { |val| val.is_a?(Integer) && val >= 0 }
             required(:enqueued) { |val| val.is_a?(Integer) && val >= 0 }
             required(:workers) { |val| val.is_a?(Integer) && val >= 0 }
             required(:processes) { |val| val.is_a?(Integer) && val >= 0 }
             required(:rss) { |val| val.is_a?(Numeric) && val >= 0 }
-            required(:listeners) { |val| val.is_a?(Integer) && val >= 0 }
             required(:utilization) { |val| val.is_a?(Numeric) && val >= 0 }
             required(:lag_stored) { |val| val.is_a?(Integer) }
             required(:lag) { |val| val.is_a?(Integer) }
+
+            nested(:listeners) do
+              required(:active) { |val| val.is_a?(Integer) && val >= 0 }
+              required(:standby) { |val| val.is_a?(Integer) && val >= 0 }
+            end
           end
         end
       end
     end
   end