Upgrade OTP versions, supporting now only 26/27/28 and adapting to enhancements

.github/workflows/main.yml

@@ -14,8 +14,8 @@ jobs:
     name: OTP ${{matrix.otp}}
     strategy:
       matrix:
-        otp: ['27', '26', '25']
-        rebar3: ['3.24.0']
+        otp: ['28', '27', '26']
+        rebar3: ['3.24']
     runs-on: 'ubuntu-24.04'
     env:
       OTPVER: ${{ matrix.otp }}
@@ -28,18 +28,17 @@ jobs:
       - run: rebar3 compile
       - run: rebar3 lint
       - run: rebar3 xref
+      - run: rebar3 dialyzer
       - run: rebar3 eunit
       - run: rebar3 fmt --check
-        if: ${{ matrix.otp == '27' }}
+        if: ${{ matrix.otp == '28' }}
       - run: rebar3 ex_doc
-        if: ${{ matrix.otp == '27' }}
-      - run: rebar3 dialyzer
-        if: ${{ matrix.otp == '27' }}
+        if: ${{ matrix.otp == '28' }}
       - run: rebar3 do cover, covertool generate
-        if: ${{ matrix.otp == '27' }}
+        if: ${{ matrix.otp == '28' }}
       - name: Upload code coverage
         uses: codecov/codecov-action@v5
-        if: ${{ matrix.otp == '27' }}
+        if: ${{ matrix.otp == '28' }}
         with:
           files: _build/test/covertool/prometheus.covertool.xml
           token: ${{ secrets.CODECOV_TOKEN }}

src/metrics/prometheus_gauge.erl

@@ -334,13 +334,15 @@ set_to_current_time(Registry, Name, LabelValues) ->
     set(Registry, Name, LabelValues, os:system_time(seconds)).
 
 ?DOC(#{equiv => track_inprogress(default, Name, [], Fun)}).
--spec track_inprogress(prometheus_metric:name(), fun(() -> any())) -> any().
+-spec track_inprogress(prometheus_metric:name(), fun(() -> dynamic())) -> dynamic().
 track_inprogress(Name, Fun) ->
     track_inprogress(default, Name, [], Fun).
 
 ?DOC(#{equiv => track_inprogress(default, Name, LabelValues, Fun)}).
--spec track_inprogress(prometheus_metric:name(), prometheus_metric:label_values(), fun(() -> any())) ->
-    any().
+-spec track_inprogress(Name, LabelValues, Fun) -> dynamic() when
+    Name :: prometheus_metric:name(),
+    LabelValues :: prometheus_metric:label_values(),
+    Fun :: fun(() -> dynamic()).
 track_inprogress(Name, LabelValues, Fun) ->
     track_inprogress(default, Name, LabelValues, Fun).
 
@@ -354,11 +356,11 @@ Raises:
 * `{invalid_metric_arity, Present, Expected}` error if labels count mismatch.
 * `{invalid_value, Value, Message}` if `Fun` isn't a function.
 """).
--spec track_inprogress(Registry, Name, LabelValues, Fun) -> any() when
+-spec track_inprogress(Registry, Name, LabelValues, Fun) -> dynamic() when
     Registry :: prometheus_registry:registry(),
     Name :: prometheus_metric:name(),
     LabelValues :: prometheus_metric:label_values(),
-    Fun :: fun(() -> any()).
+    Fun :: fun(() -> dynamic()).
 track_inprogress(Registry, Name, LabelValues, Fun) when is_function(Fun, 0) ->
     inc(Registry, Name, LabelValues, 1),
     try
@@ -370,13 +372,15 @@ track_inprogress(_Registry, _Name, _LabelValues, Fun) ->
     erlang:error({invalid_value, Fun, "track_inprogress accepts only functions"}).
 
 ?DOC(#{equiv => set_duration(default, Name, [], Fun)}).
--spec set_duration(prometheus_metric:name(), fun(() -> any())) -> any().
+-spec set_duration(prometheus_metric:name(), fun(() -> dynamic())) -> dynamic().
 set_duration(Name, Fun) ->
     set_duration(default, Name, [], Fun).
 
 ?DOC(#{equiv => set_duration(default, Name, LabelValues, Fun)}).
--spec set_duration(prometheus_metric:name(), prometheus_metric:label_values(), fun(() -> any())) ->
-    any().
+-spec set_duration(Name, LabelValues, Fun) -> dynamic() when
+    Name :: prometheus_metric:name(),
+    LabelValues :: prometheus_metric:label_values(),
+    Fun :: fun(() -> dynamic()).
 set_duration(Name, LabelValues, Fun) ->
     set_duration(default, Name, LabelValues, Fun).
 
@@ -390,11 +394,11 @@ Raises:
 * `{invalid_metric_arity, Present, Expected}` error if labels count mismatch.
 * `{invalid_value, Value, Message}` if `Fun` isn't a function.
 """).
--spec set_duration(Registry, Name, LabelValues, Fun) -> any() when
+-spec set_duration(Registry, Name, LabelValues, Fun) -> dynamic() when
     Registry :: prometheus_registry:registry(),
     Name :: prometheus_metric:name(),
     LabelValues :: prometheus_metric:label_values(),
-    Fun :: fun(() -> any()).
+    Fun :: fun(() -> dynamic()).
 set_duration(Registry, Name, LabelValues, Fun) when is_function(Fun, 0) ->
     Start = erlang:monotonic_time(),
     try

src/metrics/prometheus_histogram.erl

@@ -241,25 +241,23 @@ Raises:
     Count :: integer().
 observe_n(Registry, Name, LabelValues, Value, Count) when is_integer(Value), is_integer(Count) ->
     Key = key(Registry, Name, LabelValues),
-    try ets:lookup_element(?TABLE, Key, ?BOUNDS_POS) of
-        Buckets ->
+    case ets:lookup_element(?TABLE, Key, ?BOUNDS_POS, undefined) of
+        undefined ->
+            insert_metric(Registry, Name, LabelValues, Value, Count, fun observe_n/5);
+        Buckets when is_tuple(Buckets) ->
             BucketPosition = prometheus_buckets:position(Buckets, Value),
             Spec = [{?ISUM_POS, Value * Count}, {?BUCKETS_START + BucketPosition, Count}],
             ets:update_counter(?TABLE, Key, Spec)
-    catch
-        error:badarg ->
-            insert_metric(Registry, Name, LabelValues, Value, Count, fun observe_n/5)
     end,
     ok;
 observe_n(Registry, Name, LabelValues, Value, Count) when is_float(Value), is_integer(Count) ->
     Key = key(Registry, Name, LabelValues),
-    try ets:lookup_element(?TABLE, Key, ?BOUNDS_POS) of
-        Buckets ->
+    case ets:lookup_element(?TABLE, Key, ?BOUNDS_POS, undefined) of
+        undefined ->
+            insert_metric(Registry, Name, LabelValues, Value, Count, fun observe_n/5);
+        Buckets when is_tuple(Buckets) ->
             BucketPosition = prometheus_buckets:position(Buckets, Value),
             fobserve_impl(Key, Buckets, BucketPosition, Value, Count)
-    catch
-        error:badarg ->
-            insert_metric(Registry, Name, LabelValues, Value, Count, fun observe_n/5)
     end;
 observe_n(_Registry, _Name, _LabelValues, Value, Count) when is_number(Value) ->
     erlang:error({invalid_count, Count, "observe_n accepts only integer counts"});
@@ -305,13 +303,15 @@ pobserve(_Registry, _Name, _LabelValues, _Buckets, _Pos, Value) ->
     erlang:error({invalid_value, Value, "pobserve accepts only numbers"}).
 
 ?DOC(#{equiv => observe_duration(default, Name, [], Fun)}).
--spec observe_duration(prometheus_metric:name(), fun(() -> term())) -> term().
+-spec observe_duration(prometheus_metric:name(), fun(() -> dynamic())) -> dynamic().
 observe_duration(Name, Fun) ->
     observe_duration(default, Name, [], Fun).
 
 ?DOC(#{equiv => observe_duration(default, Name, LabelValues, Fun)}).
--spec observe_duration(prometheus_metric:name(), prometheus_metric:label_values(), fun(() -> term())) ->
-    term().
+-spec observe_duration(Name, LabelValues, Fun) -> dynamic() when
+    Name :: prometheus_metric:name(),
+    LabelValues :: prometheus_metric:label_values(),
+    Fun :: fun(() -> dynamic()).
 observe_duration(Name, LabelValues, Fun) ->
     observe_duration(default, Name, LabelValues, Fun).
 
@@ -323,11 +323,11 @@ Raises:
 * `{invalid_metric_arity, Present, Expected}` error if labels count mismatch.
 * `{invalid_value, Value, Message}` if `Fun` isn't a function.
 """).
--spec observe_duration(Registry, Name, LabelValues, Fun) -> any() when
+-spec observe_duration(Registry, Name, LabelValues, Fun) -> dynamic() when
     Registry :: prometheus_registry:registry(),
     Name :: prometheus_metric:name(),
     LabelValues :: prometheus_metric:label_values(),
-    Fun :: fun(() -> any()).
+    Fun :: fun(() -> dynamic()).
 observe_duration(Registry, Name, LabelValues, Fun) when is_function(Fun, 0) ->
     Start = erlang:monotonic_time(),
     try

src/metrics/prometheus_quantile_summary.erl

@@ -208,13 +208,15 @@ observe(_Registry, _Name, _LabelValues, Value) ->
     erlang:error({invalid_value, Value, "observe accepts only numbers"}).
 
 ?DOC(#{equiv => observe_duration(default, Name, [], Fun)}).
--spec observe_duration(prometheus_metric:name(), fun(() -> term())) -> term().
+-spec observe_duration(prometheus_metric:name(), fun(() -> dynamic())) -> dynamic().
 observe_duration(Name, Fun) ->
     observe_duration(default, Name, [], Fun).
 
 ?DOC(#{equiv => observe_duration(default, Name, LabelValues, Fun)}).
--spec observe_duration(prometheus_metric:name(), prometheus_metric:label_values(), fun(() -> term())) ->
-    term().
+-spec observe_duration(Name, LabelValues, Value) -> dynamic() when
+    Name :: prometheus_metric:name(),
+    LabelValues :: prometheus_metric:label_values(),
+    Value :: fun(() -> dynamic()).
 observe_duration(Name, LabelValues, Fun) ->
     observe_duration(default, Name, LabelValues, Fun).
 
@@ -226,11 +228,11 @@ Raises:
 * `{invalid_metric_arity, Present, Expected}` error if labels count mismatch.
 * `{invalid_value, Value, Message}` if `Fun` isn't a function.
 """).
--spec observe_duration(Registry, Name, LabelValues, Value) -> T when
+-spec observe_duration(Registry, Name, LabelValues, Value) -> dynamic() when
     Registry :: prometheus_registry:registry(),
     Name :: prometheus_metric:name(),
     LabelValues :: prometheus_metric:label_values(),
-    Value :: fun(() -> T).
+    Value :: fun(() -> dynamic()).
 observe_duration(Registry, Name, LabelValues, Fun) when is_function(Fun) ->
     Start = erlang:monotonic_time(),
     try

src/metrics/prometheus_summary.erl

@@ -184,13 +184,15 @@ observe(_Registry, _Name, _LabelValues, Value) ->
     erlang:error({invalid_value, Value, "observe accepts only numbers"}).
 
 ?DOC(#{equiv => observe_duration(default, Name, [], Fun)}).
--spec observe_duration(prometheus_metric:name(), fun(() -> term())) -> term().
+-spec observe_duration(prometheus_metric:name(), fun(() -> dynamic())) -> dynamic().
 observe_duration(Name, Fun) ->
     observe_duration(default, Name, [], Fun).
 
 ?DOC(#{equiv => observe_duration(default, Name, LabelValues, Fun)}).
--spec observe_duration(prometheus_metric:name(), prometheus_metric:label_values(), fun(() -> term())) ->
-    term().
+-spec observe_duration(Name, LabelValues, Fun) -> dynamic() when
+    Name :: prometheus_metric:name(),
+    LabelValues :: prometheus_metric:label_values(),
+    Fun :: fun(() -> dynamic()).
 observe_duration(Name, LabelValues, Fun) ->
     observe_duration(default, Name, LabelValues, Fun).
 
@@ -202,11 +204,11 @@ Raises:
 * `{invalid_metric_arity, Present, Expected}` error if labels count mismatch.
 * `{invalid_value, Value, Message}` if `Fun` isn't a function.
 """).
--spec observe_duration(Registry, Name, LabelValues, Fun) -> any() when
+-spec observe_duration(Registry, Name, LabelValues, Fun) -> dynamic() when
     Registry :: prometheus_registry:registry(),
     Name :: prometheus_metric:name(),
     LabelValues :: prometheus_metric:label_values(),
-    Fun :: fun(() -> any()).
+    Fun :: fun(() -> dynamic()).
 observe_duration(Registry, Name, LabelValues, Fun) when is_function(Fun) ->
     Start = erlang:monotonic_time(),
     try

src/prometheus.erl

@@ -9,8 +9,8 @@
 
 -behaviour(application).
 
--type label_name() :: term().
--type label_value() :: term().
+-type label_name() :: dynamic().
+-type label_value() :: dynamic().
 -type label() :: {label_name(), label_value()}.
 -type pre_rendered_labels() :: binary().
 -type labels() :: [label()] | #{label_name() => label_value()} | pre_rendered_labels().
@@ -59,16 +59,16 @@
 -export([start/2, stop/1]).
 -export([start/0, stop/0]).
 
--spec start(application:start_type(), term()) -> supervisor:startlink_ret().
+-spec start(application:start_type(), dynamic()) -> supervisor:startlink_ret().
 start(_StartType, _StartArgs) ->
     prometheus_sup:start_link().
 
--spec stop(term()) -> ok.
+-spec stop(dynamic()) -> ok.
 stop(_State) ->
     ok.
 
 ?DOC(false).
--spec start() -> ok | {error, term()}.
+-spec start() -> ok | {error, dynamic()}.
 start() ->
     case application:ensure_all_started(?MODULE) of
         {ok, _} ->
@@ -78,6 +78,6 @@ start() ->
     end.
 
 ?DOC(false).
--spec stop() -> ok | {error, term()}.
+-spec stop() -> ok | {error, dynamic()}.
 stop() ->
     application:stop(?MODULE).

src/prometheus_collector.erl

@@ -91,10 +91,10 @@ create_gauge(Name, Help, Data) ->
 -type collector() :: atom().
 
 ?DOC("Data associated with a collector").
--type data() :: any().
+-type data() :: dynamic().
 
 ?DOC("Callback for `collect_mf/3`").
--type collect_mf_callback() :: fun((prometheus_model:'MetricFamily'()) -> any()).
+-type collect_mf_callback() :: fun((prometheus_model:'MetricFamily'()) -> dynamic()).
 
 ?DOC("Should call `Callback` for each `MetricFamily` of this collector").
 -callback collect_mf(Registry, Callback) -> ok when

src/prometheus_metric.erl

@@ -75,7 +75,7 @@ as well as handling metric labels and data.
         registry => prometheus_registry:registry(),
         constant_labels => [{atom(), term()}],
         labels => labels(),
-        data => any(),
+        data => term(),
         atom() => _
     }.
 
@@ -86,7 +86,7 @@ as well as handling metric labels and data.
 -callback declare(Spec :: spec()) -> boolean().
 
 ?DOC("Sets the default metric function for the module.").
--callback set_default(Registry, Name) -> any() when
+-callback set_default(Registry, Name) -> dynamic() when
     Registry :: prometheus_registry:registry(),
     Name :: name().
 
@@ -180,7 +180,7 @@ deregister_mf(Table, Registry, Name) ->
     end.
 
 ?DOC(false).
--spec check_mf_exists(Table, Registry, Name, LabelValues) -> any() | no_return() when
+-spec check_mf_exists(Table, Registry, Name, LabelValues) -> dynamic() | no_return() when
     Table :: atom(),
     Registry :: prometheus_registry:registry(),
     Name :: name(),
@@ -213,28 +213,28 @@ check_mf_exists(Table, Registry, Name) ->
     end.
 
 ?DOC(false).
--spec mf_labels(tuple()) -> any().
+-spec mf_labels(tuple()) -> dynamic().
 mf_labels(MF) ->
     {Labels, _} = element(2, MF),
     Labels.
 
 ?DOC(false).
--spec mf_constant_labels(tuple()) -> any().
+-spec mf_constant_labels(tuple()) -> dynamic().
 mf_constant_labels(MF) ->
     element(3, MF).
 
 ?DOC(false).
--spec mf_duration_unit(tuple()) -> any().
+-spec mf_duration_unit(tuple()) -> dynamic().
 mf_duration_unit(MF) ->
     element(4, MF).
 
 ?DOC(false).
--spec mf_data(tuple()) -> any().
+-spec mf_data(tuple()) -> dynamic().
 mf_data(MF) ->
     element(5, MF).
 
 ?DOC(false).
--spec metrics(term(), term()) -> any().
+-spec metrics(ets:table(), prometheus_registry:registry()) -> dynamic().
 metrics(Table, Registry) ->
     ets:match(Table, {{Registry, mf, '$1'}, '$2', '$3', '$4', '$5'}).
 

src/prometheus_metric_spec.erl

@@ -55,7 +55,7 @@ help(Spec) ->
     validate_metric_help(Help).
 
 ?DOC(false).
--spec data(Spec :: prometheus_metric:spec()) -> any().
+-spec data(Spec :: prometheus_metric:spec()) -> dynamic().
 data(Spec) ->
     get_value(data, Spec).
 
@@ -102,7 +102,7 @@ duration_unit_from_spec(Spec) ->
     Help :: prometheus_metric:help(),
     CallTimeout :: [{atom(), term()}],
     DurationUnit :: prometheus_time:maybe_duration_unit(),
-    Data :: any().
+    Data :: dynamic().
 extract_common_params(Spec) ->
     Registry = registry(Spec),
     Name = name(Spec),
@@ -115,27 +115,27 @@ extract_common_params(Spec) ->
 
 ?DOC(false).
 ?DOC(#{equiv => get_value(Key, Spec, undefined)}).
--spec add_value(Key :: atom(), Value :: any(), Spec :: prometheus_metric:spec()) -> any().
+-spec add_value(Key :: atom(), Value :: dynamic(), Spec :: prometheus_metric:spec()) -> term().
 add_value(Key, Value, Spec) when is_list(Spec) ->
     [{Key, Value} | Spec];
 add_value(Key, Value, Spec) when is_map(Spec) ->
     Spec#{Key => Value}.
 
 ?DOC(false).
 ?DOC(#{equiv => get_value(Key, Spec, undefined)}).
--spec get_value(Key :: atom(), Spec :: prometheus_metric:spec()) -> any().
+-spec get_value(Key :: atom(), Spec :: prometheus_metric:spec()) -> term().
 get_value(Key, Spec) ->
     get_value(Key, Spec, undefined).
 
 ?DOC(false).
--spec get_value(Key :: atom(), Spec :: prometheus_metric:spec(), Default :: any()) -> any().
+-spec get_value(Key :: atom(), Spec :: prometheus_metric:spec(), Default :: dynamic()) -> dynamic().
 get_value(Key, Spec, Default) when is_list(Spec) ->
     proplists:get_value(Key, Spec, Default);
 get_value(Key, Spec, Default) when is_map(Spec) ->
     maps:get(Key, Spec, Default).
 
 ?DOC(false).
--spec fetch_value(Key :: atom(), Spec :: prometheus_metric:spec()) -> any() | no_return().
+-spec fetch_value(Key :: atom(), Spec :: prometheus_metric:spec()) -> dynamic() | no_return().
 fetch_value(Key, Spec) when is_list(Spec) ->
     case proplists:get_value(Key, Spec) of
         undefined ->