Packages
new_relic_agent
1.23.0
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/init.ex
defmodule NewRelic.Init do
@moduledoc false
alias NewRelic.Harvest.Collector
alias NewRelic.Harvest.TelemetrySdk
def run() do
verify_erlang_otp_version()
init_config()
init_features()
end
@erlang_version_requirement ">= 21.2.0"
def verify_erlang_otp_version() do
cond do
Code.ensure_loaded?(:persistent_term) -> :ok
Version.match?(System.otp_release() <> ".0.0", @erlang_version_requirement) -> :ok
true -> raise "Erlang/OTP 21.2 required to run the New Relic agent"
end
end
def init_config() do
host = determine_config(:host)
license_key = determine_config(:license_key)
region_prefix = determine_region(license_key)
collector_host = Collector.Protocol.determine_host(host, region_prefix)
telemetry_hosts = TelemetrySdk.Config.determine_hosts(host, region_prefix)
NewRelic.Config.put(%{
log: determine_config(:log),
host: host,
port: determine_config(:port, 443) |> parse_port,
scheme: determine_config(:scheme, "https"),
app_name: determine_config(:app_name) |> parse_app_names,
license_key: license_key,
harvest_enabled: determine_config(:harvest_enabled, true) |> parse_bool,
collector_host: collector_host,
region_prefix: region_prefix,
automatic_attributes: determine_automatic_attributes(),
labels: determine_config(:labels) |> parse_labels(),
telemetry_hosts: telemetry_hosts,
trace_mode: determine_trace_mode()
})
end
@region_matcher ~r/^(?<prefix>.+?)x/
def determine_region(nil), do: nil
def determine_region(license_key) do
case Regex.named_captures(@region_matcher, license_key) do
%{"prefix" => prefix} -> String.trim_trailing(prefix, "x")
_ -> nil
end
end
def init_features() do
NewRelic.Config.put(:features, %{
error_collector:
determine_feature(
"NEW_RELIC_ERROR_COLLECTOR_ENABLED",
:error_collector_enabled
),
db_query_collection:
determine_feature(
"NEW_RELIC_SQL_COLLECTION_ENABLED",
:sql_collection_enabled,
false
) ||
determine_feature(
"NEW_RELIC_DB_QUERY_COLLECTION_ENABLED",
:db_query_collection_enabled
),
ecto_instrumentation:
determine_feature(
"NEW_RELIC_ECTO_INSTRUMENTATION_ENABLED",
:ecto_instrumentation_enabled
),
redix_instrumentation:
determine_feature(
"NEW_RELIC_REDIX_INSTRUMENTATION_ENABLED",
:redix_instrumentation_enabled
),
function_argument_collection:
determine_feature(
"NEW_RELIC_FUNCTION_ARGUMENT_COLLECTION_ENABLED",
:function_argument_collection_enabled
),
request_queuing_metrics:
determine_feature(
"NEW_RELIC_REQUEST_QUEUING_METRICS_ENABLED",
:request_queuing_metrics_enabled
)
})
end
def determine_config(key, default \\ nil) when is_atom(key) do
env = key |> to_string() |> String.upcase()
System.get_env("NEW_RELIC_#{env}") ||
Application.get_env(:new_relic_agent, key, default)
end
defp determine_feature(env, config, default \\ true) do
case System.get_env(env) do
"true" -> true
"false" -> false
_ -> Application.get_env(:new_relic_agent, config, default)
end
end
defp determine_trace_mode() do
(determine_config(:infinite_tracing_trace_observer_host) && :infinite) || :sampling
end
def determine_automatic_attributes() do
Application.get_env(:new_relic_agent, :automatic_attributes, [])
|> Enum.into(%{}, fn
{name, {:system, env_var}} -> {name, System.get_env(env_var)}
{name, {m, f, a}} -> {name, apply(m, f, a)}
{name, value} -> {name, value}
end)
end
defp parse_bool(bool) when is_boolean(bool), do: bool
defp parse_bool("true"), do: true
defp parse_bool("false"), do: false
def parse_port(port) when is_integer(port), do: port
def parse_port(port) when is_binary(port), do: String.to_integer(port)
def parse_app_names(nil), do: nil
def parse_app_names(name_string) do
name_string
|> String.split(";")
|> Enum.map(&String.trim/1)
end
def parse_labels(nil), do: []
@label_splitter ~r/;|:/
def parse_labels(label_string) do
label_string
|> String.split(@label_splitter, trim: true)
|> Enum.map(&String.trim/1)
|> Enum.chunk_every(2, 2, :discard)
end
end