Reimplement "do not count specific commands" feature

evolution-gaming · Feb 20, 2017 · e832ff4 · e832ff4
1 parent fc1c375
commit e832ff4
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 6 deletions.
diff --git a/src/main/scala/com/evolutiongaming/cluster/AdaptiveAllocationStrategy.scala b/src/main/scala/com/evolutiongaming/cluster/AdaptiveAllocationStrategy.scala
@@ -55,9 +55,11 @@ class AdaptiveAllocationStrategy(
   override def extractShardId(numberOfShards: Int): ShardRegion.ExtractShardId = {
     case x: ClusterMsg =>
       if (!x.isInstanceOf[PersistenceQuery]) {
-        if (!x.isInstanceOf[DoNotCount]) {
-          increment(typeName, x.id)
-          metricRegistry.meter(s"persistence.$typeName.sender.${ x.id }.$selfHost").mark()
+        x match {
+          case cc: CountControl if cc.doNotCount =>
+          case _                                 =>
+            increment(typeName, x.id)
+            metricRegistry.meter(s"persistence.$typeName.sender.${ x.id }.$selfHost").mark()
         }
         metricRegistry.meter(s"persistence.$typeName.command.${ x.id }.${x.getClass.getSimpleName}.$selfHost").mark()
       }

diff --git a/src/main/scala/com/evolutiongaming/cluster/CountControl.scala b/src/main/scala/com/evolutiongaming/cluster/CountControl.scala
@@ -0,0 +1,5 @@
+package com.evolutiongaming.cluster
+
+trait CountControl {
+  def doNotCount: Boolean = false
+}
diff --git a/src/main/scala/com/evolutiongaming/cluster/DoNotCount.scala b/src/main/scala/com/evolutiongaming/cluster/DoNotCount.scala