Class 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 Detail

      • MODULE$

        public static final ShardedServiceRegistry$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • ShardedServiceRegistry$

        public ShardedServiceRegistry$()
    • Method Detail

      • apply

        public ShardedServiceRegistry apply​(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,​ClusterReceptionist.Entry>,​ServiceRegistry> serviceRegistries,
                                            scala.collection.immutable.Map<ActorRef<?>,​scala.concurrent.duration.Deadline> tombstones)
        Two 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 key INTERNAL API
        serviceRegistries - (undocumented)
        Returns:
        (undocumented)