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(java.lang.String persistenceId)	Deprecated. Use the deleteObject overload with revision instead.
scala.concurrent.Future<Done>	deleteObject(java.lang.String persistenceId, long revision)	Delete the object with the given persistenceId and revision.
scala.concurrent.Future<Done>	upsertObject(java.lang.String persistenceId, long revision, A value, java.lang.String tag)	Upsert the object with the given persistenceId and revision.

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

getObject

Method Detail

deleteObject

scala.concurrent.Future<Done> deleteObject(java.lang.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(java.lang.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(java.lang.String persistenceId,
                                           long revision,
                                           A value,
                                           java.lang.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