Package org.apache.pekko.cluster.sharding

Class ShardRegion$

java.lang.Object
org.apache.pekko.cluster.sharding.ShardRegion$
public class ShardRegion$ extends Object
See Also:

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    ShardRegion$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pekko.cluster.sharding.ShardRegion.GetCurrentRegions$
    getCurrentRegionsInstance()
    Java API: Send this message to the ShardRegion actor to request for CurrentRegions, which contains the addresses of all registered regions.
    org.apache.pekko.cluster.sharding.ShardRegion.GetShardRegionStats$
    getRegionStatsInstance()
    Java API:
    org.apache.pekko.cluster.sharding.ShardRegion.GetShardRegionState$
    getShardRegionStateInstance()
    Java API:
    org.apache.pekko.cluster.sharding.ShardRegion.GracefulShutdown$
    gracefulShutdownInstance()
    Java API: Send this message to the ShardRegion actor to handoff all shards that are hosted by the ShardRegion and then the ShardRegion actor will be stopped.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • MODULE$

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

  • Constructor Details

    • ShardRegion$

      public ShardRegion$()

  • Method Details

    • gracefulShutdownInstance

      public org.apache.pekko.cluster.sharding.ShardRegion.GracefulShutdown$ gracefulShutdownInstance()
      Java API: Send this message to the ShardRegion actor to handoff all shards that are hosted by the ShardRegion and then the ShardRegion actor will be stopped. You can watch it to know when it is completed.

    • getCurrentRegionsInstance

      public org.apache.pekko.cluster.sharding.ShardRegion.GetCurrentRegions$ getCurrentRegionsInstance()
      Java API: Send this message to the ShardRegion actor to request for CurrentRegions, which contains the addresses of all registered regions.

      Intended for testing purpose to see when cluster sharding is "ready" or to monitor the state of the shard regions.

    • getRegionStatsInstance

      public org.apache.pekko.cluster.sharding.ShardRegion.GetShardRegionStats$ getRegionStatsInstance()
      Java API:

    • getShardRegionStateInstance

      public org.apache.pekko.cluster.sharding.ShardRegion.GetShardRegionState$ getShardRegionStateInstance()
      Java API: