diff --git a/apps/emqx_opentelemetry/src/emqx_opentelemetry.app.src b/apps/emqx_opentelemetry/src/emqx_opentelemetry.app.src index 7988388f4..81631b03a 100644 --- a/apps/emqx_opentelemetry/src/emqx_opentelemetry.app.src +++ b/apps/emqx_opentelemetry/src/emqx_opentelemetry.app.src @@ -1,6 +1,6 @@ {application, emqx_opentelemetry, [ {description, "OpenTelemetry for EMQX Broker"}, - {vsn, "0.2.3"}, + {vsn, "0.2.4"}, {registered, []}, {mod, {emqx_otel_app, []}}, {applications, [ diff --git a/apps/emqx_opentelemetry/src/emqx_otel_metrics.erl b/apps/emqx_opentelemetry/src/emqx_otel_metrics.erl index 757ea6a9b..185a40228 100644 --- a/apps/emqx_opentelemetry/src/emqx_otel_metrics.erl +++ b/apps/emqx_opentelemetry/src/emqx_otel_metrics.erl @@ -104,7 +104,7 @@ safe_stop_default_metrics() -> _ = opentelemetry_experimental:stop_default_metrics(), ok catch - %% noramal scenario, metrics supervisor is not started + %% normal scenario, metrics supervisor is not started exit:{noproc, _} -> ok end. @@ -254,6 +254,18 @@ create_counter(Meter, Counters, CallBack) -> Counters ). +%% Note: list_to_existing_atom("cpu.use") will crash +%% so we make sure the atom is already existing here +normalize_name(cpu_use) -> + 'cpu.use'; +normalize_name(cpu_idle) -> + 'cpu.idle'; +normalize_name(run_queue) -> + 'run.queue'; +normalize_name(total_memory) -> + 'total.memory'; +normalize_name(used_memory) -> + 'used.memory'; normalize_name(Name) -> list_to_existing_atom(lists:flatten(string:replace(atom_to_list(Name), "_", ".", all))).