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

    • Constructor Detail

      • RememberEntitiesShardStore

        public RememberEntitiesShardStore()