diff --git a/src/lavinmq/http/controller/prometheus.cr b/src/lavinmq/http/controller/prometheus.cr index f739d41d7..28fc5c687 100644 --- a/src/lavinmq/http/controller/prometheus.cr +++ b/src/lavinmq/http/controller/prometheus.cr @@ -264,6 +264,10 @@ module LavinMQ value: @amqp_server.followers.size, type: "gauge", help: "Amount of follower nodes connected"}) + writer.write({name: "clustering_max_lag", + value: Config.instance.clustering_max_lag, + type: "gauge", + help: "Maximum allowed unsynced replicated messages"}) @amqp_server.followers.each do |f| writer.write({name: "follower_lag", labels: {id: f.id.to_s(36)},