Class ShardedServiceRegistry$

  • All Implemented Interfaces:
    java.io.Serializable

    public class ShardedServiceRegistry$
    extends java.lang.Object
    implements java.io.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,
                                            scala.collection.immutable.Set<UniqueAddress> nodes,
                                            scala.collection.immutable.Set<UniqueAddress> unreachable)
        INTERNAL API

        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

        serviceRegistries - (undocumented)
        nodes - (undocumented)
        unreachable - (undocumented)
        Returns:
        (undocumented)