Package akka.cluster.typed.internal.receptionist

Class ShardedServiceRegistry

java.lang.Object

akka.cluster.typed.internal.receptionist.ShardedServiceRegistry

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product, scala.Serializable

public final class ShardedServiceRegistry
extends java.lang.Object
implements scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ShardedServiceRegistry(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries, scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones, scala.collection.immutable.Set<UniqueAddress> nodes)

Method Summary

Modifier and Type	Method	Description
<T> scala.collection.immutable.Set<ActorRef<T>>	activeActorRefsFor(ServiceKey<T> key, UniqueAddress selfUniqueAddress)
<T> scala.collection.immutable.Set<ActorRef<T>>	actorRefsFor(ServiceKey<T> key)
ShardedServiceRegistry	addNode(UniqueAddress node)
ShardedServiceRegistry	addTombstone(ActorRef<?> actorRef, scala.concurrent.duration.Deadline deadline)
scala.collection.Iterable<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>>	allDdataKeys()
scala.collection.Iterator<ClusterReceptionist.Entry>	allEntries()
scala.collection.Iterator<scala.Tuple2<ServiceKey<?>,scala.collection.immutable.Set<ClusterReceptionist.Entry>>>	allServices()
scala.collection.immutable.Set<UniqueAddress>	allUniqueAddressesInState(UniqueAddress selfUniqueAddress)
static ShardedServiceRegistry	apply(int numberOfKeys)
static ShardedServiceRegistry	apply(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries, scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones, scala.collection.immutable.Set<UniqueAddress> nodes)	INTERNAL API
boolean	canEqual(java.lang.Object x$1)
scala.collection.immutable.Set<AbstractServiceKey>	collectChangedKeys(ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry> ddataKey, ServiceRegistry newRegistry)
ShardedServiceRegistry	copy(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries, scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones, scala.collection.immutable.Set<UniqueAddress> nodes)
scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry>	copy$default$1()
scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline>	copy$default$2()
scala.collection.immutable.Set<UniqueAddress>	copy$default$3()
ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>	ddataKeyFor(ServiceKey<?> serviceKey)
scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,scala.collection.immutable.Map<AbstractServiceKey,scala.collection.immutable.Set<ClusterReceptionist.Entry>>>	entriesPerDdataKey(scala.collection.immutable.Map<AbstractServiceKey,scala.collection.immutable.Set<ClusterReceptionist.Entry>> entries)
boolean	equals(java.lang.Object x$1)
int	hashCode()
boolean	hasTombstone(ActorRef<?> actorRef)
scala.collection.immutable.Set<UniqueAddress>	nodes()
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
ShardedServiceRegistry	pruneTombstones()
ServiceRegistry	registryFor(ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry> ddataKey)
ShardedServiceRegistry	removeNode(UniqueAddress node)
scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry>	serviceRegistries()
scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline>	tombstones()
java.lang.String	toString()
static scala.Option<scala.Tuple3<scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry>,scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline>,scala.collection.immutable.Set<UniqueAddress>>>	unapply(ShardedServiceRegistry x$0)
ShardedServiceRegistry	withServiceRegistry(ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry> ddataKey, ServiceRegistry registry)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ShardedServiceRegistry

public ShardedServiceRegistry(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries,
                              scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones,
                              scala.collection.immutable.Set<UniqueAddress> nodes)

Method Detail

apply

public static ShardedServiceRegistry apply(int numberOfKeys)

apply

public static ShardedServiceRegistry apply(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries,
                                           scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones,
                                           scala.collection.immutable.Set<UniqueAddress> nodes)

INTERNAL API

Two level structure for keeping service registry to be able to shard entries over multiple ddata keys (to not get too large ddata messages)

Parameters:

tombstones - Local actors that were stopped and should not be re-added to the available set of actors for a key. Since the only way to unregister is to stop, we don't need to keep track of the service key

serviceRegistries - (undocumented)

nodes - (undocumented)

Returns:

(undocumented)

unapply

public static scala.Option<scala.Tuple3<scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry>,scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline>,scala.collection.immutable.Set<UniqueAddress>>> unapply(ShardedServiceRegistry x$0)

serviceRegistries

public scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries()

tombstones

public scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones()

nodes

public scala.collection.immutable.Set<UniqueAddress> nodes()

registryFor

public ServiceRegistry registryFor(ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry> ddataKey)

allDdataKeys

public scala.collection.Iterable<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>> allDdataKeys()

ddataKeyFor

public ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry> ddataKeyFor(ServiceKey<?> serviceKey)

allServices

public scala.collection.Iterator<scala.Tuple2<ServiceKey<?>,scala.collection.immutable.Set<ClusterReceptionist.Entry>>> allServices()

allEntries

public scala.collection.Iterator<ClusterReceptionist.Entry> allEntries()

actorRefsFor

public <T> scala.collection.immutable.Set<ActorRef<T>> actorRefsFor(ServiceKey<T> key)

activeActorRefsFor

public <T> scala.collection.immutable.Set<ActorRef<T>> activeActorRefsFor(ServiceKey<T> key,
                                                                          UniqueAddress selfUniqueAddress)

withServiceRegistry

public ShardedServiceRegistry withServiceRegistry(ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry> ddataKey,
                                                  ServiceRegistry registry)

allUniqueAddressesInState

public scala.collection.immutable.Set<UniqueAddress> allUniqueAddressesInState(UniqueAddress selfUniqueAddress)

collectChangedKeys

public scala.collection.immutable.Set<AbstractServiceKey> collectChangedKeys(ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry> ddataKey,
                                                                             ServiceRegistry newRegistry)

entriesPerDdataKey

public scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,scala.collection.immutable.Map<AbstractServiceKey,scala.collection.immutable.Set<ClusterReceptionist.Entry>>> entriesPerDdataKey(scala.collection.immutable.Map<AbstractServiceKey,scala.collection.immutable.Set<ClusterReceptionist.Entry>> entries)

addTombstone

public ShardedServiceRegistry addTombstone(ActorRef<?> actorRef,
                                           scala.concurrent.duration.Deadline deadline)

hasTombstone

public boolean hasTombstone(ActorRef<?> actorRef)

pruneTombstones

public ShardedServiceRegistry pruneTombstones()

addNode

public ShardedServiceRegistry addNode(UniqueAddress node)

removeNode

public ShardedServiceRegistry removeNode(UniqueAddress node)

copy

public ShardedServiceRegistry copy(scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> serviceRegistries,
                                   scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> tombstones,
                                   scala.collection.immutable.Set<UniqueAddress> nodes)

copy$default$1

public scala.collection.immutable.Map<ORMultiMapKey<ServiceKey<?>,ClusterReceptionist.Entry>,ServiceRegistry> copy$default$1()

copy$default$2

public scala.collection.immutable.Map<ActorRef<?>,scala.concurrent.duration.Deadline> copy$default$2()

copy$default$3

public scala.collection.immutable.Set<UniqueAddress> copy$default$3()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object