Skip navigation links
A B C D E F G H I J L M N P R S T U W 

A

AbstractShardAllocationStrategy() - Constructor for class akka.cluster.sharding.ShardCoordinator.AbstractShardAllocationStrategy
 
activate() - Method in class akka.cluster.sharding.DDataShardCoordinator
 
active() - Method in class akka.cluster.sharding.ShardCoordinator
 
addAllEntities(Iterable<String>) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
addAllRegionProxies(Iterable<String>) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
addAllRegions(Iterable<String>) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
addAllShards(Iterable<? extends ClusterShardingMessages.CoordinatorState.ShardEntry>) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
addAllUnallocatedShards(Iterable<String>) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
addEntities(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
addEntitiesBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
addRegionProxies(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
addRegionProxiesBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
addRegions(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
addRegionsBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
addShards(ClusterShardingMessages.CoordinatorState.ShardEntry) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
addShards(int, ClusterShardingMessages.CoordinatorState.ShardEntry) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
addShards(ClusterShardingMessages.CoordinatorState.ShardEntry.Builder) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
addShards(int, ClusterShardingMessages.CoordinatorState.ShardEntry.Builder) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
addShardsBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
addShardsBuilder(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
addUnallocatedShards(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
addUnallocatedShardsBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
afterUpdateCallback() - Method in class akka.cluster.sharding.DDataShardCoordinator
 
ageOrdering() - Method in class akka.cluster.sharding.ShardRegion
 
akka.cluster.sharding - package akka.cluster.sharding
 
akka.cluster.sharding.protobuf - package akka.cluster.sharding.protobuf
 
akka.cluster.sharding.protobuf.msg - package akka.cluster.sharding.protobuf.msg
 
aliveRegions() - Method in class akka.cluster.sharding.ShardCoordinator
 
allocateShard(ActorRef, String, Map<ActorRef, IndexedSeq<String>>) - Method in class akka.cluster.sharding.ShardCoordinator.AbstractShardAllocationStrategy
 
allocateShard(ActorRef, String, Map<ActorRef, IndexedSeq<String>>) - Method in class akka.cluster.sharding.ShardCoordinator.AbstractShardAllocationStrategy
Invoked when the location of a new shard is to be decided.
allocateShard(ActorRef, String, Map<ActorRef, IndexedSeq<String>>) - Method in class akka.cluster.sharding.ShardCoordinator.LeastShardAllocationStrategy
 
allocateShard(ActorRef, String, Map<ActorRef, IndexedSeq<String>>) - Method in interface akka.cluster.sharding.ShardCoordinator.ShardAllocationStrategy
Invoked when the location of a new shard is to be decided.
allocateShardHomes() - Method in class akka.cluster.sharding.ShardCoordinator
 
allocationStrategy() - Method in class akka.cluster.sharding.ClusterShardingGuardian.Start
 
apply(ActorSystem) - Method in class akka.cluster.sharding.ClusterShardingSettings$
Create settings from the default configuration akka.cluster.sharding.
apply(Config) - Method in class akka.cluster.sharding.ClusterShardingSettings$
Create settings from a configuration with the same layout as the default configuration akka.cluster.sharding.
apply(ActorSystem) - Static method in class akka.cluster.sharding.ClusterShardingSettings
Create settings from the default configuration akka.cluster.sharding.
apply(Config) - Static method in class akka.cluster.sharding.ClusterShardingSettings
Create settings from a configuration with the same layout as the default configuration akka.cluster.sharding.

B

BeginHandOff(String) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.BeginHandOff
 
BeginHandOffAck(String) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.BeginHandOffAck
 
bufferMessage(String, Object, ActorRef) - Method in class akka.cluster.sharding.ShardRegion
 
bufferSize() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
build() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
buildPartial() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 

C

changeMembers(SortedSet<Member>) - Method in class akka.cluster.sharding.ShardRegion
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
clear() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
clearEntities() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
clearEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
required string entityId = 1;
clearEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
required string entityId = 1;
clearRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
required string ref = 1;
clearRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string region = 2;
clearRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string region = 2;
clearRegionProxies() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
clearRegionRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string regionRef = 2;
clearRegions() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
clearShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string shard = 1;
clearShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string shard = 1;
clearShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
required string shard = 1;
clearShardId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string shardId = 1;
clearShards() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
clearUnallocatedShards() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
clone() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
cluster() - Method in class akka.cluster.sharding.ClusterShardingGuardian
 
cluster() - Method in class akka.cluster.sharding.ShardCoordinator
 
cluster() - Method in class akka.cluster.sharding.ShardRegion
 
ClusterSharding - Class in akka.cluster.sharding
 
ClusterSharding(ExtendedActorSystem) - Constructor for class akka.cluster.sharding.ClusterSharding
 
ClusterSharding$ - Class in akka.cluster.sharding
This extension provides sharding functionality of actors in a cluster.
ClusterSharding$() - Constructor for class akka.cluster.sharding.ClusterSharding$
 
ClusterShardingGuardian - Class in akka.cluster.sharding
INTERNAL API.
ClusterShardingGuardian() - Constructor for class akka.cluster.sharding.ClusterShardingGuardian
 
ClusterShardingGuardian$ - Class in akka.cluster.sharding
INTERNAL API.
ClusterShardingGuardian$() - Constructor for class akka.cluster.sharding.ClusterShardingGuardian$
 
ClusterShardingGuardian.Start - Class in akka.cluster.sharding
 
ClusterShardingGuardian.Start$ - Class in akka.cluster.sharding
 
ClusterShardingGuardian.Started - Class in akka.cluster.sharding
 
ClusterShardingGuardian.Started$ - Class in akka.cluster.sharding
 
ClusterShardingGuardian.StartProxy - Class in akka.cluster.sharding
 
ClusterShardingGuardian.StartProxy$ - Class in akka.cluster.sharding
 
ClusterShardingMessages - Class in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.ActorRefMessage - Class in akka.cluster.sharding.protobuf.msg
Protobuf type ActorRefMessage
ClusterShardingMessages.ActorRefMessage.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type ActorRefMessage
ClusterShardingMessages.ActorRefMessageOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.CoordinatorState - Class in akka.cluster.sharding.protobuf.msg
Protobuf type CoordinatorState
ClusterShardingMessages.CoordinatorState.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type CoordinatorState
ClusterShardingMessages.CoordinatorState.ShardEntry - Class in akka.cluster.sharding.protobuf.msg
Protobuf type CoordinatorState.ShardEntry
ClusterShardingMessages.CoordinatorState.ShardEntry.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type CoordinatorState.ShardEntry
ClusterShardingMessages.CoordinatorState.ShardEntryOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.CoordinatorStateOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.EntityStarted - Class in akka.cluster.sharding.protobuf.msg
Protobuf type EntityStarted
ClusterShardingMessages.EntityStarted.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type EntityStarted
ClusterShardingMessages.EntityStartedOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.EntityState - Class in akka.cluster.sharding.protobuf.msg
Protobuf type EntityState
ClusterShardingMessages.EntityState.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type EntityState
ClusterShardingMessages.EntityStateOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.EntityStopped - Class in akka.cluster.sharding.protobuf.msg
Protobuf type EntityStopped
ClusterShardingMessages.EntityStopped.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type EntityStopped
ClusterShardingMessages.EntityStoppedOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.ShardHome - Class in akka.cluster.sharding.protobuf.msg
Protobuf type ShardHome
ClusterShardingMessages.ShardHome.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type ShardHome
ClusterShardingMessages.ShardHomeAllocated - Class in akka.cluster.sharding.protobuf.msg
Protobuf type ShardHomeAllocated
ClusterShardingMessages.ShardHomeAllocated.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type ShardHomeAllocated
ClusterShardingMessages.ShardHomeAllocatedOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.ShardHomeOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessages.ShardIdMessage - Class in akka.cluster.sharding.protobuf.msg
Protobuf type ShardIdMessage
ClusterShardingMessages.ShardIdMessage.Builder - Class in akka.cluster.sharding.protobuf.msg
Protobuf type ShardIdMessage
ClusterShardingMessages.ShardIdMessageOrBuilder - Interface in akka.cluster.sharding.protobuf.msg
 
ClusterShardingMessageSerializer - Class in akka.cluster.sharding.protobuf
INTERNAL API: Protobuf serializer of ClusterSharding messages.
ClusterShardingMessageSerializer(ExtendedActorSystem) - Constructor for class akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer
 
ClusterShardingSerializable - Interface in akka.cluster.sharding
Marker trait for remote messages and persistent events/snapshots with special serializer.
ClusterShardingSettings - Class in akka.cluster.sharding
param: role specifies that this entity type requires cluster nodes with a specific role.
ClusterShardingSettings(Option<String>, boolean, String, String, String, ClusterShardingSettings.TuningParameters, ClusterSingletonManagerSettings) - Constructor for class akka.cluster.sharding.ClusterShardingSettings
 
ClusterShardingSettings$ - Class in akka.cluster.sharding
 
ClusterShardingSettings$() - Constructor for class akka.cluster.sharding.ClusterShardingSettings$
 
ClusterShardingSettings.TuningParameters - Class in akka.cluster.sharding
 
continueGetShardHome(String, ActorRef, ActorRef) - Method in class akka.cluster.sharding.ShardCoordinator
 
continueRebalance(Set<String>) - Method in class akka.cluster.sharding.ShardCoordinator
 
coordinator() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.RegisterAck
 
coordinator() - Method in class akka.cluster.sharding.ShardRegion
 
coordinatorFailureBackoff() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
coordinatorSelection() - Method in class akka.cluster.sharding.ShardRegion
 
coordinatorSingletonSettings() - Method in class akka.cluster.sharding.ClusterShardingSettings
 
CoordinatorStateKey() - Method in class akka.cluster.sharding.DDataShardCoordinator
 
create(ActorSystem) - Method in class akka.cluster.sharding.ClusterShardingSettings$
Java API: Create settings from the default configuration akka.cluster.sharding.
create(Config) - Method in class akka.cluster.sharding.ClusterShardingSettings$
Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.sharding.
create(ActorSystem) - Static method in class akka.cluster.sharding.ClusterShardingSettings
Java API: Create settings from the default configuration akka.cluster.sharding.
create(Config) - Static method in class akka.cluster.sharding.ClusterShardingSettings
Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.sharding.
createExtension(ExtendedActorSystem) - Method in class akka.cluster.sharding.ClusterSharding$
 
createExtension(ExtendedActorSystem) - Static method in class akka.cluster.sharding.ClusterSharding
 
currentPid() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
currentRef() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
CurrentRegions(Set<Address>) - Constructor for class akka.cluster.sharding.ShardRegion.CurrentRegions
 
CurrentRegions$() - Constructor for class akka.cluster.sharding.ShardRegion.CurrentRegions$
 

D

DDataShardCoordinator - Class in akka.cluster.sharding
Singleton coordinator (with state based on ddata) that decides where to allocate shards.
DDataShardCoordinator(String, ClusterShardingSettings, ShardCoordinator.ShardAllocationStrategy, ActorRef) - Constructor for class akka.cluster.sharding.DDataShardCoordinator
 
deliverBufferedMessages(String, ActorRef) - Method in class akka.cluster.sharding.ShardRegion
 
deliverMessage(Object, ActorRef) - Method in class akka.cluster.sharding.Shard
 
deliverMessage(Object, ActorRef) - Method in class akka.cluster.sharding.ShardRegion
 
deliverTo(String, Object, Object, ActorRef) - Method in class akka.cluster.sharding.PersistentShard
 
deliverTo(String, Object, Object, ActorRef) - Method in class akka.cluster.sharding.Shard
 
done() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
done() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
done(boolean) - Method in class akka.cluster.sharding.ShardCoordinator.RebalanceWorker
 

E

Empty() - Method in class akka.cluster.sharding.Shard.State$
 
empty() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.State
 
entities() - Method in class akka.cluster.sharding.Shard.State
 
ENTITIES_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
entity() - Method in class akka.cluster.sharding.Shard.RestartEntity
 
entityId() - Method in class akka.cluster.sharding.Shard.EntityStarted
 
entityId() - Method in class akka.cluster.sharding.Shard.EntityStopped
 
entityId() - Method in interface akka.cluster.sharding.Shard.StateChange
 
entityId(Object) - Method in interface akka.cluster.sharding.ShardRegion.MessageExtractor
Extract the entity id from an incoming message.
ENTITYID_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
ENTITYID_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
entityMessage(Object) - Method in class akka.cluster.sharding.ShardRegion.HashCodeMessageExtractor
Default implementation pass on the message as is.
entityMessage(Object) - Method in interface akka.cluster.sharding.ShardRegion.MessageExtractor
Extract the message to send to the entity from an incoming message.
entityProps() - Method in class akka.cluster.sharding.ClusterShardingGuardian.Start
 
entityRestartBackoff() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
EntityStarted(String) - Constructor for class akka.cluster.sharding.Shard.EntityStarted
 
EntityStarted$() - Constructor for class akka.cluster.sharding.Shard.EntityStarted$
 
EntityStopped(String) - Constructor for class akka.cluster.sharding.Shard.EntityStopped
 
EntityStopped$() - Constructor for class akka.cluster.sharding.Shard.EntityStopped$
 
entityTerminated(ActorRef) - Method in class akka.cluster.sharding.PersistentShard
 
entityTerminated(ActorRef) - Method in class akka.cluster.sharding.Shard
 
events() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals
 
extractEntityId() - Method in class akka.cluster.sharding.ClusterShardingGuardian.Start
 
extractEntityId() - Method in class akka.cluster.sharding.ClusterShardingGuardian.StartProxy
 
extractShardId() - Method in class akka.cluster.sharding.ClusterShardingGuardian.Start
 
extractShardId() - Method in class akka.cluster.sharding.ClusterShardingGuardian.StartProxy
 

F

failure(Throwable) - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
failure(Throwable) - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
fromBinary(byte[], String) - Method in class akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer
 

G

get(ActorSystem) - Method in class akka.cluster.sharding.ClusterSharding$
 
get(ActorSystem) - Static method in class akka.cluster.sharding.ClusterSharding
 
GetCurrentRegions$() - Constructor for class akka.cluster.sharding.ShardRegion.GetCurrentRegions$
 
getCurrentRegionsInstance() - Method in class akka.cluster.sharding.ShardRegion$
 
getCurrentRegionsInstance() - Static method in class akka.cluster.sharding.ShardRegion
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
getDefaultInstance() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
getDefaultInstanceForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
getDescriptor() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
getDescriptorForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
getEntities(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
getEntities(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
repeated string entities = 1;
getEntities(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStateOrBuilder
repeated string entities = 1;
getEntitiesBytes(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
getEntitiesBytes(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
repeated string entities = 1;
getEntitiesBytes(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStateOrBuilder
repeated string entities = 1;
getEntitiesCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
getEntitiesCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
repeated string entities = 1;
getEntitiesCount() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStateOrBuilder
repeated string entities = 1;
getEntitiesList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
getEntitiesList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
repeated string entities = 1;
getEntitiesList() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStateOrBuilder
repeated string entities = 1;
getEntity(String) - Method in class akka.cluster.sharding.Shard
 
getEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
required string entityId = 1;
getEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
required string entityId = 1;
getEntityId() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStartedOrBuilder
required string entityId = 1;
getEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
required string entityId = 1;
getEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
required string entityId = 1;
getEntityId() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStoppedOrBuilder
required string entityId = 1;
getEntityIdBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
required string entityId = 1;
getEntityIdBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
required string entityId = 1;
getEntityIdBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStartedOrBuilder
required string entityId = 1;
getEntityIdBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
required string entityId = 1;
getEntityIdBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
required string entityId = 1;
getEntityIdBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStoppedOrBuilder
required string entityId = 1;
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
getParserForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
getRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
required string ref = 1;
getRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
required string ref = 1;
getRef() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessageOrBuilder
required string ref = 1;
getRefBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
required string ref = 1;
getRefBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
required string ref = 1;
getRefBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessageOrBuilder
required string ref = 1;
getRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string region = 2;
getRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
required string region = 2;
getRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string region = 2;
getRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
required string region = 2;
getRegion() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocatedOrBuilder
required string region = 2;
getRegion() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeOrBuilder
required string region = 2;
getRegionBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string region = 2;
getRegionBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
required string region = 2;
getRegionBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string region = 2;
getRegionBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
required string region = 2;
getRegionBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocatedOrBuilder
required string region = 2;
getRegionBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeOrBuilder
required string region = 2;
getRegionProxies(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
getRegionProxies(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string regionProxies = 3;
getRegionProxies(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string regionProxies = 3;
getRegionProxiesBytes(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
getRegionProxiesBytes(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string regionProxies = 3;
getRegionProxiesBytes(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string regionProxies = 3;
getRegionProxiesCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
getRegionProxiesCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string regionProxies = 3;
getRegionProxiesCount() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string regionProxies = 3;
getRegionProxiesList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
getRegionProxiesList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string regionProxies = 3;
getRegionProxiesList() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string regionProxies = 3;
getRegionRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string regionRef = 2;
getRegionRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
required string regionRef = 2;
getRegionRef() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntryOrBuilder
required string regionRef = 2;
getRegionRefBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string regionRef = 2;
getRegionRefBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
required string regionRef = 2;
getRegionRefBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntryOrBuilder
required string regionRef = 2;
getRegions(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
getRegions(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string regions = 2;
getRegions(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string regions = 2;
getRegions() - Method in class akka.cluster.sharding.ShardRegion.CurrentRegions
Java API
getRegionsBytes(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
getRegionsBytes(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string regions = 2;
getRegionsBytes(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string regions = 2;
getRegionsCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
getRegionsCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string regions = 2;
getRegionsCount() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string regions = 2;
getRegionsList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
getRegionsList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string regions = 2;
getRegionsList() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string regions = 2;
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
getSerializedSize() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
getShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string shard = 1;
getShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
required string shard = 1;
getShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string shard = 1;
getShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
required string shard = 1;
getShard() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocatedOrBuilder
required string shard = 1;
getShard() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeOrBuilder
required string shard = 1;
getShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
required string shard = 1;
getShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
required string shard = 1;
getShard() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessageOrBuilder
required string shard = 1;
getShard(String) - Method in class akka.cluster.sharding.ShardRegion
 
getShardBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string shard = 1;
getShardBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
required string shard = 1;
getShardBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string shard = 1;
getShardBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
required string shard = 1;
getShardBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocatedOrBuilder
required string shard = 1;
getShardBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeOrBuilder
required string shard = 1;
getShardBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
required string shard = 1;
getShardBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
required string shard = 1;
getShardBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessageOrBuilder
required string shard = 1;
GetShardHome(String) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.GetShardHome
 
getShardId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string shardId = 1;
getShardId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
required string shardId = 1;
getShardId() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntryOrBuilder
required string shardId = 1;
getShardIdBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string shardId = 1;
getShardIdBytes() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
required string shardId = 1;
getShardIdBytes() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntryOrBuilder
required string shardId = 1;
getShards(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
getShards(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated .CoordinatorState.ShardEntry shards = 1;
getShards(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsBuilder(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsBuilderList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsCount() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsList() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsOrBuilder(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsOrBuilder(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsOrBuilder(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsOrBuilderList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsOrBuilderList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated .CoordinatorState.ShardEntry shards = 1;
getShardsOrBuilderList() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated .CoordinatorState.ShardEntry shards = 1;
getState() - Method in class akka.cluster.sharding.DDataShardCoordinator
 
getUnallocatedShards(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
getUnallocatedShards(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string unallocatedShards = 4;
getUnallocatedShards(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string unallocatedShards = 4;
getUnallocatedShardsBytes(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
getUnallocatedShardsBytes(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string unallocatedShards = 4;
getUnallocatedShardsBytes(int) - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string unallocatedShards = 4;
getUnallocatedShardsCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
getUnallocatedShardsCount() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string unallocatedShards = 4;
getUnallocatedShardsCount() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string unallocatedShards = 4;
getUnallocatedShardsList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
getUnallocatedShardsList() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
repeated string unallocatedShards = 4;
getUnallocatedShardsList() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateOrBuilder
repeated string unallocatedShards = 4;
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
getUnknownFields() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
GracefulShutdown$() - Constructor for class akka.cluster.sharding.ShardRegion.GracefulShutdown$
 
gracefulShutdownInProgress() - Method in class akka.cluster.sharding.ShardCoordinator
 
gracefulShutdownInProgress() - Method in class akka.cluster.sharding.ShardRegion
 
gracefulShutdownInstance() - Method in class akka.cluster.sharding.ShardRegion$
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.
gracefulShutdownInstance() - Static method in class akka.cluster.sharding.ShardRegion
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.
GracefulShutdownReq(ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.GracefulShutdownReq
 

H

handingOff() - Method in class akka.cluster.sharding.ShardRegion
 
handleFailure() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
handOff(ActorRef) - Method in class akka.cluster.sharding.Shard
 
HandOff(String) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.HandOff
 
handOffStopMessage() - Method in class akka.cluster.sharding.ClusterShardingGuardian.Start
 
handOffStopper() - Method in class akka.cluster.sharding.Shard
 
HandOffStopper(String, ActorRef, Set<ActorRef>, Object) - Constructor for class akka.cluster.sharding.ShardRegion.HandOffStopper
 
handOffStopperProps(String, ActorRef, Set<ActorRef>, Object) - Method in class akka.cluster.sharding.ShardRegion$
 
handOffStopperProps(String, ActorRef, Set<ActorRef>, Object) - Static method in class akka.cluster.sharding.ShardRegion
 
handOffTimeout() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
hasEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
required string entityId = 1;
hasEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
required string entityId = 1;
hasEntityId() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStartedOrBuilder
required string entityId = 1;
hasEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
required string entityId = 1;
hasEntityId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
required string entityId = 1;
hasEntityId() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStoppedOrBuilder
required string entityId = 1;
HashCodeMessageExtractor(int) - Constructor for class akka.cluster.sharding.ShardRegion.HashCodeMessageExtractor
 
hasRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
required string ref = 1;
hasRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
required string ref = 1;
hasRef() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessageOrBuilder
required string ref = 1;
hasRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string region = 2;
hasRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
required string region = 2;
hasRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string region = 2;
hasRegion() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
required string region = 2;
hasRegion() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocatedOrBuilder
required string region = 2;
hasRegion() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeOrBuilder
required string region = 2;
hasRegionRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string regionRef = 2;
hasRegionRef() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
required string regionRef = 2;
hasRegionRef() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntryOrBuilder
required string regionRef = 2;
hasShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string shard = 1;
hasShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
required string shard = 1;
hasShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string shard = 1;
hasShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
required string shard = 1;
hasShard() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocatedOrBuilder
required string shard = 1;
hasShard() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeOrBuilder
required string shard = 1;
hasShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
required string shard = 1;
hasShard() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
required string shard = 1;
hasShard() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessageOrBuilder
required string shard = 1;
hasShardId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string shardId = 1;
hasShardId() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
required string shardId = 1;
hasShardId() - Method in interface akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntryOrBuilder
required string shardId = 1;
hasSnapshots() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
HostShard(String) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.HostShard
 

I

idByRef() - Method in class akka.cluster.sharding.Shard
 
initialized() - Method in class akka.cluster.sharding.PersistentShard
 
initialized() - Method in class akka.cluster.sharding.Shard
 
initializeShard(String, ActorRef) - Method in class akka.cluster.sharding.ShardRegion
 
Internal$() - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
internalGetFieldAccessorTable() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
isInitialized() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
isMember(ActorRef) - Method in class akka.cluster.sharding.ShardCoordinator
 

J

journalPluginId() - Method in class akka.cluster.sharding.ClusterShardingSettings
 
journalPluginId() - Method in class akka.cluster.sharding.PersistentShard
 
journalPluginId() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
journalPluginId() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 

L

leastShardAllocationMaxSimultaneousRebalance() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
leastShardAllocationRebalanceThreshold() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
LeastShardAllocationStrategy(int, int) - Constructor for class akka.cluster.sharding.ShardCoordinator.LeastShardAllocationStrategy
 
loggedFullBufferWarning() - Method in class akka.cluster.sharding.ShardRegion
 
lookup() - Method in class akka.cluster.sharding.ClusterSharding$
 
lookup() - Static method in class akka.cluster.sharding.ClusterSharding
 

M

main(String[]) - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData$
 
main(String[]) - Static method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
manifest(Object) - Method in class akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer
 
matchingRole(Member) - Method in class akka.cluster.sharding.ShardRegion
 
membersByAge() - Method in class akka.cluster.sharding.ShardRegion
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
mergeFrom(ClusterShardingMessages.ActorRefMessage) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
mergeFrom(ClusterShardingMessages.CoordinatorState) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
mergeFrom(ClusterShardingMessages.CoordinatorState.ShardEntry) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
mergeFrom(ClusterShardingMessages.EntityStarted) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
mergeFrom(ClusterShardingMessages.EntityState) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
mergeFrom(ClusterShardingMessages.EntityStopped) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
mergeFrom(ClusterShardingMessages.ShardHome) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
mergeFrom(ClusterShardingMessages.ShardHomeAllocated) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
 
mergeFrom(Message) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
mergeFrom(ClusterShardingMessages.ShardIdMessage) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
 
messageBuffers() - Method in class akka.cluster.sharding.Shard
 
MODULE$ - Static variable in class akka.cluster.sharding.ClusterSharding$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ClusterShardingGuardian$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ClusterShardingGuardian.Start$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ClusterShardingGuardian.Started$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ClusterShardingGuardian.StartProxy$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ClusterShardingSettings$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.RemoveInternalClusterShardingData$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.Shard$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.Shard.EntityStarted$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.Shard.EntityStopped$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.Shard.RestartEntity$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.Shard.State$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ShardCoordinator$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ShardCoordinator.Internal$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ShardRegion$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ShardRegion.CurrentRegions$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ShardRegion.GetCurrentRegions$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ShardRegion.GracefulShutdown$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ShardRegion.Passivate$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.cluster.sharding.ShardRegion.ShardInitialized$
Static reference to the singleton instance of this Scala object.

N

newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
newBuilder(ClusterShardingMessages.ActorRefMessage) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
newBuilder(ClusterShardingMessages.CoordinatorState) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
newBuilder(ClusterShardingMessages.CoordinatorState.ShardEntry) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
newBuilder(ClusterShardingMessages.EntityStarted) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
newBuilder(ClusterShardingMessages.EntityState) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
newBuilder(ClusterShardingMessages.EntityStopped) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
newBuilder(ClusterShardingMessages.ShardHome) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
newBuilder(ClusterShardingMessages.ShardHomeAllocated) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
newBuilder() - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
newBuilder(ClusterShardingMessages.ShardIdMessage) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
newBuilderForType() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
node() - Method in class akka.cluster.sharding.DDataShardCoordinator
 

P

parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseDelimitedFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
parseFrom(ByteString) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseFrom(byte[]) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseFrom(InputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseFrom(CodedInputStream) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
PARSER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
passivate(ActorRef, Object) - Method in class akka.cluster.sharding.Shard
 
Passivate(Object) - Constructor for class akka.cluster.sharding.ShardRegion.Passivate
 
Passivate$() - Constructor for class akka.cluster.sharding.ShardRegion.Passivate$
 
passivateCompleted(Shard.EntityStopped) - Method in class akka.cluster.sharding.Shard
 
passivating() - Method in class akka.cluster.sharding.Shard
 
persistCount() - Method in class akka.cluster.sharding.PersistentShard
 
persistCount() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
persistenceId() - Method in class akka.cluster.sharding.PersistentShard
 
persistenceId() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
persistenceId(String) - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
persistenceId() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
persistenceId2dot3(String) - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
PersistentShard - Class in akka.cluster.sharding
INTERNAL API
PersistentShard(String, String, Props, ClusterShardingSettings, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, Object) - Constructor for class akka.cluster.sharding.PersistentShard
 
PersistentShardCoordinator - Class in akka.cluster.sharding
Singleton coordinator that decides where to allocate shards.
PersistentShardCoordinator(String, ClusterShardingSettings, ShardCoordinator.ShardAllocationStrategy) - Constructor for class akka.cluster.sharding.PersistentShardCoordinator
 
postStop() - Method in class akka.cluster.sharding.ShardCoordinator
 
postStop() - Method in class akka.cluster.sharding.ShardRegion
 
preStart() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
preStart() - Method in class akka.cluster.sharding.ShardRegion
 
processChange(A, Function1<A, BoxedUnit>) - Method in class akka.cluster.sharding.PersistentShard
 
processChange(A, Function1<A, BoxedUnit>) - Method in class akka.cluster.sharding.Shard
 
props(String, Set<String>, Promise<BoxedUnit>, boolean) - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData$
INTERNAL API: Props for RemoveInternalClusterShardingData actor.
props(String, Set<String>, Promise<BoxedUnit>, boolean) - Static method in class akka.cluster.sharding.RemoveInternalClusterShardingData
INTERNAL API: Props for RemoveInternalClusterShardingData actor.
props(String, String, ActorRef) - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId$
 
props(String, String, Props, ClusterShardingSettings, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, Object) - Method in class akka.cluster.sharding.Shard$
Factory method for the Props of the Shard actor.
props(String, String, Props, ClusterShardingSettings, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, Object) - Static method in class akka.cluster.sharding.Shard
Factory method for the Props of the Shard actor.
props(String, ClusterShardingSettings, ShardCoordinator.ShardAllocationStrategy) - Method in class akka.cluster.sharding.ShardCoordinator$
INTERNAL API Factory method for the Props of the ShardCoordinator actor.
props(String, ClusterShardingSettings, ShardCoordinator.ShardAllocationStrategy, ActorRef) - Method in class akka.cluster.sharding.ShardCoordinator$
INTERNAL API Factory method for the Props of the ShardCoordinator actor with state based on ddata.
props(String, ClusterShardingSettings, akka.cluster.sharding.ShardCoordinator.ShardAllocationStrategy) - Static method in class akka.cluster.sharding.ShardCoordinator
INTERNAL API Factory method for the Props of the ShardCoordinator actor.
props(String, ClusterShardingSettings, akka.cluster.sharding.ShardCoordinator.ShardAllocationStrategy, ActorRef) - Static method in class akka.cluster.sharding.ShardCoordinator
INTERNAL API Factory method for the Props of the ShardCoordinator actor with state based on ddata.
props(String, Props, ClusterShardingSettings, String, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, Object) - Method in class akka.cluster.sharding.ShardRegion$
INTERNAL API Factory method for the Props of the ShardRegion actor.
props(String, Props, ClusterShardingSettings, String, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, Object) - Static method in class akka.cluster.sharding.ShardRegion
INTERNAL API Factory method for the Props of the ShardRegion actor.
proxyProps(String, ClusterShardingSettings, String, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>) - Method in class akka.cluster.sharding.ShardRegion$
INTERNAL API Factory method for the Props of the ShardRegion actor when using it in proxy only mode.
proxyProps(String, ClusterShardingSettings, String, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>) - Static method in class akka.cluster.sharding.ShardRegion
INTERNAL API Factory method for the Props of the ShardRegion actor when using it in proxy only mode.

R

rebalance(Map<ActorRef, IndexedSeq<String>>, Set<String>) - Method in class akka.cluster.sharding.ShardCoordinator.AbstractShardAllocationStrategy
 
rebalance(Map<ActorRef, IndexedSeq<String>>, Set<String>) - Method in class akka.cluster.sharding.ShardCoordinator.AbstractShardAllocationStrategy
Invoked periodically to decide which shards to rebalance to another location.
rebalance(Map<ActorRef, IndexedSeq<String>>, Set<String>) - Method in class akka.cluster.sharding.ShardCoordinator.LeastShardAllocationStrategy
 
rebalance(Map<ActorRef, IndexedSeq<String>>, Set<String>) - Method in interface akka.cluster.sharding.ShardCoordinator.ShardAllocationStrategy
Invoked periodically to decide which shards to rebalance to another location.
rebalanceInProgress() - Method in class akka.cluster.sharding.ShardCoordinator
 
rebalanceInterval() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
rebalanceTask() - Method in class akka.cluster.sharding.ShardCoordinator
 
RebalanceWorker(String, ActorRef, FiniteDuration, Set<ActorRef>) - Constructor for class akka.cluster.sharding.ShardCoordinator.RebalanceWorker
 
rebalanceWorkerProps(String, ActorRef, FiniteDuration, Set<ActorRef>) - Method in class akka.cluster.sharding.ShardCoordinator$
 
rebalanceWorkerProps(String, ActorRef, FiniteDuration, Set<ActorRef>) - Static method in class akka.cluster.sharding.ShardCoordinator
 
receive() - Method in class akka.cluster.sharding.ClusterShardingGuardian
 
receive() - Method in class akka.cluster.sharding.DDataShardCoordinator
 
receive() - Method in class akka.cluster.sharding.PersistentShard
 
receive() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
receive() - Method in class akka.cluster.sharding.Shard
 
receive() - Method in class akka.cluster.sharding.ShardCoordinator.RebalanceWorker
 
receive() - Method in class akka.cluster.sharding.ShardRegion.HandOffStopper
 
receive() - Method in class akka.cluster.sharding.ShardRegion
 
receiveClusterEvent(ClusterEvent.ClusterDomainEvent) - Method in class akka.cluster.sharding.ShardRegion
 
receiveClusterState(ClusterEvent.CurrentClusterState) - Method in class akka.cluster.sharding.ShardRegion
 
receiveCommand() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
receiveCommand() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
receiveCommand() - Method in class akka.cluster.sharding.Shard
 
receiveCommand(ShardRegion.ShardRegionCommand) - Method in class akka.cluster.sharding.ShardRegion
 
receiveCoordinatorMessage(akka.cluster.sharding.ShardCoordinator.Internal.CoordinatorMessage) - Method in class akka.cluster.sharding.Shard
 
receiveCoordinatorMessage(akka.cluster.sharding.ShardCoordinator.Internal.CoordinatorMessage) - Method in class akka.cluster.sharding.ShardRegion
 
receiveRecover() - Method in class akka.cluster.sharding.PersistentShard
 
receiveRecover() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
receiveRecover() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
receiveShardCommand(Shard.ShardCommand) - Method in class akka.cluster.sharding.Shard
 
receiveShardRegionCommand(ShardRegion.ShardRegionCommand) - Method in class akka.cluster.sharding.Shard
 
receiveSnapshotResult() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
receiveTerminated(ActorRef) - Method in class akka.cluster.sharding.Shard
 
receiveTerminated() - Method in class akka.cluster.sharding.ShardCoordinator
 
receiveTerminated(ActorRef) - Method in class akka.cluster.sharding.ShardRegion
 
ref() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardHome
 
REF_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
refById() - Method in class akka.cluster.sharding.Shard
 
region() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardHomeAllocated
 
region() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardRegionRegistered
 
region() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardRegionTerminated
 
REGION_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
REGION_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
regionByShard() - Method in class akka.cluster.sharding.ShardRegion
 
REGIONPROXIES_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
regionProxy() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardRegionProxyRegistered
 
regionProxy() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardRegionProxyTerminated
 
regionProxyTerminated(ActorRef) - Method in class akka.cluster.sharding.ShardCoordinator
 
REGIONREF_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
regions() - Method in class akka.cluster.sharding.ShardRegion.CurrentRegions
 
regions() - Method in class akka.cluster.sharding.ShardRegion
 
REGIONS_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
regionTerminated(ActorRef) - Method in class akka.cluster.sharding.ShardCoordinator
 
regionTerminationInProgress() - Method in class akka.cluster.sharding.ShardCoordinator
 
Register(ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.Register
 
register() - Method in class akka.cluster.sharding.ShardRegion
 
RegisterAck(ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.RegisterAck
 
registerAllExtensions(ExtensionRegistry) - Static method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages
 
RegisterProxy(ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.RegisterProxy
 
registrationMessage() - Method in class akka.cluster.sharding.ShardRegion
 
remaining() - Method in class akka.cluster.sharding.ShardCoordinator.RebalanceWorker
 
remaining() - Method in class akka.cluster.sharding.ShardRegion.HandOffStopper
 
remainingPids() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
rememberEntities() - Method in class akka.cluster.sharding.ClusterShardingSettings
 
removalMargin() - Method in class akka.cluster.sharding.ShardCoordinator
 
Removals(boolean, boolean) - Constructor for class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals
 
removals() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result
 
Removals$() - Constructor for class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals$
 
remove(ActorSystem, String, Set<String>, boolean, boolean) - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData$
remove(ActorSystem, String, Set<String>, boolean, boolean) - Static method in class akka.cluster.sharding.RemoveInternalClusterShardingData
RemoveInternalClusterShardingData - Class in akka.cluster.sharding
 
RemoveInternalClusterShardingData(String, Set<String>, Promise<BoxedUnit>, boolean) - Constructor for class akka.cluster.sharding.RemoveInternalClusterShardingData
 
RemoveInternalClusterShardingData$ - Class in akka.cluster.sharding
Utility program that removes the internal data stored with Akka Persistence by the Cluster Sharding coordinator.
RemoveInternalClusterShardingData$() - Constructor for class akka.cluster.sharding.RemoveInternalClusterShardingData$
 
RemoveInternalClusterShardingData.RemoveOnePersistenceId - Class in akka.cluster.sharding
INTERNAL API: Remove all events and snapshots for one specific persistenceId.
RemoveInternalClusterShardingData.RemoveOnePersistenceId$ - Class in akka.cluster.sharding
INTERNAL API
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals - Class in akka.cluster.sharding
 
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals$ - Class in akka.cluster.sharding
 
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result - Class in akka.cluster.sharding
 
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result$ - Class in akka.cluster.sharding
 
removeNext() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData
 
RemoveOnePersistenceId(String, String, ActorRef) - Constructor for class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
RemoveOnePersistenceId$() - Constructor for class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId$
 
removeShards(int) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
replicator() - Method in class akka.cluster.sharding.ClusterShardingGuardian
 
requestShardBufferHomes() - Method in class akka.cluster.sharding.ShardRegion
 
requireClusterRole(Option<String>) - Method in class akka.cluster.sharding.ClusterSharding
 
RestartEntity(String) - Constructor for class akka.cluster.sharding.Shard.RestartEntity
 
RestartEntity$() - Constructor for class akka.cluster.sharding.Shard.RestartEntity$
 
Result(Try<RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals>) - Constructor for class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result
 
Result$() - Constructor for class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result$
 
retryCount() - Method in class akka.cluster.sharding.ShardRegion
 
retryInterval() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
retryTask() - Method in class akka.cluster.sharding.ShardRegion
 
role() - Method in class akka.cluster.sharding.ClusterShardingSettings
 
roleOption(String) - Method in class akka.cluster.sharding.ClusterShardingSettings$
INTERNAL API
roleOption(String) - Static method in class akka.cluster.sharding.ClusterShardingSettings
INTERNAL API

S

saveSnapshotWhenNeeded() - Method in class akka.cluster.sharding.PersistentShard
 
saveSnapshotWhenNeeded() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
sendGracefulShutdownToCoordinator() - Method in class akka.cluster.sharding.ShardRegion
 
sendHostShardMsg(String, ActorRef) - Method in class akka.cluster.sharding.ShardCoordinator
 
sendMsgBuffer(Shard.EntityStarted) - Method in class akka.cluster.sharding.Shard
 
sendUpdate(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent) - Method in class akka.cluster.sharding.DDataShardCoordinator
 
setEntities(int, String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState.Builder
repeated string entities = 1;
setEntityId(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
required string entityId = 1;
setEntityId(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
required string entityId = 1;
setEntityIdBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted.Builder
required string entityId = 1;
setEntityIdBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped.Builder
required string entityId = 1;
setRef(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
required string ref = 1;
setRefBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage.Builder
required string ref = 1;
setRegion(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string region = 2;
setRegion(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string region = 2;
setRegionBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string region = 2;
setRegionBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string region = 2;
setRegionProxies(int, String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regionProxies = 3;
setRegionRef(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string regionRef = 2;
setRegionRefBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string regionRef = 2;
setRegions(int, String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string regions = 2;
setShard(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string shard = 1;
setShard(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string shard = 1;
setShard(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
required string shard = 1;
setShardBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome.Builder
required string shard = 1;
setShardBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated.Builder
required string shard = 1;
setShardBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage.Builder
required string shard = 1;
setShardId(String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string shardId = 1;
setShardIdBytes(ByteString) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry.Builder
required string shardId = 1;
setShards(int, ClusterShardingMessages.CoordinatorState.ShardEntry) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
setShards(int, ClusterShardingMessages.CoordinatorState.ShardEntry.Builder) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated .CoordinatorState.ShardEntry shards = 1;
settings() - Method in class akka.cluster.sharding.ClusterShardingGuardian.Start
 
settings() - Method in class akka.cluster.sharding.ClusterShardingGuardian.StartProxy
 
setUnallocatedShards(int, String) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.Builder
repeated string unallocatedShards = 4;
Shard - Class in akka.cluster.sharding
INTERNAL API
Shard(String, String, Props, ClusterShardingSettings, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, Object) - Constructor for class akka.cluster.sharding.Shard
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.BeginHandOff
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.BeginHandOffAck
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.GetShardHome
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.HandOff
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.HostShard
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardHome
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardHomeAllocated
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardHomeDeallocated
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardStarted
 
shard() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.ShardStopped
 
Shard$ - Class in akka.cluster.sharding
INTERNAL API
Shard$() - Constructor for class akka.cluster.sharding.Shard$
 
Shard.EntityStarted - Class in akka.cluster.sharding
State change for starting an entity in this Shard
Shard.EntityStarted$ - Class in akka.cluster.sharding
 
Shard.EntityStopped - Class in akka.cluster.sharding
State change for an entity which has terminated.
Shard.EntityStopped$ - Class in akka.cluster.sharding
 
Shard.RestartEntity - Class in akka.cluster.sharding
When an remembering entities and the entity stops without issuing a Passivate, we restart it after a back off using this message.
Shard.RestartEntity$ - Class in akka.cluster.sharding
 
Shard.ShardCommand - Interface in akka.cluster.sharding
A Shard command
Shard.State - Class in akka.cluster.sharding
 
Shard.State$ - Class in akka.cluster.sharding
 
Shard.StateChange - Interface in akka.cluster.sharding
A case class which represents a state change for the Shard
SHARD_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
SHARD_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
SHARD_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
shardBuffers() - Method in class akka.cluster.sharding.ShardRegion
 
ShardCoordinator - Class in akka.cluster.sharding
Singleton coordinator that decides where to allocate shards.
ShardCoordinator(String, ClusterShardingSettings, akka.cluster.sharding.ShardCoordinator.ShardAllocationStrategy) - Constructor for class akka.cluster.sharding.ShardCoordinator
 
ShardCoordinator$ - Class in akka.cluster.sharding
 
ShardCoordinator$() - Constructor for class akka.cluster.sharding.ShardCoordinator$
 
ShardCoordinator.AbstractShardAllocationStrategy - Class in akka.cluster.sharding
Java API: Java implementations of custom shard allocation and rebalancing logic used by the ShardCoordinator should extend this abstract class and implement the two methods.
ShardCoordinator.Internal$ - Class in akka.cluster.sharding
INTERNAL API
ShardCoordinator.Internal$.BeginHandOff - Class in akka.cluster.sharding
ShardCoordinator initiates rebalancing process by sending this message to all registered ShardRegion actors (including proxy only).
ShardCoordinator.Internal$.BeginHandOffAck - Class in akka.cluster.sharding
ShardCoordinator.Internal$.CoordinatorCommand - Interface in akka.cluster.sharding
Messages sent to the coordinator
ShardCoordinator.Internal$.CoordinatorMessage - Interface in akka.cluster.sharding
Messages sent from the coordinator
ShardCoordinator.Internal$.DomainEvent - Interface in akka.cluster.sharding
 
ShardCoordinator.Internal$.GetShardHome - Class in akka.cluster.sharding
ShardRegion requests the location of a shard by sending this message to the ShardCoordinator.
ShardCoordinator.Internal$.GracefulShutdownReq - Class in akka.cluster.sharding
ShardRegion requests full handoff to be able to shutdown gracefully.
ShardCoordinator.Internal$.HandOff - Class in akka.cluster.sharding
When all ShardRegion actors have acknowledged the BeginHandOff the ShardCoordinator sends this message to the ShardRegion responsible for the shard.
ShardCoordinator.Internal$.HostShard - Class in akka.cluster.sharding
ShardCoordinator informs a ShardRegion that it is hosting this shard
ShardCoordinator.Internal$.Register - Class in akka.cluster.sharding
ShardRegion registers to ShardCoordinator, until it receives ShardCoordinator.Internal$.RegisterAck.
ShardCoordinator.Internal$.RegisterAck - Class in akka.cluster.sharding
Acknowledgement from ShardCoordinator that ShardCoordinator.Internal$.Register or ShardCoordinator.Internal$.RegisterProxy was successful.
ShardCoordinator.Internal$.RegisterProxy - Class in akka.cluster.sharding
ShardRegion in proxy only mode registers to ShardCoordinator, until it receives ShardCoordinator.Internal$.RegisterAck.
ShardCoordinator.Internal$.ShardHome - Class in akka.cluster.sharding
ShardCoordinator replies with this message for ShardCoordinator.Internal$.GetShardHome requests.
ShardCoordinator.Internal$.ShardHomeAllocated - Class in akka.cluster.sharding
 
ShardCoordinator.Internal$.ShardHomeDeallocated - Class in akka.cluster.sharding
 
ShardCoordinator.Internal$.ShardRegionProxyRegistered - Class in akka.cluster.sharding
 
ShardCoordinator.Internal$.ShardRegionProxyTerminated - Class in akka.cluster.sharding
 
ShardCoordinator.Internal$.ShardRegionRegistered - Class in akka.cluster.sharding
 
ShardCoordinator.Internal$.ShardRegionTerminated - Class in akka.cluster.sharding
 
ShardCoordinator.Internal$.ShardStarted - Class in akka.cluster.sharding
ShardRegion replies with this message for ShardCoordinator.Internal$.HostShard requests which lead to it hosting the shard
ShardCoordinator.Internal$.ShardStopped - Class in akka.cluster.sharding
Reply to HandOff when all entities in the shard have been terminated.
ShardCoordinator.Internal$.State - Class in akka.cluster.sharding
 
ShardCoordinator.Internal$.StateInitialized - Class in akka.cluster.sharding
 
ShardCoordinator.LeastShardAllocationStrategy - Class in akka.cluster.sharding
The default implementation of ShardCoordinator.LeastShardAllocationStrategy allocates new shards to the ShardRegion with least number of previously allocated shards.
ShardCoordinator.RebalanceWorker - Class in akka.cluster.sharding
INTERNAL API.
ShardCoordinator.ShardAllocationStrategy - Interface in akka.cluster.sharding
Interface of the pluggable shard allocation and rebalancing logic used by the ShardCoordinator.
shardFailureBackoff() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
ShardHome(String, ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardHome
 
ShardHomeAllocated(String, ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardHomeAllocated
 
ShardHomeDeallocated(String) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardHomeDeallocated
 
shardId(Object) - Method in class akka.cluster.sharding.ShardRegion.HashCodeMessageExtractor
 
shardId(Object) - Method in interface akka.cluster.sharding.ShardRegion.MessageExtractor
Extract the entity id from an incoming message.
shardId() - Method in class akka.cluster.sharding.ShardRegion.ShardInitialized
 
SHARDID_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
sharding() - Method in class akka.cluster.sharding.ClusterShardingGuardian
 
ShardInitialized(String) - Constructor for class akka.cluster.sharding.ShardRegion.ShardInitialized
 
ShardInitialized$() - Constructor for class akka.cluster.sharding.ShardRegion.ShardInitialized$
 
shardRegion(String) - Method in class akka.cluster.sharding.ClusterSharding
Retrieve the actor reference of the ShardRegion actor responsible for the named entity type.
shardRegion() - Method in class akka.cluster.sharding.ClusterShardingGuardian.Started
 
shardRegion() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.GracefulShutdownReq
 
shardRegion() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.Register
 
ShardRegion - Class in akka.cluster.sharding
This actor creates children entity actors on demand for the shards that it is told to be responsible for.
ShardRegion(String, Option<Props>, ClusterShardingSettings, String, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, Object) - Constructor for class akka.cluster.sharding.ShardRegion
 
ShardRegion$ - Class in akka.cluster.sharding
 
ShardRegion$() - Constructor for class akka.cluster.sharding.ShardRegion$
 
ShardRegion.CurrentRegions - Class in akka.cluster.sharding
Reply to GetCurrentRegions
ShardRegion.CurrentRegions$ - Class in akka.cluster.sharding
 
ShardRegion.GetCurrentRegions$ - Class in akka.cluster.sharding
 
ShardRegion.GracefulShutdown$ - Class in akka.cluster.sharding
 
ShardRegion.HandOffStopper - Class in akka.cluster.sharding
INTERNAL API.
ShardRegion.HashCodeMessageExtractor - Class in akka.cluster.sharding
Convenience implementation of ShardRegion.MessageExtractor that construct shardId based on the hashCode of the entityId.
ShardRegion.MessageExtractor - Interface in akka.cluster.sharding
Java API: Interface of functions to extract entity id, shard id, and the message to send to the entity from an incoming message.
ShardRegion.Passivate - Class in akka.cluster.sharding
If the state of the entities are persistent you may stop entities that are not used to reduce memory consumption.
ShardRegion.Passivate$ - Class in akka.cluster.sharding
 
ShardRegion.ShardInitialized - Class in akka.cluster.sharding
We must be sure that a shard is initialized before to start send messages to it.
ShardRegion.ShardInitialized$ - Class in akka.cluster.sharding
 
ShardRegion.ShardRegionCommand - Interface in akka.cluster.sharding
 
shardRegionProxy() - Method in class akka.cluster.sharding.ShardCoordinator.Internal$.RegisterProxy
 
ShardRegionProxyRegistered(ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardRegionProxyRegistered
 
ShardRegionProxyTerminated(ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardRegionProxyTerminated
 
ShardRegionRegistered(ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardRegionRegistered
 
ShardRegionTerminated(ActorRef) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardRegionTerminated
 
shards() - Method in class akka.cluster.sharding.ShardRegion
 
SHARDS_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
shardsByRef() - Method in class akka.cluster.sharding.ShardRegion
 
ShardStarted(String) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardStarted
 
shardStartTimeout() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
ShardStopped(String) - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.ShardStopped
 
shuttingDown() - Method in class akka.cluster.sharding.ShardCoordinator
 
snapshotAfter() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
snapshotPluginId() - Method in class akka.cluster.sharding.ClusterShardingSettings
 
snapshotPluginId() - Method in class akka.cluster.sharding.PersistentShard
 
snapshotPluginId() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
snapshots() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals
 
start(String, Props, ClusterShardingSettings, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, ShardCoordinator.ShardAllocationStrategy, Object) - Method in class akka.cluster.sharding.ClusterSharding
Scala API: Register a named entity type by defining the Props of the entity actor and functions to extract entity and shard identifier from messages.
start(String, Props, ClusterShardingSettings, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>) - Method in class akka.cluster.sharding.ClusterSharding
Register a named entity type by defining the Props of the entity actor and functions to extract entity and shard identifier from messages.
start(String, Props, ClusterShardingSettings, ShardRegion.MessageExtractor, ShardCoordinator.ShardAllocationStrategy, Object) - Method in class akka.cluster.sharding.ClusterSharding
Java/Scala API: Register a named entity type by defining the Props of the entity actor and functions to extract entity and shard identifier from messages.
start(String, Props, ClusterShardingSettings, ShardRegion.MessageExtractor) - Method in class akka.cluster.sharding.ClusterSharding
Java/Scala API: Register a named entity type by defining the Props of the entity actor and functions to extract entity and shard identifier from messages.
Start(String, Props, ClusterShardingSettings, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, ShardCoordinator.ShardAllocationStrategy, Object) - Constructor for class akka.cluster.sharding.ClusterShardingGuardian.Start
 
Start$() - Constructor for class akka.cluster.sharding.ClusterShardingGuardian.Start$
 
Started(ActorRef) - Constructor for class akka.cluster.sharding.ClusterShardingGuardian.Started
 
Started$() - Constructor for class akka.cluster.sharding.ClusterShardingGuardian.Started$
 
startProxy(String, Option<String>, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>) - Method in class akka.cluster.sharding.ClusterSharding
Scala API: Register a named entity type ShardRegion on this node that will run in proxy only mode, i.e.
startProxy(String, Optional<String>, ShardRegion.MessageExtractor) - Method in class akka.cluster.sharding.ClusterSharding
Java/Scala API: Register a named entity type ShardRegion on this node that will run in proxy only mode, i.e.
StartProxy(String, ClusterShardingSettings, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>) - Constructor for class akka.cluster.sharding.ClusterShardingGuardian.StartProxy
 
StartProxy$() - Constructor for class akka.cluster.sharding.ClusterShardingGuardian.StartProxy$
 
state() - Method in class akka.cluster.sharding.Shard
 
State(Set<String>) - Constructor for class akka.cluster.sharding.Shard.State
 
State() - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.State
 
state() - Method in class akka.cluster.sharding.ShardCoordinator
 
State$() - Constructor for class akka.cluster.sharding.Shard.State$
 
StateInitialized() - Constructor for class akka.cluster.sharding.ShardCoordinator.Internal$.StateInitialized
 
stateInitialized() - Method in class akka.cluster.sharding.ShardCoordinator
 
stateStoreMode() - Method in class akka.cluster.sharding.ClusterShardingSettings
 
stopMessage() - Method in class akka.cluster.sharding.ShardRegion.Passivate
 
stoppingShard() - Method in class akka.cluster.sharding.ShardCoordinator.RebalanceWorker
 
system() - Method in class akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer
 

T

toBinary(Object) - Method in class akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
toBuilder() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
totalBufferSize() - Method in class akka.cluster.sharding.Shard
 
totalBufferSize() - Method in class akka.cluster.sharding.ShardRegion
 
tuningParameters() - Method in class akka.cluster.sharding.ClusterShardingSettings
 
TuningParameters(FiniteDuration, FiniteDuration, int, FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration, int, int, int, FiniteDuration, FiniteDuration) - Constructor for class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
typeName() - Method in class akka.cluster.sharding.ClusterShardingGuardian.Start
 
typeName() - Method in class akka.cluster.sharding.ClusterShardingGuardian.StartProxy
 

U

unAckedHostShards() - Method in class akka.cluster.sharding.ShardCoordinator
 
UNALLOCATEDSHARDS_FIELD_NUMBER - Static variable in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
update(E, Function1<E, BoxedUnit>) - Method in class akka.cluster.sharding.DDataShardCoordinator
 
update(E, Function1<E, BoxedUnit>) - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
update(E, Function1<E, BoxedUnit>) - Method in class akka.cluster.sharding.ShardCoordinator
 
updateSuccess(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent) - Method in class akka.cluster.sharding.DDataShardCoordinator
 
updatingStateTimeout() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
updatingStateTimeout() - Method in class akka.cluster.sharding.DDataShardCoordinator
 

W

waitDeleteMessagesSuccess() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
waitDeleteSnapshotsSuccess() - Method in class akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId
 
waitingForState() - Method in class akka.cluster.sharding.DDataShardCoordinator
 
waitingForStateInitialized() - Method in class akka.cluster.sharding.DDataShardCoordinator
 
waitingForStateInitialized() - Method in class akka.cluster.sharding.PersistentShardCoordinator
 
waitingForStateTimeout() - Method in class akka.cluster.sharding.ClusterShardingSettings.TuningParameters
 
waitingForStateTimeout() - Method in class akka.cluster.sharding.DDataShardCoordinator
 
waitingForUpdate(E) - Method in class akka.cluster.sharding.DDataShardCoordinator
 
watchStateActors() - Method in class akka.cluster.sharding.ShardCoordinator
 
withCoordinatorSingletonSettings(ClusterSingletonManagerSettings) - Method in class akka.cluster.sharding.ClusterShardingSettings
 
withJournalPluginId(String) - Method in class akka.cluster.sharding.ClusterShardingSettings
 
withRememberEntities(boolean) - Method in class akka.cluster.sharding.ClusterShardingSettings
 
withRole(String) - Method in class akka.cluster.sharding.ClusterShardingSettings
 
withRole(Option<String>) - Method in class akka.cluster.sharding.ClusterShardingSettings
 
withSnapshotPluginId(String) - Method in class akka.cluster.sharding.ClusterShardingSettings
 
withTuningParameters(ClusterShardingSettings.TuningParameters) - Method in class akka.cluster.sharding.ClusterShardingSettings
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
writeReplace() - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated
 
writeTo(CodedOutputStream) - Method in class akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage
 
A B C D E F G H I J L M N P R S T U W 
Skip navigation links