mirror of
https://github.com/PluralKit/PluralKit.git
synced 2026-02-15 10:10:12 +00:00
fix(gateway): remove shard_id from pluralkit_gateway_events metric
This commit is contained in:
parent
f3e006034b
commit
0600ae00ff
1 changed files with 8 additions and 2 deletions
|
|
@ -86,12 +86,18 @@ pub async fn runner(
|
||||||
while let Some(item) = shard.next_event(EventTypeFlags::all()).await {
|
while let Some(item) = shard.next_event(EventTypeFlags::all()).await {
|
||||||
match item {
|
match item {
|
||||||
Ok(event) => {
|
Ok(event) => {
|
||||||
|
// event_type * shard_id is too many labels and prometheus fails to query it
|
||||||
|
// so we split it into two metrics
|
||||||
counter!(
|
counter!(
|
||||||
"pluralkit_gateway_events",
|
"pluralkit_gateway_events_type",
|
||||||
"shard_id" => shard.id().number().to_string(),
|
|
||||||
"event_type" => serde_variant::to_variant_name(&event.kind()).unwrap(),
|
"event_type" => serde_variant::to_variant_name(&event.kind()).unwrap(),
|
||||||
)
|
)
|
||||||
.increment(1);
|
.increment(1);
|
||||||
|
counter!(
|
||||||
|
"pluralkit_gateway_events_shard",
|
||||||
|
"shard_id" => shard.id().number().to_string(),
|
||||||
|
)
|
||||||
|
.increment(1);
|
||||||
if let Err(error) = shard_state
|
if let Err(error) = shard_state
|
||||||
.handle_event(shard.id().number(), event.clone())
|
.handle_event(shard.id().number(), event.clone())
|
||||||
.await
|
.await
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue