fix: wolff_client:get_leader_connections/3 typespec

kafka4beam · May 2, 2024 · 2779625 · 2779625
1 parent 1d0a46d
commit 2779625
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 3 deletions.
diff --git a/changelog.md b/changelog.md
@@ -1,3 +1,6 @@
+* 1.10.3
+  - Fixed typespec for `wolff_client:get_leader_connections/3`.
+
 * 1.10.2 (merge 1.5.13)
   - Use long-lived metadata connection.
     This is to avoid having to excessively re-establish connection when there are many concurrent connectivity checks.

diff --git a/src/wolff.app.src b/src/wolff.app.src
@@ -1,6 +1,6 @@
 {application, wolff,
  [{description, "Kafka's publisher"},
-  {vsn, "1.10.2"},
+  {vsn, "1.10.3"},
   {registered, []},
   {applications,
    [kernel,

diff --git a/src/wolff.appup.src b/src/wolff.appup.src
@@ -1,5 +1,5 @@
 %% -*- mode: erlang; -*-
-{"1.10.2",
+{"1.10.3",
   [
   ],
   [

diff --git a/src/wolff_client.erl b/src/wolff_client.erl
@@ -99,7 +99,7 @@ get_id(Pid) ->
 get_leader_connections(Client, Topic) ->
    safe_call(Client, {get_leader_connections, Topic, all_partitions}).
 
--spec get_leader_connections(pid(), topic(), pos_integer()) ->
+-spec get_leader_connections(pid(), topic(), all_partitions | pos_integer()) ->
         {ok, [{partition(), pid() | ?conn_down(_)}]} | {error, any()}.
 get_leader_connections(Client, Topic, MaxPartitions) ->
    safe_call(Client, {get_leader_connections, Topic, MaxPartitions}).