From 277962552d3efdbc92a6cb301e9307cc1e883a9d Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Thu, 2 May 2024 16:06:50 -0300 Subject: [PATCH] fix: `wolff_client:get_leader_connections/3` typespec --- changelog.md | 3 +++ src/wolff.app.src | 2 +- src/wolff.appup.src | 2 +- src/wolff_client.erl | 2 +- 4 files changed, 6 insertions(+), 3 deletions(-) diff --git a/changelog.md b/changelog.md index 84e1757..504a7a6 100644 --- 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 index 8866472..498e7bb 100644 --- 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 index 5a5a3a5..83ff639 100644 --- 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 index 908caa6..4563649 100644 --- 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}).