more renam

Author: sebastian-alfers

akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardRegion.scala

@@ -907,7 +907,7 @@ private[akka] class ShardRegion(
       }
 
     case ShardHome(shard, shardRegionRef) =>
-      instrumentation.onReceiveShardHome(cluster.selfAddress, self, typeName, shard)
+      instrumentation.receivedShardHome(cluster.selfAddress, self, typeName, shard)
       receiveShardHome(shard, shardRegionRef)
 
     case ShardHomes(homes) =>
@@ -1456,7 +1456,7 @@ private[akka] class ShardRegion(
   }
 
   private def requestShardHome(shard: ShardId): Unit = {
-    instrumentation.onRequestShardHome(cluster.selfAddress, self, typeName, shard)
+    instrumentation.requestedShardHome(cluster.selfAddress, self, typeName, shard)
     coordinator.foreach(_ ! GetShardHome(shard))
   }
 }

akka-cluster-sharding/src/main/scala/akka/cluster/sharding/internal/ClusterShardingInstrumentation.scala

@@ -97,19 +97,19 @@ class ClusterShardingTelemetryEnsemble(val instrumentations: Seq[ClusterSharding
   override def dependencies: immutable.Seq[String] =
     instrumentations.flatMap(_.dependencies)
 
-  override def onRequestShardHome(
+  override def requestedShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
       shardId: String): Unit =
-    instrumentations.foreach(_.onRequestShardHome(selfAddress, shardRegionActor, typeName, shardId))
+    instrumentations.foreach(_.requestedShardHome(selfAddress, shardRegionActor, typeName, shardId))
 
-  override def onReceiveShardHome(
+  override def receivedShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
       shardId: String): Unit =
-    instrumentations.foreach(_.onReceiveShardHome(selfAddress, shardRegionActor, typeName, shardId))
+    instrumentations.foreach(_.receivedShardHome(selfAddress, shardRegionActor, typeName, shardId))
 }
 
 /**
@@ -137,13 +137,13 @@ class EmptyClusterShardingInstrumentation extends ClusterShardingInstrumentation
 
   override def dependencies: immutable.Seq[String] = Nil
 
-  override def onRequestShardHome(
+  override def requestedShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
       shardId: String): Unit = ()
 
-  override def onReceiveShardHome(
+  override def receivedShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
@@ -166,13 +166,13 @@ trait ClusterShardingInstrumentation {
    */
   def incrementShardRegionBufferSize(selfAddress: Address, shardRegionActor: ActorRef, typeName: String): Unit
 
-  def onRequestShardHome(
+  def requestedShardHome(
                           selfAddress: Address,
                           shardRegionActor: ActorRef,
                           typeName: String,
                           shardId: String): Unit
 
-  def onReceiveShardHome(
+  def receivedShardHome(
                           selfAddress: Address,
                           shardRegionActor: ActorRef,
                           typeName: String,

akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingInstrumentationSpec.scala

@@ -71,14 +71,14 @@ class SpecClusterShardingTelemetry(@nowarn("msg=never used") system: ExtendedAct
 
   override def dependencies: Seq[String] = Nil
 
-  override def onRequestShardHome(
+  override def requestedShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
       shardId: String): Unit =
     shardHomeRequests.incrementAndGet()
 
-  override def onReceiveShardHome(
+  override def receivedShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,