From 6b402f4bf0f1f8030f633d0bf98f5a4ffe80b44d Mon Sep 17 00:00:00 2001 From: Yury Gribkov Date: Thu, 25 Jun 2020 03:39:26 -0400 Subject: [PATCH] Annotate Shard instrumented methods with InternalStableApi (#29255) --- .../src/main/scala/akka/cluster/sharding/Shard.scala | 3 +++ 1 file changed, 3 insertions(+) diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala index b5341accd1..e398300e51 100644 --- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala +++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala @@ -366,6 +366,8 @@ private[akka] object Shard { def pendingRememberedEntitiesExist(): Boolean = !remembering.isEmpty def entityIdExists(id: EntityId): Boolean = entities.get(id) != null + + @InternalStableApi def size: Int = entities.size override def toString: EntityId = entities.toString @@ -418,6 +420,7 @@ private[akka] class Shard( private val flightRecorder = ShardingFlightRecorder(context.system) + @InternalStableApi private val entities = new Entities(log, settings.rememberEntities, verboseDebug) private var lastMessageTimestamp = Map.empty[EntityId, Long]