Rename ThreadCounter -> Counter

db/migrate/create_outboxer_counters.rb

@@ -0,0 +1,25 @@
+class CreateOutboxerCounters < ActiveRecord::Migration[6.1]
+  def up
+    create_table :outboxer_counters do |t|
+      t.string  :hostname, limit: 255
+      t.integer :process_id
+      t.integer :thread_id
+
+      t.integer :publisher_id
+
+      t.integer :queued_count,     null: false
+      t.integer :publishing_count, null: false
+      t.integer :published_count,  null: false
+      t.integer :failed_count,     null: false
+
+      t.timestamps
+    end
+
+    add_index :outboxer_counters, [:hostname, :process_id, :thread_id],
+      unique: true, name: "idx_outboxer_counters_identity"
+  end
+
+  def down
+    drop_table :outboxer_counters if table_exists?(:outboxer_counters)
+  end
+end

lib/outboxer.rb

@@ -10,7 +10,7 @@
 require_relative "outboxer/models/message"
 require_relative "outboxer/models/message_count"
 require_relative "outboxer/models/message_total"
-require_relative "outboxer/models/thread_counter"
+require_relative "outboxer/models/counter"
 
 require_relative "outboxer/models/publisher"
 require_relative "outboxer/models/signal"

lib/outboxer/models/thread_counter.rb → lib/outboxer/models/counter.rb

@@ -1,7 +1,7 @@
 module Outboxer
   module Models
-    class ThreadCounter < ::ActiveRecord::Base
-      self.table_name = "outboxer_thread_counters"
+    class Counter < ::ActiveRecord::Base
+      self.table_name = "outboxer_counters"
 
       def self.insert_or_increment_by(hostname: Socket.gethostname,
                                       process_id: Process.pid,

spec/lib/outboxer/models/thread_counter_spec.rb → spec/lib/outboxer/models/counter_spec.rb

@@ -2,7 +2,7 @@
 
 module Outboxer
   module Models
-    RSpec.describe ThreadCounter, type: :model do
+    RSpec.describe Counter, type: :model do
       describe ".insert_or_increment_by" do
         let(:hostname)   { "test-host" }
         let(:process_id) { 12_345 }
@@ -11,16 +11,16 @@ module Models
 
         it "inserts a new row successfully" do
           expect do
-            ThreadCounter.insert_or_increment_by(
+            Counter.insert_or_increment_by(
               hostname: hostname,
               process_id: process_id,
               thread_id: thread_id,
               queued_count: 1,
               time: now
             )
-          end.to change(ThreadCounter, :count).by(1)
+          end.to change(Counter, :count).by(1)
 
-          row = ThreadCounter.find_by(
+          row = Counter.find_by(
             hostname: hostname,
             process_id: process_id,
             thread_id: thread_id
@@ -31,21 +31,21 @@ module Models
         end
 
         it "increments existing counts if called again" do
-          ThreadCounter.insert_or_increment_by(
+          Counter.insert_or_increment_by(
             hostname: hostname,
             process_id: process_id,
             thread_id: thread_id,
             queued_count: 1
           )
 
-          ThreadCounter.insert_or_increment_by(
+          Counter.insert_or_increment_by(
             hostname: hostname,
             process_id: process_id,
             thread_id: thread_id,
             queued_count: 2
           )
 
-          row = ThreadCounter.find_by(
+          row = Counter.find_by(
             hostname: hostname,
             process_id: process_id,
             thread_id: thread_id
@@ -55,7 +55,7 @@ module Models
         end
 
         it "updates multiple counters atomically" do
-          ThreadCounter.insert_or_increment_by(
+          Counter.insert_or_increment_by(
             hostname: hostname,
             process_id: process_id,
             thread_id: thread_id,
@@ -64,7 +64,7 @@ module Models
             failed_count: 3
           )
 
-          row = ThreadCounter.find_by(
+          row = Counter.find_by(
             hostname: hostname,
             process_id: process_id,
             thread_id: thread_id
@@ -77,15 +77,15 @@ module Models
 
         it "does not create duplicate rows on repeated calls" do
           3.times do
-            ThreadCounter.insert_or_increment_by(
+            Counter.insert_or_increment_by(
               hostname: hostname,
               process_id: process_id,
               thread_id: thread_id,
               queued_count: 1
             )
           end
 
-          count = ThreadCounter.where(
+          count = Counter.where(
             hostname: hostname,
             process_id: process_id,
             thread_id: thread_id

tasks/database.rake

@@ -28,8 +28,8 @@ namespace :outboxer do
       db_config = Outboxer::Database.config(environment: environment, pool: 1)
       ActiveRecord::Base.establish_connection(db_config)
 
-      require_relative "../db/migrate/create_outboxer_thread_counters"
-      CreateOutboxerThreadCounters.new.up
+      require_relative "../db/migrate/create_outboxer_counters"
+      CreateOutboxerCounters.new.up
 
       require_relative "../db/migrate/create_outboxer_messages"
       CreateOutboxerMessages.new.up