From d66027dad6c3c6ff07cd5c2598bb4d05a421d5ad Mon Sep 17 00:00:00 2001 From: Pierre Ricadat Date: Wed, 24 Apr 2024 12:48:33 +0900 Subject: [PATCH] Fix assignedShards metric (#124) --- .../src/main/scala/com/devsisters/shardcake/ShardManager.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala b/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala index ba38acf..28381c1 100644 --- a/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala +++ b/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala @@ -76,6 +76,7 @@ class ShardManager( ) } _ <- ManagerMetrics.pods.decrement + _ <- ManagerMetrics.assignedShards.tagged("pod_address", podAddress.toString).decrementBy(unassignments.size) _ <- ManagerMetrics.unassignedShards.incrementBy(unassignments.size) _ <- eventsHub.publish(ShardingEvent.PodUnregistered(podAddress)) _ <- eventsHub