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

Class NoAdmissionOptimizer$

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

Disabled admission window proportion optimizer.

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    NoAdmissionOptimizer$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.pekko.cluster.sharding.internal.AdmissionOptimizer
    apply(int initialLimit, org.apache.pekko.cluster.sharding.ClusterShardingSettings.CompositePassivationStrategy.AdmissionOptimizer optimizer)
     
    double
    calculateAdjustment()
    Calculate an adjustment to the proportion of the admission window.
    void
    recordActive()
    An entity was accessed that is already active.
    void
    recordPassive()
    An entity was accessed that was passive (needed to be activated).
    void
    updateLimit(int newLimit)
    The per-shard limit has been updated.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • MODULE$

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

  • Constructor Details

    • NoAdmissionOptimizer$

      public NoAdmissionOptimizer$()

  • Method Details

    • recordActive

      public void recordActive()
      An entity was accessed that is already active.

    • recordPassive

      public void recordPassive()
      An entity was accessed that was passive (needed to be activated).

    • updateLimit

      public void updateLimit(int newLimit)
      The per-shard limit has been updated.
      Parameters:
      newLimit - the new per-shard limit

    • calculateAdjustment

      public double calculateAdjustment()
      Calculate an adjustment to the proportion of the admission window. Can be positive (to grow the window) or negative (to shrink the window). Returns 0.0 if no adjustment should be made.
      Returns:
      the adjustment to make to the admission window proportion

    • apply

      public static org.apache.pekko.cluster.sharding.internal.AdmissionOptimizer apply(int initialLimit, org.apache.pekko.cluster.sharding.ClusterShardingSettings.CompositePassivationStrategy.AdmissionOptimizer optimizer)