Package org.apache.pekko.persistence.state.scaladsl

Interface DurableStateUpdateStore<A>

All Superinterfaces:
DurableStateStore<A>
All Known Implementing Classes:
PersistenceTestKitDurableStateStore
public interface DurableStateUpdateStore<A> extends DurableStateStore<A>
API for updating durable state objects.

For Java API see pekko.persistence.state.javadsl.DurableStateUpdateStore.

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.concurrent.Future<Done>
    deleteObject(String persistenceId)
    Deprecated.
    Use the deleteObject overload with revision instead.
    scala.concurrent.Future<Done>
    deleteObject(String persistenceId, long revision)
    Delete the object with the given persistenceId and revision.
    scala.concurrent.Future<Done>
    upsertObject(String persistenceId, long revision, A value, String tag)
    Upsert the object with the given persistenceId and revision.

    Methods inherited from interface org.apache.pekko.persistence.state.scaladsl.DurableStateStore

    getObject

  • Method Details

    • deleteObject

      scala.concurrent.Future<Done> deleteObject(String persistenceId)
      Deprecated.
      Use the deleteObject overload with revision instead. Since Akka 2.6.20.
      Delete the object with the given persistenceId. This deprecated function ignores whether the object is deleted or not.

      Parameters:
      persistenceId - the persistenceId of the object to delete
      revision - the revision of the object to delete
      Returns:
      a Future that completes when the object has been deleted

    • deleteObject

      scala.concurrent.Future<Done> deleteObject(String persistenceId, long revision)
      Delete the object with the given persistenceId and revision.

      Since Pekko v1.1, if the revision does not match the current revision of the object, the delete operation will fail. The returned Future will complete with a failed result wrapping the exception.

      Parameters:
      persistenceId - the persistenceId of the object to delete
      revision - the revision of the object to delete
      Returns:
      a Future that completes when the object has been deleted

    • upsertObject

      scala.concurrent.Future<Done> upsertObject(String persistenceId, long revision, A value, String tag)
      Upsert the object with the given persistenceId and revision.

      Parameters:
      persistenceId - the persistenceId of the object to upsert
      revision - the revision of the object to upsert
      value - the value to upsert
      tag - a tag to associate with the object
      Returns:
      a Future that completes when the object has been upserted