File tree Expand file tree Collapse file tree 2 files changed +22
-1
lines changed
Expand file tree Collapse file tree 2 files changed +22
-1
lines changed Original file line number Diff line number Diff line change @@ -46,7 +46,8 @@ defmodule Logflare.Backends.UserMonitoring do
4646 tags = Sources . get_labels_mapping ( source ) |> Map . keys ( )
4747
4848 [
49- counter ( "logflare.backends.ingest.ingested_bytes" ,
49+ counter ( "logflare.backends.ingest.ingested_count" ,
50+ measurement: :ingested_bytes ,
5051 tags: [ "backend_id" , "source_id" ] ++ tags ,
5152 keep: keep_function ,
5253 description: "Count of events ingested by backend for a source"
Original file line number Diff line number Diff line change @@ -151,6 +151,26 @@ defmodule Logflare.Backends.UserMonitoringTest do
151151 events ,
152152 & match? ( % LogEvent { body: % { "attributes" => % { "my_label" => "test" } } } , & 1 )
153153 )
154+
155+ assert Enum . any? (
156+ events ,
157+ & match? (
158+ % LogEvent {
159+ body: % { "event_message" => "logflare.backends.ingest.ingested_count" }
160+ } ,
161+ & 1
162+ )
163+ )
164+
165+ assert Enum . any? (
166+ events ,
167+ & match? (
168+ % LogEvent {
169+ body: % { "event_message" => "logflare.backends.ingest.ingested_bytes" }
170+ } ,
171+ & 1
172+ )
173+ )
154174 end )
155175 end
156176
You can’t perform that action at this time.
0 commit comments