Package akka.cluster.sharding.internal

Class AlwaysAdmissionFilter$

  • public class AlwaysAdmissionFilter$
extends java.lang.Object
    INTERNAL API

    Disabled admission filter, always admit candidates to the main area.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static AlwaysAdmissionFilter$ MODULE$
      Static reference to the singleton instance of this Scala object.

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean admit​(java.lang.String candidate, java.lang.String selected)
      Determine whether an entity should be admitted to the main area.
      static akka.cluster.sharding.internal.AdmissionFilter apply​(int initialCapacity, akka.cluster.sharding.ClusterShardingSettings.CompositePassivationStrategy.AdmissionFilter filter)  
      void update​(java.lang.String id)
      Update the filter when an entity is accessed
      void updateCapacity​(int newCapacity)
      Update the capacity, the per-shard entity limit.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • MODULE$

        public static final AlwaysAdmissionFilter$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • AlwaysAdmissionFilter$

        public AlwaysAdmissionFilter$()

    • Method Detail

      • updateCapacity

        public void updateCapacity​(int newCapacity)
        Update the capacity, the per-shard entity limit.
        Parameters:
        newCapacity - the new capacity for the filter

      • update

        public void update​(java.lang.String id)
        Update the filter when an entity is accessed
        Parameters:
        id - the entity id that has been accessed

      • admit

        public boolean admit​(java.lang.String candidate,
                     java.lang.String selected)
        Determine whether an entity should be admitted to the main area. The candidate has been removed from the admission window (according to its replacement policy) and can replace an entity in the main area (selected by its replacement policy). Whichever entity is not admitted or retained will be passivated.
        Parameters:
        candidate - the candidate from the window that may be admitted to the main area
        selected - the entity selected from the main area to possibly be replaced by the candidate
        Returns:
        whether to admit the candidate to the main area

      • apply

        public static akka.cluster.sharding.internal.AdmissionFilter apply​(int initialCapacity,
                                                                   akka.cluster.sharding.ClusterShardingSettings.CompositePassivationStrategy.AdmissionFilter filter)