Packages

prometheus_ecto

0.0.1
1.4.3 1.4.2 1.4.1 1.4.0 1.3.0 1.2.0 1.0.3 1.0.2 1.0.1 1.0.0 1.0.0-rc1 1.0.0-alpha9 1.0.0-alpha8 1.0.0-alpha6 1.0.0-alpha4 1.0.0-alpha3 1.0.0-alpha2 1.0.0-alpha1 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

Prometheus monitoring system client Ecto integration. Observes queries duration.

HexDocs

Current section

Files

Jump to
Readme
24 Versions
2 Dependencies
Dependants
Files
Activity
prometheus_ecto lib prometheus_ecto_collector.ex
Raw

lib/prometheus_ecto_collector.ex 

defmodule Ecto.PrometheusCollector do



  def setup do

    request_duration_bounds = [10, 100, 1_000, 10_000, 100_000, 300_000, 500_000, 750_000, 1_000_000, 1_500_000, 2_000_000, 3_000_000]

    labels = [:stage, :result]

    :prometheus_histogram.declare([name: :ecto_query_duration_microseconds,

                                   help: "Ecto query duration in microseconds.",

                                   labels: labels,

                                   buckets: request_duration_bounds])

  end



  def log(entry) do

    {result, _} = entry.result

    :prometheus_histogram.observe(:ecto_query_duration_microseconds, [:queue, result], microseconds_time(entry.queue_time))

    :prometheus_histogram.observe(:ecto_query_duration_microseconds, [:query, result], microseconds_time(entry.query_time))

    :prometheus_histogram.observe(:ecto_query_duration_microseconds, [:decode, result], microseconds_time(entry.decode_time))

    entry

  end



  defp microseconds_time(time) do

    :erlang.convert_time_unit(time, :native, :micro_seconds)

  end

end