ProcessingPolicy

org.apache.pekko.persistence.testkit.ProcessingPolicy
See theProcessingPolicy companion object

Policies allow to emulate behavior of the storage (failures and rejections).

Type parameters

U

type determines operations which storage can perform.

Attributes

Companion
object
Source
ProcessingPolicy.scala
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

def tryProcess(processId: String, processingUnit: U): ProcessingResult

Emulates behavior of the storage. The function is invoked when any of the plugin's operations is executed. If you need this operation to succeed return ProcessingSuccess, otherwise you should return some of the ProcessingFailure's.

Emulates behavior of the storage. The function is invoked when any of the plugin's operations is executed. If you need this operation to succeed return ProcessingSuccess, otherwise you should return some of the ProcessingFailure's.

Value parameters

processId

persistenceId or other id of the processing operation

processingUnit

details about current operation to be executed

Attributes

Returns

needed result of processing the operation

Source
ProcessingPolicy.scala