rename api

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.shardRegionReceiveShardHome(cluster.selfAddress, self, typeName, shard)
+      instrumentation.onReceiveShardHome(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.shardRegionRequestShardHome(cluster.selfAddress, self, typeName, shard)
+    instrumentation.onRequestShardHome(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 shardRegionRequestShardHome(
+  override def onRequestShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
       shardId: String): Unit =
-    instrumentations.foreach(_.shardRegionRequestShardHome(selfAddress, shardRegionActor, typeName, shardId))
+    instrumentations.foreach(_.onRequestShardHome(selfAddress, shardRegionActor, typeName, shardId))
 
-  override def shardRegionReceiveShardHome(
+  override def onReceiveShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
       shardId: String): Unit =
-    instrumentations.foreach(_.shardRegionReceiveShardHome(selfAddress, shardRegionActor, typeName, shardId))
+    instrumentations.foreach(_.onReceiveShardHome(selfAddress, shardRegionActor, typeName, shardId))
 }
 
 /**
@@ -137,13 +137,13 @@ class EmptyClusterShardingInstrumentation extends ClusterShardingInstrumentation
 
   override def dependencies: immutable.Seq[String] = Nil
 
-  override def shardRegionRequestShardHome(
+  override def onRequestShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
       shardId: String): Unit = ()
 
-  override def shardRegionReceiveShardHome(
+  override def onReceiveShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
@@ -166,6 +166,18 @@ trait ClusterShardingInstrumentation {
    */
   def incrementShardRegionBufferSize(selfAddress: Address, shardRegionActor: ActorRef, typeName: String): Unit
 
+  def onRequestShardHome(
+                          selfAddress: Address,
+                          shardRegionActor: ActorRef,
+                          typeName: String,
+                          shardId: String): Unit
+
+  def onReceiveShardHome(
+                          selfAddress: Address,
+                          shardRegionActor: ActorRef,
+                          typeName: String,
+                          shardId: String): Unit
+
   /**
    * Optional dependencies for this instrumentation.
    *
@@ -174,22 +186,4 @@ trait ClusterShardingInstrumentation {
    * @return list of class names for optional instrumentation dependencies
    */
   def dependencies: immutable.Seq[String]
-
-  /**
-   * Triggered when a region requests the home of a shard.
-   */
-  def shardRegionRequestShardHome(
-      selfAddress: Address,
-      shardRegionActor: ActorRef,
-      typeName: String,
-      shardId: String): Unit
-
-  /**
-   * Triggered when a region receives the home of a shard.
-   */
-  def shardRegionReceiveShardHome(
-      selfAddress: Address,
-      shardRegionActor: ActorRef,
-      typeName: String,
-      shardId: String): Unit
 }

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 shardRegionRequestShardHome(
+  override def onRequestShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,
       shardId: String): Unit =
     shardHomeRequests.incrementAndGet()
 
-  override def shardRegionReceiveShardHome(
+  override def onReceiveShardHome(
       selfAddress: Address,
       shardRegionActor: ActorRef,
       typeName: String,