Skip to content

Commit 03e2f71

Browse files
authored
fix: use default storage for peep (#1651)
1 parent e1acf33 commit 03e2f71

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

lib/realtime/metrics_cleaner.ex

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,11 +38,10 @@ defmodule Realtime.MetricsCleaner do
3838
defp loop_and_cleanup_metrics_table do
3939
tenant_ids = Realtime.Tenants.Connect.list_tenants() |> MapSet.new()
4040

41-
{_, tids} = Peep.Persistent.storage(Realtime.PromEx.Metrics)
41+
{_, tid} = Peep.Persistent.storage(Realtime.PromEx.Metrics)
4242

43-
tids
44-
|> Tuple.to_list()
45-
|> Stream.flat_map(fn tid -> :ets.select(tid, @peep_filter_spec) end)
43+
tid
44+
|> :ets.select(@peep_filter_spec)
4645
|> Enum.uniq()
4746
|> Stream.reject(fn tenant_id -> MapSet.member?(tenant_ids, tenant_id) end)
4847
|> Enum.map(fn tenant_id -> %{tenant: tenant_id} end)

lib/realtime/monitoring/prom_ex.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ defmodule Realtime.PromEx do
6666

6767
defmodule Store do
6868
@moduledoc false
69-
# Custom store to set global tags and striped storage
69+
# Custom store to set global tags
7070

7171
@behaviour PromEx.Storage
7272

@@ -82,7 +82,7 @@ defmodule Realtime.PromEx do
8282
name: name,
8383
metrics: metrics,
8484
global_tags: Application.get_env(:realtime, :metrics_tags, %{}),
85-
storage: :striped
85+
storage: :default
8686
)
8787
end
8888
end

mix.exs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ defmodule Realtime.MixProject do
44
def project do
55
[
66
app: :realtime,
7-
version: "2.67.3",
7+
version: "2.67.4",
88
elixir: "~> 1.18",
99
elixirc_paths: elixirc_paths(Mix.env()),
1010
start_permanent: Mix.env() == :prod,

0 commit comments

Comments
 (0)