Packages
new_relic_agent
1.17.0-rc.1
1.40.3
1.40.2
1.40.1
1.40.0
1.39.0
1.38.0
1.37.0
1.36.0
1.35.0
1.34.0
1.33.0
1.32.0
1.31.1
1.31.0
1.30.0
1.29.0
1.28.0
1.27.8
1.27.7
1.27.6
1.27.5
1.27.4
1.27.3
1.27.2
1.27.1
1.27.0
1.26.0
1.25.3
1.25.2
1.25.1
1.25.0
1.24.5
1.24.4
1.24.3
1.24.2
1.24.1
1.24.0
1.24.0-rc.10
1.24.0-rc.9
1.24.0-rc.8
1.24.0-rc.7
1.23.6
1.23.5
1.23.4
1.23.3
1.23.2
1.23.1
1.23.0
1.23.0-rc.6
1.23.0-rc.5
1.23.0-rc.4
1.23.0-rc.3
1.23.0-rc.2
1.23.0-rc.1
1.22.6
1.22.5
1.22.4
1.22.3
1.22.2
1.22.1
1.22.0
1.21.2
1.21.1
1.21.0
1.21.0-rc.3
1.21.0-rc.1
1.20.0
1.20.0-rc.1
1.19.7
1.19.6
1.19.5
1.19.4
1.19.3
1.19.2
1.19.1
1.19.0
1.18.5
1.18.4
1.18.3
1.18.2
1.18.1
1.18.0
1.18.0-rc.5
1.18.0-rc.4
1.18.0-rc.2
1.18.0-rc.1
1.17.1
1.17.0
1.17.0-rc.4
1.17.0-rc.3
1.17.0-rc.2
1.17.0-rc.1
1.17.0-rc.0
1.16.7
1.16.6
1.16.5
1.16.4
1.16.3
1.16.2
1.16.1
1.16.0
1.16.0-rc.2
1.16.0-rc.1
1.16.0-rc.0
1.15.0
1.15.0-rc.3
1.15.0-rc.2
1.15.0-rc.1
1.14.0
1.13.1
1.13.0
1.12.0
1.11.0
1.10.2
1.10.1
1.10.0
1.9.12
1.9.11
1.9.10
1.9.9
1.9.8
1.9.7
1.9.6
1.9.5
1.9.4
1.9.3
1.9.2
1.9.1
1.9.0
1.8.0
1.7.0
1.6.2
1.6.1
1.6.0
1.5.0
1.4.0
1.3.2
1.3.1
1.3.0
1.2.1
1.2.0
1.1.0
1.0.5
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
New Relic's Open-Source Elixir Agent
Current section
Files
Jump to
Current section
Files
lib/new_relic/harvest/collector/metric_data.ex
defmodule NewRelic.Harvest.Collector.MetricData do
# Heper functions for generating Metrics with the correct timeslice values
@moduledoc false
alias NewRelic.Metric
def transform(:http_dispatcher, duration_s: duration_s),
do: %Metric{
name: :HttpDispatcher,
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
def transform({:transaction, name},
type: type,
duration_s: duration_s
),
do: [
%Metric{
name: "#{type}Transaction",
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
},
%Metric{
name: "#{type}Transaction/all",
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
},
%Metric{
name: join(["#{type}Transaction", name]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
},
# UI doesn't handle Elixir's level of concurrency so great
# sending just call count improves things
%Metric{
name: "#{type}TransactionTotalTime",
call_count: 1
},
%Metric{
name: join(["#{type}TransactionTotalTime", name]),
call_count: 1
}
]
def transform(
{:caller, parent_type, parent_account_id, parent_app_id, transport_type},
duration_s: duration_s
),
do: [
%Metric{
name:
join([
"DurationByCaller",
parent_type,
parent_account_id,
parent_app_id,
transport_type,
"all"
]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
]
def transform({:datastore, datastore, table, operation}, duration_s: duration_s),
do: [
%Metric{
name: join(["Datastore/statement", datastore, table, operation]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
},
%Metric{
name: join(["Datastore/operation", datastore, operation]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
},
%Metric{
name: join(["Datastore", datastore, "all"]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
]
def transform({:external, url, component, method}, duration_s: duration_s) do
host = URI.parse(url).host
method = method |> to_string() |> String.upcase()
[
%Metric{
name: :"External/all",
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
},
%Metric{
name: join(["External", host, "all"]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
},
%Metric{
name: join(["External", host, component, method]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
]
end
def transform({:external, url, component, method},
type: type,
scope: scope,
duration_s: duration_s
) do
host = URI.parse(url).host
method = method |> to_string() |> String.upcase()
[
%Metric{
name: join(["External", host, component, method]),
scope: join(["#{type}Transaction", scope]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
]
end
def transform({:external, name}, duration_s: duration_s),
do: [
%Metric{
name: :"External/all",
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
},
%Metric{
name: join(["External", name, "all"]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
]
def transform({:external, name}, type: type, scope: scope, duration_s: duration_s),
do: %Metric{
name: join(["External", name]),
scope: join(["#{type}Transaction", scope]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
def transform(:external, type: type, duration_s: duration_s) do
%Metric{
name: "External/all#{type}",
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
end
def transform({:function, function_name},
duration_s: duration_s,
exclusive_time_s: exclusive_time_s
) do
%Metric{
name: join(["Function", function_name]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: exclusive_time_s,
min_call_time: duration_s,
max_call_time: duration_s
}
end
def transform({:function, function_name},
type: type,
scope: scope,
duration_s: duration_s,
exclusive_time_s: exclusive_time_s
) do
%Metric{
name: join(["Function", function_name]),
scope: join(["#{type}Transaction", scope]),
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: exclusive_time_s,
min_call_time: duration_s,
max_call_time: duration_s
}
end
def transform(:error, error_count: error_count),
do: %Metric{
name: :"Errors/all",
call_count: error_count
}
def transform(:memory, mb: memory_mb),
do: %Metric{
name: :"Memory/Physical",
call_count: 1,
total_call_time: memory_mb
}
def transform(:cpu, utilization: utilization),
do: %Metric{
name: :"CPU/User Time",
call_count: 1,
total_call_time: utilization
}
def transform(:apdex, apdex: :satisfying, threshold: t),
do: %Metric{name: :Apdex, call_count: 1, min_call_time: t, max_call_time: t}
def transform(:apdex, apdex: :tolerating, threshold: t),
do: %Metric{name: :Apdex, total_call_time: 1, min_call_time: t, max_call_time: t}
def transform(:apdex, apdex: :frustrating, threshold: t),
do: %Metric{name: :Apdex, total_exclusive_time: 1, min_call_time: t, max_call_time: t}
def transform({:supportability, :error_event}, error_count: error_count),
do: [
%Metric{
name: :"Supportability/Events/TransactionError/Sent",
call_count: error_count
},
%Metric{
name: :"Supportability/Events/TransactionError/Seen",
call_count: error_count
}
]
def transform({:supportability, harvester}, reservoir_size: reservoir_size),
do: [
%Metric{
name: join(["Supportability/EventHarvest", harvester, "HarvestLimit"]),
call_count: 1,
total_call_time: reservoir_size
}
]
def transform({:supportability, harvester}, harvest_size: harvest_size),
do: [
%Metric{
name: join(["Supportability/Elixir/Collector/HarvestSize", harvester]),
call_count: 1,
total_call_time: harvest_size
},
%Metric{
name: :"Supportability/Elixir/Harvest",
call_count: 1
},
%Metric{
name: :"Supportability/Harvest",
call_count: 1
}
]
def transform({:supportability, :collector}, status: status),
do: [
%Metric{
name: join(["Supportability/Agent/Collector/HTTPError", status]),
call_count: 1
}
]
def transform(:supportability, [:trace_context, :accept, :success]),
do: [
%Metric{name: :"Supportability/TraceContext/Accept/Success", call_count: 1}
]
def transform(:supportability, [:trace_context, :accept, :exception]),
do: [
%Metric{name: :"Supportability/TraceContext/Accept/Exception", call_count: 1}
]
def transform(:supportability, [:trace_context, :tracestate, :non_new_relic]),
do: [
%Metric{name: :"Supportability/TraceContext/TraceState/NoNrEntry", call_count: 1}
]
def transform(:supportability, [:trace_context, :traceparent, :invalid]),
do: [
%Metric{name: :"Supportability/TraceContext/TraceParent/Parse/Exception", call_count: 1}
]
def transform(:supportability, [:dt, :accept, :success]),
do: [
%Metric{name: :"Supportability/DistributedTrace/AcceptPayload/Success", call_count: 1}
]
def transform(:supportability, [:dt, :accept, :parse_error]),
do: [
%Metric{
name: :"Supportability/DistributedTrace/AcceptPayload/ParseException",
call_count: 1
}
]
def transform(:supportability, [:transaction, :missing_attributes]),
do: [
%Metric{
name: :"Supportability/Transaction/MissingAttributes",
call_count: 1
}
]
def transform(:queue_time, duration_s: duration_s) do
[
%Metric{
name: "WebFrontend/QueueTime",
call_count: 1,
total_call_time: duration_s,
total_exclusive_time: duration_s,
min_call_time: duration_s,
max_call_time: duration_s
}
]
end
defp join(segments), do: NewRelic.Util.metric_join(segments)
end