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

Various internal stable markers (#27004)

Browse source
This commit is contained in:
Christopher Batey 2019-05-29 07:09:12 +01:00 • committed by GitHub
parent 31f6170c62
commit 28fbd28e7a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 10 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -163,6 +163,7 @@ private[akka] object Shard {
* *
* @see [[ClusterSharding$ ClusterSharding extension]] * @see [[ClusterSharding$ ClusterSharding extension]]
*/ */
@InternalStableApi
private[akka] class Shard( private[akka] class Shard(
typeName: String, typeName: String,
shardId: ShardRegion.ShardId, shardId: ShardRegion.ShardId,
@ -381,6 +382,7 @@ private[akka] class Shard(
entityTerminated(ref) entityTerminated(ref)
} }
@InternalStableApi
def entityTerminated(ref: ActorRef): Unit = { def entityTerminated(ref: ActorRef): Unit = {
val id = idByRef(ref) val id = idByRef(ref)
idByRef -= ref idByRef -= ref

2
akka-persistence/src/main/scala/akka/persistence/Eventsourced.scala
View file

@ -139,6 +139,7 @@ private[persistence] trait Eventsourced
* Called whenever a message replay succeeds. * Called whenever a message replay succeeds.
* May be implemented by subclass. * May be implemented by subclass.
*/ */
@InternalStableApi
private[akka] def onReplaySuccess(): Unit = () private[akka] def onReplaySuccess(): Unit = ()
/** /**
@ -231,6 +232,7 @@ private[persistence] trait Eventsourced
private def unstashInternally(all: Boolean): Unit = private def unstashInternally(all: Boolean): Unit =
if (all) internalStash.unstashAll() else internalStash.unstash() if (all) internalStash.unstashAll() else internalStash.unstash()
@InternalStableApi
private def startRecovery(recovery: Recovery): Unit = { private def startRecovery(recovery: Recovery): Unit = {
val timeout = { val timeout = {
val journalPluginConfig = this match { val journalPluginConfig = this match {

2
akka-remote/src/main/scala/akka/remote/RemoteTransport.scala
View file

@ -7,6 +7,7 @@ package akka.remote
import akka.AkkaException import akka.AkkaException
import akka.Done import akka.Done
import akka.actor._ import akka.actor._
import akka.annotation.InternalStableApi
import akka.event.LoggingAdapter import akka.event.LoggingAdapter
import scala.collection.immutable import scala.collection.immutable
@ -95,6 +96,7 @@ private[akka] abstract class RemoteTransport(val system: ExtendedActorSystem, va
* @param uid UID of the remote system, if the uid is not defined it will not be a strong quarantine but * @param uid UID of the remote system, if the uid is not defined it will not be a strong quarantine but
* the current endpoint writer will be stopped (dropping system messages) and the address will be gated * the current endpoint writer will be stopped (dropping system messages) and the address will be gated
*/ */
@InternalStableApi
def quarantine(address: Address, uid: Option[Long], reason: String): Unit def quarantine(address: Address, uid: Option[Long], reason: String): Unit
} }

3
akka-remote/src/main/scala/akka/remote/artery/ArteryTransport.scala
View file

@ -24,12 +24,12 @@ import scala.util.Success
import scala.util.Try import scala.util.Try
import scala.util.control.NoStackTrace import scala.util.control.NoStackTrace
import scala.util.control.NonFatal import scala.util.control.NonFatal
import akka.Done import akka.Done
import akka.NotUsed import akka.NotUsed
import akka.actor.Actor import akka.actor.Actor
import akka.actor.Props import akka.actor.Props
import akka.actor._ import akka.actor._
import akka.annotation.InternalStableApi
import akka.dispatch.Dispatchers import akka.dispatch.Dispatchers
import akka.event.Logging import akka.event.Logging
import akka.event.LoggingAdapter import akka.event.LoggingAdapter
@ -793,6 +793,7 @@ private[remote] abstract class ArteryTransport(_system: ExtendedActorSystem, _pr
} }
} }
@InternalStableApi
override def quarantine(remoteAddress: Address, uid: Option[Long], reason: String): Unit = { override def quarantine(remoteAddress: Address, uid: Option[Long], reason: String): Unit = {
quarantine(remoteAddress, uid, reason, harmless = false) quarantine(remoteAddress, uid, reason, harmless = false)
} }

2
akka-remote/src/main/scala/akka/remote/artery/RemoteInstrument.scala
View file

@ -10,6 +10,7 @@ import scala.annotation.tailrec
import scala.collection.immutable import scala.collection.immutable
import scala.util.control.NonFatal import scala.util.control.NonFatal
import akka.actor.{ ActorRef, ExtendedActorSystem } import akka.actor.{ ActorRef, ExtendedActorSystem }
import akka.annotation.InternalStableApi
import akka.event.{ Logging, LoggingAdapter } import akka.event.{ Logging, LoggingAdapter }
import akka.util.{ unused, OptionVal } import akka.util.{ unused, OptionVal }
import akka.util.ccompat._ import akka.util.ccompat._
@ -327,6 +328,7 @@ private[remote] object RemoteInstruments {
def getKey(kl: Int): Byte = (kl >>> 26).toByte def getKey(kl: Int): Byte = (kl >>> 26).toByte
def getLength(kl: Int): Int = kl & lengthMask def getLength(kl: Int): Int = kl & lengthMask
@InternalStableApi
def create(system: ExtendedActorSystem, @unused log: LoggingAdapter): Vector[RemoteInstrument] = { def create(system: ExtendedActorSystem, @unused log: LoggingAdapter): Vector[RemoteInstrument] = {
val c = system.settings.config val c = system.settings.config
val path = "akka.remote.artery.advanced.instruments" val path = "akka.remote.artery.advanced.instruments"