Package org.apache.pekko.cluster.sharding

Class ShardingQueries.ShardsQueryResult$

java.lang.Object

org.apache.pekko.cluster.sharding.ShardingQueries.ShardsQueryResult$

All Implemented Interfaces:

Serializable

Enclosing class:

ShardingQueries

public static class ShardingQueries.ShardsQueryResult$
extends Object
implements Serializable

See Also:

• Serialized Form

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ShardsQueryResult$()

Method Summary

Modifier and Type	Method	Description
<B> ShardingQueries.ShardsQueryResult<B>	apply(scala.collection.immutable.Seq<scala.util.Either<String,B>> ps, int total, scala.concurrent.duration.FiniteDuration timeout)
<B> ShardingQueries.ShardsQueryResult<B>	apply(scala.collection.immutable.Set<String> failed, scala.collection.immutable.Seq<B> responses, int total, scala.concurrent.duration.FiniteDuration timeout)
<T, A, B> scala.Tuple2<scala.collection.immutable.Seq<A>,scala.collection.immutable.Seq<B>>	partition(scala.collection.immutable.Seq<T> ps, scala.Function1<T,scala.util.Either<A,B>> f)
<A, B> scala.Tuple2<scala.collection.immutable.Seq<A>,scala.collection.immutable.Seq<B>>	prepend(scala.Tuple2<scala.collection.immutable.Seq<A>,scala.collection.immutable.Seq<B>> acc, scala.util.Either<A,B> next)
<B> scala.Option<scala.Tuple4<scala.collection.immutable.Set<String>,scala.collection.immutable.Seq<B>,Object,scala.concurrent.duration.FiniteDuration>>	unapply(ShardingQueries.ShardsQueryResult<B> x$0)

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final ShardingQueries.ShardsQueryResult$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ShardsQueryResult$

public ShardsQueryResult$()

Method Details

apply

public <B> ShardingQueries.ShardsQueryResult<B> apply(scala.collection.immutable.Seq<scala.util.Either<String,B>> ps,
 int total,
 scala.concurrent.duration.FiniteDuration timeout)

Parameters:

ps - the partitioned results of actors queried that did not reply by the timeout or returned another failure and those that did

total - the total number of actors tracked versus a possible subset

partition

public <T,
A,
B>
scala.Tuple2<scala.collection.immutable.Seq<A>,scala.collection.immutable.Seq<B>> partition(scala.collection.immutable.Seq<T> ps,
 scala.Function1<T,scala.util.Either<A,B>> f)

prepend

public <A,
B>
scala.Tuple2<scala.collection.immutable.Seq<A>,scala.collection.immutable.Seq<B>> prepend(scala.Tuple2<scala.collection.immutable.Seq<A>,scala.collection.immutable.Seq<B>> acc,
 scala.util.Either<A,B> next)

apply

public <B> ShardingQueries.ShardsQueryResult<B> apply(scala.collection.immutable.Set<String> failed,
 scala.collection.immutable.Seq<B> responses,
 int total,
 scala.concurrent.duration.FiniteDuration timeout)

unapply

public <B>
scala.Option<scala.Tuple4<scala.collection.immutable.Set<String>,scala.collection.immutable.Seq<B>,Object,scala.concurrent.duration.FiniteDuration>> unapply(ShardingQueries.ShardsQueryResult<B> x$0)