Update to Nebulex v2.1.0

Author: cabol

erlang_cache/elixir_libs/nbx_cache/mix.exs

@@ -18,7 +18,7 @@ defmodule NbxCache.MixProject do
 
   defp deps do
     [
-      {:nebulex, "~> 2.0"},
+      {:nebulex, "~> 2.1"},
       {:shards, "~> 1.0"}
     ]
   end

erlang_cache/rebar.config

@@ -5,7 +5,7 @@
 ]}.
 
 {deps, [
-  {nebulex, {elixir, "nebulex", "2.0.0"}},
+  {nebulex, {elixir, "nebulex", "2.1.0"}},
   {shards, "1.0.1"}
 ]}.
 

near_cache/mix.exs

@@ -21,9 +21,9 @@ defmodule NearCache.MixProject do
 
   defp deps do
     [
-      {:nebulex, "~> 2.0"},
+      {:nebulex, "~> 2.1"},
       {:shards, "~> 1.0"},
-      {:decorator, "~> 1.3"},
+      {:decorator, "~> 1.4"},
       {:jchash, "~> 0.1", app: false}
     ]
   end

nebulex_bench/mix.exs

@@ -21,7 +21,7 @@ defmodule NebulexBench.MixProject do
 
   defp deps do
     [
-      {:nebulex, "~> 2.0"},
+      {:nebulex, "~> 2.1"},
       {:shards, "~> 1.0"},
       {:basho_bench, github: "mrallen1/basho_bench", ref: "mra-rebar3"}
     ]

nebulex_ecto_example/mix.exs

@@ -21,9 +21,9 @@ defmodule NebulexEctoExample.MixProject do
 
   defp deps do
     [
-      {:nebulex, "~> 2.0"},
+      {:nebulex, "~> 2.1"},
       {:shards, "~> 1.0"},
-      {:decorator, "~> 1.3"},
+      {:decorator, "~> 1.4"},
       {:ecto_sql, "~> 3.4"},
       {:postgrex, ">= 0.0.0"}
     ]

nebulex_telemetry_example/README.md

@@ -2,8 +2,11 @@
 
 This example illustrates how to instrument our Nebulex caches using Telemetry.
 
-See also [Nebulex.Cache.Stats](http://hexdocs.pm/nebulex/Nebulex.Cache.Stats.html)
-and [Telemetry Guide](http://hexdocs.pm/nebulex/telemetry.html).
+For more information about Telemetry events and stats, see:
+
+  * [Telemetry Events](https://hexdocs.pm/nebulex/Nebulex.Cache.html#module-telemetry-events)
+  * [Cache Stats](http://hexdocs.pm/nebulex/Nebulex.Cache.Stats.html)
+  * [Telemetry Guide](http://hexdocs.pm/nebulex/telemetry.html)
 
 ## Getting started
 
@@ -32,13 +35,27 @@ iex(7)> NebulexTelemetryExample.Cache.get 1
 nil
 ```
 
-You should see the metrics popping out:
+For the event `nebulex_telemetry_example.cache.command.stop.duration` you should
+see something like:
 
 ```
 [Telemetry.Metrics.ConsoleReporter] Got new event!
-Event name: nebulex.cache.stats
+Event name: nebulex_telemetry_example.cache.command.stop
+All measurements: %{duration: 13000}
+All metadata: %{adapter_meta: %{backend: :ets, cache: NebulexTelemetryExample.Cache, meta_tab: #Reference<0.1959874111.2908094469.85946>, pid: #PID<0.216.0>, started_at: ~U[2021-05-15 15:14:52.603317Z], stats_counter: {:write_concurrency, #Reference<0.1959874111.2908094469.85953>}, telemetry: true, telemetry_prefix: [:nebulex_telemetry_example, :cache]}, args: [1, 1, 10, :put, [ttl: 10]], function_name: :put, result: true, telemetry_span_context: #Reference<0.1959874111.2907963407.84960>}
+
+Metric measurement: #Function<4.70336728/1 in Telemetry.Metrics.maybe_convert_measurement/2> (summary)
+With value: 0.013 millisecond
+Tag values: %{cache: NebulexTelemetryExample.Cache, function_name: :put}
+```
+
+For the stats:
+
+```
+[Telemetry.Metrics.ConsoleReporter] Got new event!
+Event name: nebulex_telemetry_example.cache.stats
 All measurements: %{evictions: 2, expirations: 1, hits: 1, misses: 2, writes: 2}
-All metadata: %{cache: NebulexTelemetryExample.Cache}
+All metadata: %{cache: NebulexTelemetryExample.Cache, started_at: ~U[2021-05-15 15:14:52.603317Z]}
 
 Metric measurement: :hits (last_value)
 With value: 1
@@ -63,9 +80,13 @@ Tag values: %{cache: NebulexTelemetryExample.Cache}
 Metric measurement: :expirations (last_value)
 With value: 1
 Tag values: %{cache: NebulexTelemetryExample.Cache}
+```
 
+And for the custome event:
+
+```
 [Telemetry.Metrics.ConsoleReporter] Got new event!
-Event name: nebulex.cache.size
+Event name: nebulex_telemetry_example.cache.size
 All measurements: %{value: 0}
 All metadata: %{cache: NebulexTelemetryExample.Cache}
 

nebulex_telemetry_example/lib/nebulex_telemetry_example/cache.ex

@@ -5,7 +5,7 @@ defmodule NebulexTelemetryExample.Cache do
 
   def dispatch_cache_size do
     :telemetry.execute(
-      [:nebulex, :cache, :size],
+      [:nebulex_telemetry_example, :cache, :size],
       %{value: size()},
       %{cache: __MODULE__}
     )

nebulex_telemetry_example/lib/nebulex_telemetry_example/telemetry.ex

@@ -2,6 +2,8 @@ defmodule NebulexTelemetryExample.Telemetry do
   use Supervisor
   import Telemetry.Metrics
 
+  @telemetry_prefix "nebulex_telemetry_example.cache"
+
   def start_link(arg) do
     Supervisor.start_link(__MODULE__, arg, name: __MODULE__)
   end
@@ -21,22 +23,29 @@ defmodule NebulexTelemetryExample.Telemetry do
 
   defp metrics do
     [
-      # Nebulex Stats Metrics
-      last_value("nebulex.cache.stats.hits", tags: [:cache]),
-      last_value("nebulex.cache.stats.misses", tags: [:cache]),
-      last_value("nebulex.cache.stats.writes", tags: [:cache]),
-      last_value("nebulex.cache.stats.updates", tags: [:cache, :node]),
-      last_value("nebulex.cache.stats.evictions", tags: [:cache]),
-      last_value("nebulex.cache.stats.expirations", tags: [:cache]),
-
-      # Nebulex custom Metrics
-      last_value("nebulex.cache.size.value", tags: [:cache]),
-
-      # VM Metrics
-      summary("vm.memory.total", unit: {:byte, :kilobyte}),
-      summary("vm.total_run_queue_lengths.total"),
-      summary("vm.total_run_queue_lengths.cpu"),
-      summary("vm.total_run_queue_lengths.io")
+      # Cache command events
+      summary(
+        @telemetry_prefix <> ".command.stop.duration",
+        unit: {:native, :millisecond},
+        tags: [:cache, :function_name],
+        tag_values: &Map.put(&1, :cache, &1.adapter_meta.cache)
+      ),
+      summary(
+        @telemetry_prefix <> ".command.exception.duration",
+        unit: {:native, :millisecond},
+        tags: [:function_name, :kind]
+      ),
+
+      # Cache stats
+      last_value(@telemetry_prefix <> ".stats.hits", tags: [:cache]),
+      last_value(@telemetry_prefix <> ".stats.misses", tags: [:cache]),
+      last_value(@telemetry_prefix <> ".stats.writes", tags: [:cache]),
+      last_value(@telemetry_prefix <> ".stats.updates", tags: [:cache, :node]),
+      last_value(@telemetry_prefix <> ".stats.evictions", tags: [:cache]),
+      last_value(@telemetry_prefix <> ".stats.expirations", tags: [:cache]),
+
+      # Custom metrics
+      last_value(@telemetry_prefix <> ".size.value", tags: [:cache])
     ]
   end
 

nebulex_telemetry_example/mix.exs

@@ -22,9 +22,9 @@ defmodule NebulexTelemetryExample.MixProject do
   # Run "mix help deps" to learn about dependencies.
   defp deps do
     [
-      {:nebulex, "~> 2.0"},
-      {:decorator, "~> 1.3"},
-      {:telemetry_metrics, "~> 0.5"},
+      {:nebulex, "~> 2.1"},
+      {:decorator, "~> 1.4"},
+      {:telemetry_metrics, "~> 0.6"},
       {:telemetry_poller, "~> 0.5"},
       {:telemetry_metrics_statsd, "~> 0.5.0"}
     ]

partitioned_cache/mix.exs

@@ -21,9 +21,9 @@ defmodule PartitionedCache.MixProject do
 
   defp deps do
     [
-      {:nebulex, "~> 2.0"},
+      {:nebulex, "~> 2.1"},
       {:shards, "~> 1.0"},
-      {:decorator, "~> 1.3"},
+      {:decorator, "~> 1.4"},
       {:jchash, "~> 0.1", app: false},
       {:telemetry, "~> 0.4"},
       {:telemetry_metrics, "~> 0.6"},