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

HexDocs

Current section

Files

Jump to

Readme 148 Versions 7 Dependencies 8 Dependants Files Activity

new_relic_agent lib new_relic metric metric_data.ex

Raw

lib/new_relic/metric/metric_data.ex

defmodule NewRelic.Metric.MetricData do
  # Heper functions for generating Metrics with the correct timeslice values

  @moduledoc false

  alias NewRelic.Metric

  def transform({:custom, name}, count: count, value: value),
    do: %Metric{
      name: join(["Custom", name]),
      call_count: count,
      total_call_time: value,
      min_call_time: value,
      max_call_time: value
    }

  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: :Web,
        duration_s: duration_s,
        total_time_s: total_time_s
      ),
      do: [
        %Metric{
          name: "WebTransaction",
          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(["WebTransaction", name]),
          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: "WebTransactionTotalTime",
          call_count: 1,
          total_call_time: total_time_s,
          total_exclusive_time: total_time_s,
          min_call_time: total_time_s,
          max_call_time: total_time_s
        },
        # Transaction breakdown doesn't handle Elixir's level of concurrency,
        # sending just call count improves things
        %Metric{
          name: join(["WebTransactionTotalTime", name]),
          call_count: 1
        }
      ]

  def transform({:transaction, name},
        type: :Other,
        duration_s: duration_s,
        total_time_s: total_time_s
      ),
      do: [
        %Metric{
          name: "OtherTransaction/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(["OtherTransaction", name]),
          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: "OtherTransactionTotalTime",
          call_count: 1,
          total_call_time: total_time_s,
          total_exclusive_time: total_time_s,
          min_call_time: total_time_s,
          max_call_time: total_time_s
        },
        # Transaction breakdown doesn't handle Elixir's level of concurrency,
        # sending just call count improves things
        %Metric{
          name: join(["OtherTransactionTotalTime", name]),
          call_count: 1
        }
      ]

  def transform(
        {:caller, type, account_id, app_id, transport_type},
        duration_s: duration_s
      ),
      do: %Metric{
        name: join(["DurationByCaller", type, account_id, 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},
        type: type,
        scope: scope,
        duration_s: duration_s
      ),
      do: [
        %Metric{
          name: join(["Datastore/statement", datastore, table, operation]),
          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
        },
        %Metric{
          name: join(["Datastore/operation", datastore, operation]),
          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
        },
        %Metric{
          name: join(["Datastore", datastore, "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
        },
        %Metric{
          name: "Datastore/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
        }
      ]

  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
        },
        %Metric{
          name: join(["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({:datastore, datastore, operation},
        type: type,
        scope: scope,
        duration_s: duration_s
      ),
      do: [
        %Metric{
          name: join(["Datastore/operation", datastore, operation]),
          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
        },
        %Metric{
          name: join(["Datastore", datastore, "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
        },
        %Metric{
          name: join(["Datastore", "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
        }
      ]

  def transform({:datastore, datastore, operation},
        duration_s: duration_s
      ),
      do: [
        %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
        },
        %Metric{
          name: join(["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
    }

  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
      }

  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
      }

  def transform(:error, type: type, error_count: error_count),
    do: [
      %Metric{
        name: "Errors/all#{type}",
        call_count: error_count
      },
      %Metric{
        name: :"Errors/all",
        call_count: error_count
      }
    ]

  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,
      min_call_time: memory_mb,
      max_call_time: memory_mb
    }

  def transform(:cpu, utilization: utilization),
    do: %Metric{
      name: :"CPU/User Time",
      call_count: 1,
      total_call_time: utilization,
      min_call_time: utilization,
      max_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, :infinite_tracing}, spans_seen: spans_seen),
    do: [
      %Metric{
        name: :"Supportability/InfiniteTracing/Span/Seen",
        call_count: spans_seen
      }
    ]

  def transform({:supportability, :infinite_tracing}, harvest_size: harvest_size),
    do: [
      %Metric{
        name: :"Supportability/InfiniteTracing/Span/Sent",
        call_count: harvest_size
      },
      %Metric{
        name: :"Supportability/Elixir/TelemetrySdk/Harvest/Span",
        call_count: 1
      },
      %Metric{
        name: :"Supportability/Harvest",
        call_count: 1
      }
    ]

  def transform({:supportability, harvester},
        events_seen: events_seen,
        reservoir_size: reservoir_size
      ),
      do: [
        %Metric{
          name: join(["Supportability/Elixir/Collector/HarvestSeen", harvester]),
          call_count: 1,
          total_call_time: events_seen
        },
        %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/Harvest",
        call_count: 1
      }
    ]

  def transform({:supportability, :agent, metric}, value: value),
    do: %Metric{
      name: join(["Supportability/ElixirAgent", metric]),
      call_count: 1,
      total_call_time: value,
      min_call_time: value,
      max_call_time: value
    }

  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, :tracestate, :invalid]),
    do: %Metric{
      name: :"Supportability/TraceContext/TraceState/Parse/Exception",
      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
    }

  defp join(segments), do: NewRelic.Util.metric_join(segments)
end

Operator	Description	Example
name:	Match package name. Supports * wildcards and repo/package form	name:phx* or name:hexpm/phoenix
description:	Full-text search of package descriptions	description:auth
depends:	Packages depending on a given package. Supports repo:package form	depends:ecto or depends:hexpm:ecto
build_tool:	Filter by build tool	build_tool:mix
updated_after:	Packages updated after an ISO8601 datetime	updated_after:2025-01-01T00:00:00Z
extra:	Match custom metadata (key,value). Nested keys are separated by commas	extra:license,MIT