refactor: rename from HordePro to Horde

Author: Adriano Santos

.envrc.example

@@ -1,2 +1,2 @@
-export POSTGRES_URL="ecto://postgres:postgres@localhost:6431/horde_pro"
+export POSTGRES_URL="ecto://postgres:postgres@localhost:6431/horde"
 export MIX_ENV=test

.github/workflows/ci.yml

@@ -7,7 +7,7 @@ jobs:
   test:
     runs-on: ubuntu-latest
     env:
-      POSTGRES_URL: "ecto://postgres:postgres@localhost:5431/horde_pro"
+      POSTGRES_URL: "ecto://postgres:postgres@localhost:5431/horde"
       MIX_ENV: "test"
 
     strategy:
@@ -31,7 +31,7 @@ jobs:
         env:
           POSTGRES_PASSWORD: postgres
           POSTGRES_USER: postgres
-          POSTGRES_DB: horde_pro
+          POSTGRES_DB: horde
           POSTGRES_PORT: 5431
 
     name: Tests
@@ -50,4 +50,4 @@ jobs:
       - run: mix format --check-formatted
         if: matrix.elixir-version == 1.17 && matrix.otp-version == 27
 
-      - run: mix do ecto.create --quiet -r HordeProTest.Repo, ecto.migrate -r HordeProTest.Repo, test
+      - run: mix do ecto.create --quiet -r HordeTest.Repo, ecto.migrate -r HordeTest.Repo, test

.gitignore

@@ -20,7 +20,7 @@ erl_crash.dump
 *.ez
 
 # Ignore package tarball (built via "mix hex.build").
-horde_pro-*.tar
+horde-*.tar
 
 # Temporary files, for example, from tests.
 /tmp/

README.md

@@ -1,36 +1,32 @@
-# HordePro
+# Horde
 <!-- MDOC !-->
 
-`HordePro` is a Postgres-backed distributed supervisor and registry.
+`Horde` is a distributed Supervisor and Registry.
 
-HordePro shares no code with Horde and has been completely re-written from the ground up, using what I learned from Horde and the better part of a decade in hindsight.
+This version of Horde reflects years of practical experience with Elixir and distributed systems. It introduces a refined architecture focused on stability, maintainability, and ease of operation, while keeping the API familiar to existing users.
 
-HordePro is backed by Postgres rather than the CRDT library that Horde uses (also written by me). I think this is a better choice for most users, since Postgres is already a singleton in most stacks, and this allows me to simplify things considerably. As such, HordePro should be more stable and easier to maintain and extend.
+One of the key design choices is the use of Postgres as the coordination back-end. Since Postgres is already a reliable singleton component in most stacks, this allows Horde to simplify its internal design and offer more predictable operational behavior.
 
-HordePro remains 99% API-compatible with `Elixir.DynamicSupervisor` and `Elixir.Registry`, and improves upon the API coverage offered in Horde.
+Horde remains 99% API-compatible with `Elixir.DynamicSupervisor` and `Elixir.Registry`, and improves upon the API coverage offered in Horde.
 
-Currently HordePro only supports Postgres as a back-end. If you are interested in running it against MariaDB or something else, please get in touch with me.
+At the moment, Horde supports Postgres as its back-end. If you are interested in using other databases, such as MariaDB, feel free to reach out.
 
-See `HordePro.DynamicSupervisor` and `HordePro.Registry` for documentation.
-
-## Getting Started
-
-Purchase a subscription to HordePro at Code Code Ship.
+Refer to `Horde.DynamicSupervisor` and `Horde.Registry` for detailed documentation.
 
 ## Installation
 
 If [available in Hex](https://hex.pm/docs/publish), the package can be installed
-by adding `horde_pro` to your list of dependencies in `mix.exs`:
+by adding `horde` to your list of dependencies in `mix.exs`:
 
 ```elixir
 def deps do
   [
-    {:horde_pro, "~> 0.1.0"}
+    {:horde, "~> 0.1.0"}
   ]
 end
 ```
 
 Documentation can be generated with [ExDoc](https://github.com/elixir-lang/ex_doc)
 and published on [HexDocs](https://hexdocs.pm). Once published, the docs can
-be found at <https://hexdocs.pm/horde_pro>.
+be found at <https://hexdocs.pm/horde>.
 

TODOS.md

@@ -21,5 +21,5 @@
 - use LISTEN / NOTIFY instead of polling in *Manager
 
 ## Considering
-- HordePro.Supervisor
+- Horde.Supervisor
   - I have seen this being requested a number of times. Sometimes people want to start a static list of processes and have them be uniformly distributed across their cluster. Perhaps we can meet this use case.

benchmarks/dynamic_supervisor_insert.exs

@@ -1,6 +1,6 @@
-defmodule HordeProTest.Repo do
+defmodule HordeTest.Repo do
   use Ecto.Repo,
-    otp_app: :horde_pro,
+    otp_app: :horde,
     adapter: Ecto.Adapters.Postgres
 
   def init(_context, config) do
@@ -13,7 +13,7 @@ defmodule HordeProTest.Repo do
   end
 end
 
-{:ok, _pid} = HordeProTest.Repo.start_link()
+{:ok, _pid} = HordeTest.Repo.start_link()
 
 Logger.configure(level: :critical)
 
@@ -38,7 +38,7 @@ Benchee.run(
       Task.async_stream(
         cases,
         fn n ->
-          HordePro.DynamicSupervisorChild.encode(
+          Horde.DynamicSupervisorChild.encode(
             %{supervisor_id: "123_123", lock_id: -2_329_838},
             self(),
             child_spec.start,
@@ -47,7 +47,7 @@ Benchee.run(
             :worker,
             []
           )
-          |> HordeProTest.Repo.insert()
+          |> HordeTest.Repo.insert()
         end,
         max_concurrency: parallel
       )
@@ -85,15 +85,15 @@ Benchee.run(
 
       pids
     end,
-    "HordePro.DynamicSupervisor.start_child/3" => fn {pids, {cases, parallel}} ->
+    "Horde.DynamicSupervisor.start_child/3" => fn {pids, {cases, parallel}} ->
       bench_pid = self()
 
       Task.async_stream(
         cases,
         fn n ->
           {:ok, _child_pid} =
-            HordePro.DynamicSupervisor.start_child(
-              {:via, PartitionSupervisor, {HordeProSupervisor, n}},
+            Horde.DynamicSupervisor.start_child(
+              {:via, PartitionSupervisor, {HordeSupervisor, n}},
               {Task,
                fn ->
                  send(bench_pid, {:msg, n})
@@ -122,14 +122,14 @@ Benchee.run(
 
     {:ok, sup1} =
       PartitionSupervisor.start_link(
-        name: HordeProSupervisor,
+        name: HordeSupervisor,
         partitions: parallel,
         child_spec:
-          HordePro.DynamicSupervisor.child_spec(
+          Horde.DynamicSupervisor.child_spec(
             strategy: :one_for_one,
             backend:
-              HordePro.Adapter.Postgres.DynamicSupervisorBackend.new(
-                repo: HordeProTest.Repo,
+              Horde.Adapter.Postgres.DynamicSupervisorBackend.new(
+                repo: HordeTest.Repo,
                 supervisor_id: "benchmark_#{ref}"
               )
           )

benchmarks/mix.exs

@@ -23,7 +23,7 @@ defmodule HordeBench.MixProject do
     [
       {:benchee, "> 0.0.0"},
       {:horde, "> 0.0.0"},
-      {:horde_pro, path: ".."},
+      {:horde, path: ".."},
       {:sql_fmt, "> 0.0.0"}
     ]
   end

benchmarks/registry_replication.exs

@@ -1,6 +1,6 @@
-defmodule HordeProTest.Repo do
+defmodule HordeTest.Repo do
   use Ecto.Repo,
-    otp_app: :horde_pro,
+    otp_app: :horde,
     adapter: Ecto.Adapters.Postgres
 
   def init(_context, config) do
@@ -13,10 +13,10 @@ defmodule HordeProTest.Repo do
   end
 end
 
-{:ok, _pid} = HordeProTest.Repo.start_link()
+{:ok, _pid} = HordeTest.Repo.start_link()
 
-defmodule HordeProTest.Telemetry do
-  def handle_event([:horde_pro_test, :repo, :query], measurements, metadata, config) do
+defmodule HordeTest.Telemetry do
+  def handle_event([:horde_test, :repo, :query], measurements, metadata, config) do
     IO.inspect(metadata, label: "METADATA")
 
     measurements
@@ -31,8 +31,8 @@ tel_attach = fn ->
   :ok =
     :telemetry.attach(
       "foo",
-      [:horde_pro_test, :repo, :query],
-      &HordeProTest.Telemetry.handle_event/4,
+      [:horde_test, :repo, :query],
+      &HordeTest.Telemetry.handle_event/4,
       %{}
     )
 end
@@ -77,10 +77,10 @@ Benchee.run(
 
       pids
     end,
-    "HordePro.Registry replication" => fn {pids, {cases, _parallel}} ->
+    "Horde.Registry replication" => fn {pids, {cases, _parallel}} ->
       Enum.each(cases, fn n ->
         Task.start_link(fn ->
-          HordePro.Registry.register(HordeProRegistry, "hello_#{n}", :value)
+          Horde.Registry.register(HordeRegistry, "hello_#{n}", :value)
           Process.sleep(20_000)
         end)
       end)
@@ -90,7 +90,7 @@ Benchee.run(
       while(fn ->
         Process.sleep(2)
 
-        last != HordePro.Registry.count(HordeProRegistry2)
+        last != Horde.Registry.count(HordeRegistry2)
       end)
 
       pids
@@ -103,7 +103,7 @@ Benchee.run(
     #   Task.async_stream(
     #     cases,
     #     fn n ->
-    #       HordePro.DynamicSupervisorChild.encode(
+    #       Horde.DynamicSupervisorChild.encode(
     #         %{supervisor_id: "123_123", lock_id: -2_329_838},
     #         self(),
     #         child_spec.start,
@@ -112,7 +112,7 @@ Benchee.run(
     #         :worker,
     #         []
     #       )
-    #       |> HordeProTest.Repo.insert()
+    #       |> HordeTest.Repo.insert()
     #     end,
     #     max_concurrency: parallel
     #   )
@@ -150,15 +150,15 @@ Benchee.run(
 
     #   pids
     # end,
-    # "HordePro.DynamicSupervisor.start_child/3" => fn {pids, {cases, parallel}} ->
+    # "Horde.DynamicSupervisor.start_child/3" => fn {pids, {cases, parallel}} ->
     #   bench_pid = self()
 
     #   Task.async_stream(
     #     cases,
     #     fn n ->
     #       {:ok, _child_pid} =
-    #         HordePro.DynamicSupervisor.start_child(
-    #           {:via, PartitionSupervisor, {HordeProSupervisor, n}},
+    #         Horde.DynamicSupervisor.start_child(
+    #           {:via, PartitionSupervisor, {HordeSupervisor, n}},
     #           {Task,
     #            fn ->
     #              send(bench_pid, {:msg, n})
@@ -202,24 +202,24 @@ Benchee.run(
     Horde.Cluster.set_members(HordeRegistry, [HordeRegistry, HordeRegistry2])
 
     {:ok, reg1} =
-      HordePro.Registry.start_link(
-        name: HordeProRegistry,
+      Horde.Registry.start_link(
+        name: HordeRegistry,
         keys: :unique,
         backend:
-          HordePro.Adapter.Postgres.RegistryBackend.new(
-            repo: HordeProTest.Repo,
+          Horde.Adapter.Postgres.RegistryBackend.new(
+            repo: HordeTest.Repo,
             registry_id: "registry_#{ref}"
           ),
         partitions: parallel
       )
 
     {:ok, reg1_2} =
-      HordePro.Registry.start_link(
-        name: HordeProRegistry2,
+      Horde.Registry.start_link(
+        name: HordeRegistry2,
         keys: :unique,
         backend:
-          HordePro.Adapter.Postgres.RegistryBackend.new(
-            repo: HordeProTest.Repo,
+          Horde.Adapter.Postgres.RegistryBackend.new(
+            repo: HordeTest.Repo,
             registry_id: "registry_#{ref}"
           ),
         partitions: parallel

docker-compose.yml

@@ -6,7 +6,7 @@ services:
     environment:
       POSTGRES_USER: postgres
       POSTGRES_PASSWORD: postgres
-      POSTGRES_DB: horde_pro
+      POSTGRES_DB: horde
       POSTGRES_PORT: 6431
     command: postgres -c shared_buffers=256MB -c max_connections=200
 

justfile

@@ -16,16 +16,16 @@ watch:
   watchexec -r --clear=reset -w . --project-origin=. --stop-timeout=0 mix test --warnings-as-errors --all-warnings
 
 watch2:
-  watchexec -r --clear=reset -w . --project-origin=. --stop-timeout=0 mix test --warnings-as-errors --all-warnings test/horde_pro/registry_test.exs
+  watchexec -r --clear=reset -w . --project-origin=. --stop-timeout=0 mix test --warnings-as-errors --all-warnings test/horde/registry_test.exs
 
 watch3:
-  watchexec -r --clear=reset -w . --project-origin=. --stop-timeout=0 mix test --warnings-as-errors --all-warnings test/horde_pro/adapter/postgres/locker_test.exs
+  watchexec -r --clear=reset -w . --project-origin=. --stop-timeout=0 mix test --warnings-as-errors --all-warnings test/horde/adapter/postgres/locker_test.exs
 
 migrate:
-  MIX_ENV=test mix ecto.migrate -r HordeProTest.Repo
+  MIX_ENV=test mix ecto.migrate -r HordeTest.Repo
 
 db_reset:
-  MIX_ENV=test mix do ecto.drop -r HordeProTest.Repo, ecto.create -r HordeProTest.Repo, ecto.migrate -r HordeProTest.Repo
+  MIX_ENV=test mix do ecto.drop -r HordeTest.Repo, ecto.create -r HordeTest.Repo, ecto.migrate -r HordeTest.Repo
 
 gen_migration MIG:
-  MIX_ENV=test mix ecto.gen.migration -r HordeProTest.Repo {{MIG}}
+  MIX_ENV=test mix ecto.gen.migration -r HordeTest.Repo {{MIG}}