Package org.apache.pekko.cluster.sharding.internal

Class AlwaysAdmissionFilter$

java.lang.Object
org.apache.pekko.cluster.sharding.internal.AlwaysAdmissionFilter$
public class AlwaysAdmissionFilter$ extends Object
INTERNAL API

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

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    AlwaysAdmissionFilter$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    admit(String candidate, String selected)
    Determine whether an entity should be admitted to the main area.
    static org.apache.pekko.cluster.sharding.internal.AdmissionFilter
    apply(int initialCapacity, org.apache.pekko.cluster.sharding.ClusterShardingSettings.CompositePassivationStrategy.AdmissionFilter filter)
     
    void
    update(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 Details

    • MODULE$

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

  • Constructor Details

    • AlwaysAdmissionFilter$

      public AlwaysAdmissionFilter$()

  • Method Details

    • 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(String id)
      Update the filter when an entity is accessed
      Parameters:
      id - the entity id that has been accessed

    • admit

      public boolean admit(String candidate, 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 org.apache.pekko.cluster.sharding.internal.AdmissionFilter apply(int initialCapacity, org.apache.pekko.cluster.sharding.ClusterShardingSettings.CompositePassivationStrategy.AdmissionFilter filter)