Class ShardedServiceRegistry$
- java.lang.Object
-
- akka.cluster.typed.internal.receptionist.ShardedServiceRegistry$
-
- All Implemented Interfaces:
java.io.Serializable
,scala.Serializable
public class ShardedServiceRegistry$ extends java.lang.Object implements scala.Serializable
INTERNAL API- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static ShardedServiceRegistry$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description ShardedServiceRegistry$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ShardedServiceRegistry
apply(int numberOfKeys)
ShardedServiceRegistry
apply(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries, scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones, scala.collection.immutable.Set<UniqueAddress> nodes)
INTERNAL APIscala.Option<scala.Tuple3<scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry>,scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline>,scala.collection.immutable.Set<UniqueAddress>>>
unapply(ShardedServiceRegistry x$0)
-
-
-
Field Detail
-
MODULE$
public static final ShardedServiceRegistry$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
apply
public ShardedServiceRegistry apply(int numberOfKeys)
-
apply
public ShardedServiceRegistry apply(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries, scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones, scala.collection.immutable.Set<UniqueAddress> nodes)
INTERNAL APITwo level structure for keeping service registry to be able to shard entries over multiple ddata keys (to not get too large ddata messages)
- Parameters:
tombstones
- Local actors that were stopped and should not be re-added to the available set of actors for a key. Since the only way to unregister is to stop, we don't need to keep track of the service keyserviceRegistries
- (undocumented)nodes
- (undocumented)- Returns:
- (undocumented)
-
unapply
public scala.Option<scala.Tuple3<scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry>,scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline>,scala.collection.immutable.Set<UniqueAddress>>> unapply(ShardedServiceRegistry x$0)
-
-