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

Class DisabledEntityPassivationStrategy$

  • public class DisabledEntityPassivationStrategy$
extends java.lang.Object
    INTERNAL API: No-op passivation strategy for when automatic passivation is disabled.

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static org.apache.pekko.cluster.sharding.internal.EntityPassivationStrategy apply​(ClusterShardingSettings settings)  
      void entityTerminated​(java.lang.String id)
      An entity instance has been terminated and should be removed from active tracking.
      scala.collection.immutable.Seq<java.lang.String> entityTouched​(java.lang.String id)
      An entity instance has been touched.
      scala.collection.immutable.Seq<java.lang.String> intervalPassed()
      Called each time the scheduledInterval has passed, if defined.
      scala.collection.immutable.Seq<java.lang.String> limitUpdated​(int newLimit)
      The per-region active entity limit has been updated, which can trigger passivation.
      scala.Option<scala.concurrent.duration.FiniteDuration> scheduledInterval()
      An optional interval for time-based passivation strategies.
      scala.collection.immutable.Seq<java.lang.String> shardsUpdated​(int activeShards)
      Active shards in this region have been updated, which can trigger passivation.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • DisabledEntityPassivationStrategy$

        public DisabledEntityPassivationStrategy$()

    • Method Detail

      • limitUpdated

        public scala.collection.immutable.Seq<java.lang.String> limitUpdated​(int newLimit)
        The per-region active entity limit has been updated, which can trigger passivation.
        Parameters:
        newLimit - the new per-region active entity limit
        Returns:
        entities to passivate in the associated shard

      • shardsUpdated

        public scala.collection.immutable.Seq<java.lang.String> shardsUpdated​(int activeShards)
        Active shards in this region have been updated, which can trigger passivation.
        Parameters:
        activeShards - updated number of active shards
        Returns:
        entities to passivate in the associated shard

      • entityTouched

        public scala.collection.immutable.Seq<java.lang.String> entityTouched​(java.lang.String id)
        An entity instance has been touched. Recorded before message delivery.
        Parameters:
        id - entity id for the touched entity instance
        Returns:
        entities to passivate, when active capacity has been reached

      • entityTerminated

        public void entityTerminated​(java.lang.String id)
        An entity instance has been terminated and should be removed from active tracking.
        Parameters:
        id - entity id for the terminated entity instance

      • scheduledInterval

        public scala.Option<scala.concurrent.duration.FiniteDuration> scheduledInterval()
        An optional interval for time-based passivation strategies.
        Returns:
        the scheduled interval to call the intervalPassed method

      • intervalPassed

        public scala.collection.immutable.Seq<java.lang.String> intervalPassed()
        Called each time the scheduledInterval has passed, if defined.
        Returns:
        entities to passivate, if deemed inactive

      • apply

        public static org.apache.pekko.cluster.sharding.internal.EntityPassivationStrategy apply​(ClusterShardingSettings settings)