Class RememberEntitiesShardStore$


  • public class RememberEntitiesShardStore$
    extends java.lang.Object
    INTERNAL API

    Could 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 GetEntities the store must eventually reply with 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 to Update the store must eventually reply with UpdateDone (the shard does bound this with updating-state-timeout) or stop itself on failure.

    • Method Summary

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • RememberEntitiesShardStore$

        public RememberEntitiesShardStore$()