Class GetClusterShardingStats
- java.lang.Object
-
- org.apache.pekko.cluster.sharding.typed.GetClusterShardingStats
-
- All Implemented Interfaces:
java.io.Serializable
,ClusterShardingQuery
,scala.Equals
,scala.Product
public final class GetClusterShardingStats extends java.lang.Object implements ClusterShardingQuery, scala.Product, java.io.Serializable
Query the statistics about the currently running sharded entities in the entire cluster. If the giventimeout
is reached without answers from all shard regions the reply will contain an empty map of regions.Intended for testing purpose to see when cluster sharding is "ready" or to monitor the state of the shard regions.
param: timeout the timeout applied to querying all alive regions param: replyTo the actor to send the result to
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description GetClusterShardingStats(EntityTypeKey<?> entityTypeKey, java.time.Duration timeout, ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo)
Java APIGetClusterShardingStats(EntityTypeKey<?> entityTypeKey, scala.concurrent.duration.FiniteDuration timeout, ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static GetClusterShardingStats
apply(EntityTypeKey<?> entityTypeKey, scala.concurrent.duration.FiniteDuration timeout, ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo)
boolean
canEqual(java.lang.Object x$1)
GetClusterShardingStats
copy(EntityTypeKey<?> entityTypeKey, scala.concurrent.duration.FiniteDuration timeout, ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo)
EntityTypeKey<?>
copy$default$1()
scala.concurrent.duration.FiniteDuration
copy$default$2()
ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats>
copy$default$3()
EntityTypeKey<?>
entityTypeKey()
boolean
equals(java.lang.Object x$1)
int
hashCode()
int
productArity()
java.lang.Object
productElement(int x$1)
java.lang.String
productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats>
replyTo()
scala.concurrent.duration.FiniteDuration
timeout()
java.lang.String
toString()
static scala.Option<scala.Tuple3<EntityTypeKey<?>,scala.concurrent.duration.FiniteDuration,ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats>>>
unapply(GetClusterShardingStats x$0)
-
-
-
Constructor Detail
-
GetClusterShardingStats
public GetClusterShardingStats(EntityTypeKey<?> entityTypeKey, scala.concurrent.duration.FiniteDuration timeout, ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo)
-
GetClusterShardingStats
public GetClusterShardingStats(EntityTypeKey<?> entityTypeKey, java.time.Duration timeout, ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo)
Java APIQuery the statistics about the currently running sharded entities in the entire cluster. If the given
timeout
is reached without answers from all shard regions the reply will contain an empty map of regions.
-
-
Method Detail
-
apply
public static GetClusterShardingStats apply(EntityTypeKey<?> entityTypeKey, scala.concurrent.duration.FiniteDuration timeout, ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo)
-
unapply
public static scala.Option<scala.Tuple3<EntityTypeKey<?>,scala.concurrent.duration.FiniteDuration,ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats>>> unapply(GetClusterShardingStats x$0)
-
entityTypeKey
public EntityTypeKey<?> entityTypeKey()
-
timeout
public scala.concurrent.duration.FiniteDuration timeout()
-
replyTo
public ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo()
-
copy
public GetClusterShardingStats copy(EntityTypeKey<?> entityTypeKey, scala.concurrent.duration.FiniteDuration timeout, ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> replyTo)
-
copy$default$1
public EntityTypeKey<?> copy$default$1()
-
copy$default$2
public scala.concurrent.duration.FiniteDuration copy$default$2()
-
copy$default$3
public ActorRef<org.apache.pekko.cluster.sharding.ShardRegion.ClusterShardingStats> copy$default$3()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementName
in interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-