public class PersistentShardCoordinator extends ShardCoordinator implements akka.persistence.PersistentActor
ClusterSharding extension
ShardCoordinator.AbstractShardAllocationStrategy, ShardCoordinator.Internal$, ShardCoordinator.LeastShardAllocationStrategy, ShardCoordinator.RebalanceWorker, ShardCoordinator.ShardAllocationStrategy
akka.persistence.Eventsourced.AsyncHandlerInvocation, akka.persistence.Eventsourced.AsyncHandlerInvocation$, akka.persistence.Eventsourced.PendingHandlerInvocation, akka.persistence.Eventsourced.ProcessingState, akka.persistence.Eventsourced.StashingHandlerInvocation, akka.persistence.Eventsourced.StashingHandlerInvocation$, akka.persistence.Eventsourced.State
Constructor and Description |
---|
PersistentShardCoordinator(java.lang.String typeName,
ClusterShardingSettings settings,
ShardCoordinator.ShardAllocationStrategy allocationStrategy) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
journalPluginId() |
int |
persistCount() |
java.lang.String |
persistenceId() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveCommand() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveRecover() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveSnapshotResult() |
void |
saveSnapshotWhenNeeded() |
java.lang.String |
snapshotPluginId() |
<E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> |
update(E evt,
scala.Function1<E,scala.runtime.BoxedUnit> f) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
waitingForStateInitialized() |
active, aliveRegions, allocateShardHomes, cluster, continueGetShardHome, continueRebalance, gracefulShutdownInProgress, isMember, postStop, props, props, rebalanceInProgress, rebalanceTask, rebalanceWorkerProps, receiveTerminated, regionProxyTerminated, regionTerminated, regionTerminationInProgress, removalMargin, sendHostShardMsg, shuttingDown, state, stateInitialized, unAckedHostShards, watchStateActors
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$extension_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$instanceId_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$internalStash_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$maxMessageBatchSize_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$pendingInvocations_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$persistingEvents_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$processingCommands_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$unstashFilterPredicate_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$writerUuid_$eq, akka$persistence$Eventsourced$$_lastSequenceNr_$eq, akka$persistence$Eventsourced$$_lastSequenceNr, akka$persistence$Eventsourced$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, deferAsync, deleteMessages, journal, lastSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, persist, persist, persistAll, persistAllAsync, persistAsync, persistAsync, recoveryFinished, recoveryRunning, snapshotSequenceNr, snapshotStore, snapshotterId, unhandled, unstashAll
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, self, sender, supervisorStrategy
akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, stash, unstash, unstashAll
public PersistentShardCoordinator(java.lang.String typeName, ClusterShardingSettings settings, ShardCoordinator.ShardAllocationStrategy allocationStrategy)
public java.lang.String persistenceId()
persistenceId
in interface akka.persistence.PersistenceIdentity
public java.lang.String journalPluginId()
journalPluginId
in interface akka.persistence.PersistenceIdentity
public java.lang.String snapshotPluginId()
snapshotPluginId
in interface akka.persistence.PersistenceIdentity
public int persistCount()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveRecover()
receiveRecover
in interface akka.persistence.Eventsourced
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveCommand()
receiveCommand
in interface akka.persistence.Eventsourced
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForStateInitialized()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveSnapshotResult()
public <E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> void update(E evt, scala.Function1<E,scala.runtime.BoxedUnit> f)
update
in class ShardCoordinator
public void saveSnapshotWhenNeeded()