lib/logstash_writer.rb in logstash_writer-0.0.3 vs lib/logstash_writer.rb in logstash_writer-0.0.4

@@ -90,9 +90,11 @@
     }
 
     @metrics[:lag].set({}, 0)
     @metrics[:queue_size].set({}, 0)
 
+    metrics_registry.gauge(:"#{metrics_prefix}_queue_max", "The maximum size of the event queue").set({}, backlog)
+
     @queue = []
     @queue_mutex = Mutex.new
     @queue_cv    = ConditionVariable.new
 
     @socket_mutex = Mutex.new