File size: 1,814 Bytes
8da2481 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 | defmodule Plausible.Ingestion.Counters.TelemetryHandler do
@moduledoc """
Subscribes to telemetry events emitted by `Plausible.Ingestion.Event`.
Every time a request derived event is either dispatched to clickhouse or dropped,
a telemetry event is emitted respectively. That event is captured here,
its metadata is extracted and sent for internal stats aggregation via
`Counters.Buffer` interface.
"""
alias Plausible.Ingestion.Counters
alias Plausible.Ingestion.Event
@event_dropped Event.telemetry_event_dropped()
@event_buffered Event.telemetry_event_buffered()
@telemetry_events [@event_dropped, @event_buffered]
@telemetry_handler &__MODULE__.handle_event/4
@spec install(Counters.Buffer.t()) :: :ok
def install(%Counters.Buffer{buffer_name: buffer_name} = buffer) do
:ok =
:telemetry.attach_many(
"ingest-counters-#{buffer_name}",
@telemetry_events,
@telemetry_handler,
buffer
)
end
@spec handle_event([atom()], any(), map(), Counters.Buffer.t()) :: :ok
def handle_event(
@event_dropped,
_measurements,
%{
domain: domain,
reason: reason,
request_timestamp: timestamp,
tracker_script_version: tracker_script_version
},
buffer
) do
Counters.Buffer.aggregate(
buffer,
"dropped_#{reason}",
domain,
timestamp,
tracker_script_version
)
:ok
end
def handle_event(
@event_buffered,
_measurements,
%{
domain: domain,
request_timestamp: timestamp,
tracker_script_version: tracker_script_version
},
buffer
) do
Counters.Buffer.aggregate(buffer, "buffered", domain, timestamp, tracker_script_version)
:ok
end
end
|