Class RememberEntitiesShardStore
- java.lang.Object
-
- akka.cluster.sharding.internal.RememberEntitiesShardStore
-
public class RememberEntitiesShardStore extends java.lang.ObjectINTERNAL APICould potentially become an open SPI in the future.
Protocol contract for implementations (the store is a local child actor of the shard, which death-watches it): - In response to
GetEntitiesthe store must eventually reply withRememberEntitiesShardStore.RememberedEntities. The shard does not put a timeout on this, because the load can legitimately be slow (e.g. when many shards recover their stores concurrently during a rolling restart). Therefore, if the store cannot load its state (e.g. failed recovery) it must stop itself; the shard detects the termination via death watch and is restarted after a backoff. A store that stays alive without replying would leave the shard stuck. - In response toRememberEntitiesShardStore.Updatethe store must eventually reply withRememberEntitiesShardStore.UpdateDone(the shard does bound this withupdating-state-timeout) or stop itself on failure.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interfaceRememberEntitiesShardStore.Commandstatic classRememberEntitiesShardStore.GetEntities$static classRememberEntitiesShardStore.RememberedEntitiesstatic classRememberEntitiesShardStore.RememberedEntities$static classRememberEntitiesShardStore.Updatestatic classRememberEntitiesShardStore.Update$static classRememberEntitiesShardStore.UpdateDonestatic classRememberEntitiesShardStore.UpdateDone$
-
Constructor Summary
Constructors Constructor Description RememberEntitiesShardStore()
-