public final class AutoDowning extends DowningProvider
Constructor and Description |
---|
AutoDowning(ActorSystem system) |
Modifier and Type | Method and Description |
---|---|
scala.Option<Props> |
downingActorProps()
If a props is returned it is created as a child of the core cluster daemon on cluster startup.
|
scala.concurrent.duration.FiniteDuration |
downRemovalMargin()
Time margin after which shards or singletons that belonged to a downed/removed
partition are created in surviving partition.
|
load
public AutoDowning(ActorSystem system)
public scala.concurrent.duration.FiniteDuration downRemovalMargin()
DowningProvider
downRemovalMargin
in class DowningProvider
public scala.Option<Props> downingActorProps()
DowningProvider
Cluster
APIs.
The actor will run on the same dispatcher as the cluster actor if dispatcher not configured.
May throw an exception which will then immediately lead to Cluster stopping, as the downing provider is vital to a working cluster.
downingActorProps
in class DowningProvider