Fix assignedShards metric (#124)

ghostdogpr · web-flow · commit d66027dad6c3 · 2024-04-24T12:48:33.000+09:00
diff --git 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

Original file line number	Diff line number	Diff line change
`@@ -76,6 +76,7 @@ class ShardManager(`
`76`	`76`	`)`
`77`	`77`	`}`
`78`	`78`	`_ <- ManagerMetrics.pods.decrement`
	`79`	`+ _ <- ManagerMetrics.assignedShards.tagged("pod_address", podAddress.toString).decrementBy(unassignments.size)`
`79`	`80`	`_ <- ManagerMetrics.unassignedShards.incrementBy(unassignments.size)`
`80`	`81`	`_ <- eventsHub.publish(ShardingEvent.PodUnregistered(podAddress))`
`81`	`82`	`_ <- eventsHub`