Packages

o

zio.temporal.testkit

ZWorkflowReplayer

object ZWorkflowReplayer

Replays a workflow given its history. Useful for backwards compatibility testing.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ZWorkflowReplayer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  14. def replayWorkflowExecution(history: ZWorkflowExecutionHistory, worker: ZWorker): Task[Unit]

    Replays workflow from a ZWorkflowExecutionHistory.

    Replays workflow from a ZWorkflowExecutionHistory.

    history

    object that contains the workflow ids and the events.

    worker

    existing worker with registered workflow implementations.

    Exceptions thrown

    Exception if replay failed for any reason.

  15. def replayWorkflowExecution(history: ZWorkflowExecutionHistory, workflowClass: ZWorkflowImplementationClass[_], moreClasses: ZWorkflowImplementationClass[_]*): RIO[ZTestWorkflowEnvironment[Any], Unit]

    Replays workflow from a ZWorkflowExecutionHistory.

    Replays workflow from a ZWorkflowExecutionHistory.

    history

    object that contains the workflow ids and the events.

    workflowClass

    s workflow implementation class to replay

    moreClasses

    optional additional workflow implementation classes (like child or external workflows)

    Exceptions thrown

    Exception if replay failed for any reason.

  16. def replayWorkflowExecution(jsonSerializedHistory: String, workflowClass: ZWorkflowImplementationClass[_], moreClasses: ZWorkflowImplementationClass[_]*): RIO[ZTestWorkflowEnvironment[Any], Unit]

    Replays workflow from a json serialized history.

    Replays workflow from a json serialized history. The json should be in the format:

     { "workflowId": "...", "runId": "...", "events": [ ... ] }

    RunId must match the one used to generate the serialized history.

    jsonSerializedHistory

    string that contains the json serialized history.

    workflowClass

    s workflow implementation class to replay

    moreClasses

    optional additional workflow implementation classes

    Exceptions thrown

    Exception if replay failed for any reason.

  17. def replayWorkflowExecution(historyFile: Path, workflowClass: ZWorkflowImplementationClass[_], moreClasses: ZWorkflowImplementationClass[_]*): RIO[ZTestWorkflowEnvironment[Any], Unit]

    Replays workflow from a file

    Replays workflow from a file

    historyFile

    file that contains a json serialized history.

    workflowClass

    s workflow implementation class to replay

    moreClasses

    optional additional workflow implementation classes

    Exceptions thrown

    Exception if replay failed for any reason.

  18. def replayWorkflowExecutionFromResource(resourceName: String, worker: ZWorker): RIO[ZTestWorkflowEnvironment[Any], Unit]

    Replays workflow from a resource that contains a json serialized history.

    Replays workflow from a resource that contains a json serialized history.

    resourceName

    name of the resource.

    worker

    worker existing worker with the correct task queue and registered implementations.

    Exceptions thrown

    Exception if replay failed for any reason.

  19. def replayWorkflowExecutionFromResource(resourceName: String, workflowClass: ZWorkflowImplementationClass[_], moreClasses: ZWorkflowImplementationClass[_]*): RIO[ZTestWorkflowEnvironment[Any], Unit]

    Replays workflow from a resource that contains a json serialized history.

    Replays workflow from a resource that contains a json serialized history.

    resourceName

    name of the resource.

    workflowClass

    s workflow implementation class to replay

    moreClasses

    optional additional workflow implementation classes

    Exceptions thrown

    Exception if replay failed for any reason.

  20. def replayWorkflowExecutions(histories: List[ZWorkflowExecutionHistory], failFast: Boolean, worker: ZWorker): Task[ZReplayResults]

    Replays workflows provided by an iterable using an already-initialized worker.

    Replays workflows provided by an iterable using an already-initialized worker.

    histories

    The histories to be replayed

    failFast

    If true, throws upon the first error encountered (if any) during replay. If false, all histories will be replayed and the returned object contains information about any failures.

    worker

    A worker which should have registered all the workflow implementations which were used to produce (or are expected to be compatible with) the provided histories.

    returns

    If failFast is false, contains any replay failures encountered.

    Exceptions thrown

    Exception If replay failed and failFast is true.

  21. def replayWorkflowExecutions(histories: List[ZWorkflowExecutionHistory], failFast: Boolean, workflowClass: ZWorkflowImplementationClass[_], moreClasses: ZWorkflowImplementationClass[_]*): RIO[ZTestWorkflowEnvironment[Any], ZReplayResults]

    Replays workflows provided by an iterable.

    Replays workflows provided by an iterable.

    histories

    The histories to be replayed

    failFast

    If true, throws upon the first error encountered (if any) during replay. If false, all histories will be replayed and the returned object contains information about any failures.

    returns

    If failFast is false, contains any replay failures encountered.

    Exceptions thrown

    Exception If replay failed and failFast is true.

  22. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped