Ensure publisher throughput is based on messages published (#169)

db/migrate/create_outboxer_messages.rb

@@ -8,16 +8,24 @@ def up
 
       t.timestamps
 
-      t.string :updated_by_publisher_name, limit: 263
-      # 255 (hostname) + 1 (colon) + 7 (pid)
-
+      t.string :updated_by_publisher_name, limit: 263 # 255 (hostname) + 1 (colon) + 7 (pid)
       t.bigint :updated_by_publisher_id
     end
 
-    add_index :outboxer_messages, :status
-    add_index :outboxer_messages, [:status, :updated_at]
+    # messages by status count
+    add_index :outboxer_messages, :status, name: 'idx_outboxer_status'
+
+    # messages by status latency
+    add_index :outboxer_messages, [:status, :updated_at],
+      name: 'idx_outboxer_status_updated_at'
+
+    # publisher latency
+    add_index :outboxer_messages, [:updated_by_publisher_id, :updated_at],
+      name: 'idx_outboxer_pub_id_updated_at'
 
-    add_index :outboxer_messages, :updated_by_publisher_id
+    # publisher throughput
+    add_index :outboxer_messages, [:status, :updated_by_publisher_id, :updated_at],
+      name: 'idx_outboxer_status_pub_id_updated_at'
   end
 
   def down

lib/outboxer/publisher.rb

@@ -258,17 +258,18 @@ def create_heartbeat_thread(id:, name:,
                   raise NotFound.new(id: id), cause: error
                 end
 
+                end_rtt = process.clock_gettime(process::CLOCK_MONOTONIC)
+                rtt = end_rtt - start_rtt
+
                 signal = publisher.signals.order(created_at: :asc).first
 
                 if !signal.nil?
                   handle_signal(id: id, name: signal.name, logger: logger, process: process)
                   signal.destroy
                 end
 
-                end_rtt = process.clock_gettime(process::CLOCK_MONOTONIC)
-                rtt = end_rtt - start_rtt
-
-                throughput = messages = Models::Message
+                throughput = Models::Message
+                  .where(status: Models::Message::Status::PUBLISHED)
                   .where(updated_by_publisher_id: id)
                   .where('updated_at >= ?', 1.second.ago)
                   .count