Package org.apache.pekko.cluster.sharding

Class ShardingQueries.ShardsQueryResult$

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

ShardingQueries

public static class ShardingQueries.ShardsQueryResult$
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static 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<java.lang.String,B>> ps, int total, scala.concurrent.duration.FiniteDuration timeout)
<B> ShardingQueries.ShardsQueryResult<B>	apply(scala.collection.immutable.Set<java.lang.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<java.lang.String>,scala.collection.immutable.Seq<B>,java.lang.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 Detail

MODULE$

public static final ShardingQueries.ShardsQueryResult$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ShardsQueryResult$

public ShardsQueryResult$()

Method Detail

apply

public <B> ShardingQueries.ShardsQueryResult<B> apply(scala.collection.immutable.Seq<scala.util.Either<java.lang.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<java.lang.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<java.lang.String>,scala.collection.immutable.Seq<B>,java.lang.Object,scala.concurrent.duration.FiniteDuration>> unapply(ShardingQueries.ShardsQueryResult<B> x$0)