raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Annotate Shard instrumented methods with InternalStableApi (#29255)

Browse source
This commit is contained in:
Yury Gribkov 2020-06-25 03:39:26 -04:00 • committed by GitHub
parent 0f7785e8d9
commit 6b402f4bf0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala
View file

@ -366,6 +366,8 @@ private[akka] object Shard {
def pendingRememberedEntitiesExist(): Boolean = !remembering.isEmpty def pendingRememberedEntitiesExist(): Boolean = !remembering.isEmpty
def entityIdExists(id: EntityId): Boolean = entities.get(id) != null def entityIdExists(id: EntityId): Boolean = entities.get(id) != null
@InternalStableApi
def size: Int = entities.size def size: Int = entities.size
override def toString: EntityId = entities.toString override def toString: EntityId = entities.toString
@ -418,6 +420,7 @@ private[akka] class Shard(
private val flightRecorder = ShardingFlightRecorder(context.system) private val flightRecorder = ShardingFlightRecorder(context.system)
@InternalStableApi
private val entities = new Entities(log, settings.rememberEntities, verboseDebug) private val entities = new Entities(log, settings.rememberEntities, verboseDebug)
private var lastMessageTimestamp = Map.empty[EntityId, Long] private var lastMessageTimestamp = Map.empty[EntityId, Long]