final case class ZWorkflowImplementationOptions extends Product with Serializable
- Alphabetic
- By Inheritance
- ZWorkflowImplementationOptions
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val activityOptions: Option[Map[String, ZActivityOptions]]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- val defaultActivityOptions: Option[ZActivityOptions]
- val defaultLocalActivityOptions: Option[ZLocalActivityOptions]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val failWorkflowExceptionTypes: List[Class[_ <: Throwable]]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val localActivityOptions: Option[Map[String, ZLocalActivityOptions]]
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toJava: WorkflowImplementationOptions
Converts workflow implementation options to Java SDK's WorkflowImplementationOptions
- def toString(): String
- Definition Classes
- ZWorkflowImplementationOptions → AnyRef → Any
- def transformJavaOptions(f: (Builder) => Builder): ZWorkflowImplementationOptions
Allows to specify options directly on the java SDK's WorkflowImplementationOptions.
Allows to specify options directly on the java SDK's WorkflowImplementationOptions. Use it in case an appropriate
withXXXmethod is missing- Note
the options specified via this method take precedence over those specified via other methods.
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withActivityOptions(values: Map[String, ZActivityOptions]): ZWorkflowImplementationOptions
Set individual activity options per activityType (activity method name).
Set individual activity options per activityType (activity method name). Will be merged with the map from zio.temporal.workflow.ZWorkflow.newActivityStub which has the highest precedence.
- values
map from activityType to ActivityOptions
- def withActivityOptions(values: (String, ZActivityOptions)*): ZWorkflowImplementationOptions
Set individual activity options per activityType (activity method name).
Set individual activity options per activityType (activity method name). Will be merged with the map from zio.temporal.workflow.ZWorkflow.newActivityStub which has the highest precedence.
- values
map from activityType to ActivityOptions
- def withDefaultActivityOptions(value: ZActivityOptions): ZWorkflowImplementationOptions
These activity options have the lowest precedence across all activity options.
These activity options have the lowest precedence across all activity options. Will be overwritten entirely by zio.temporal.workflow.ZWorkflow.newActivityStub and then by the individual activity options if any are set through withActivityOptions
- value
ZActivityOptions for all activities in the workflow.
- def withDefaultLocalActivityOptions(value: ZLocalActivityOptions): ZWorkflowImplementationOptions
These local activity options have the lowest precedence across all local activity options.
These local activity options have the lowest precedence across all local activity options. Will be overwritten entirely by zio.temporal.workflow.ZWorkflow.newLocalActivityStub and then by the individual local activity options if any are set through withLocalActivityOptions
- value
ActivityOptions for all activities in the workflow.
- def withFailWorkflowExceptionTypes(values: List[Class[_ <: Throwable]]): ZWorkflowImplementationOptions
Optional: Sets how workflow worker deals with exceptions thrown from the workflow code which include non-deterministic history events (presumably arising from non-deterministic workflow definitions or non-backward compatible workflow definition changes).
Optional: Sets how workflow worker deals with exceptions thrown from the workflow code which include non-deterministic history events (presumably arising from non-deterministic workflow definitions or non-backward compatible workflow definition changes).
The default behavior is to fail workflow on io.temporal.failure.TemporalFailure or any of its subclasses. Any other exceptions thrown from the workflow code are treated as bugs that can be fixed by a new deployment. So workflow is not failed, but it stuck in a retry loop trying to execute the code that led to the unexpected exception.
This option allows to specify specific exception types which should lead to workflow failure instead of blockage. Any exception that extends the configured type considered matched. For example to fail workflow on any exception pass Throwable class to this method.
- def withFailWorkflowExceptionTypes(values: Class[_ <: Throwable]*): ZWorkflowImplementationOptions
Optional: Sets how workflow worker deals with exceptions thrown from the workflow code which include non-deterministic history events (presumably arising from non-deterministic workflow definitions or non-backward compatible workflow definition changes).
Optional: Sets how workflow worker deals with exceptions thrown from the workflow code which include non-deterministic history events (presumably arising from non-deterministic workflow definitions or non-backward compatible workflow definition changes).
The default behavior is to fail workflow on io.temporal.failure.TemporalFailure or any of its subclasses. Any other exceptions thrown from the workflow code are treated as bugs that can be fixed by a new deployment. So workflow is not failed, but it stuck in a retry loop trying to execute the code that led to the unexpected exception.
This option allows to specify specific exception types which should lead to workflow failure instead of blockage. Any exception that extends the configured type considered matched. For example to fail workflow on any exception pass Throwable class to this method.
- def withLocalActivityOptions(values: Map[String, ZLocalActivityOptions]): ZWorkflowImplementationOptions
Set individual local activity options per activityType (activity method name).
Set individual local activity options per activityType (activity method name). Will be merged with the map from zio.temporal.workflow.ZWorkflow.newLocalActivityStub which has the highest precedence.
- values
map from activityType to ActivityOptions
- def withLocalActivityOptions(values: (String, ZLocalActivityOptions)*): ZWorkflowImplementationOptions
Set individual local activity options per activityType (activity method name).
Set individual local activity options per activityType (activity method name). Will be merged with the map from zio.temporal.workflow.ZWorkflow.newLocalActivityStub which has the highest precedence.
- values
map from activityType to ActivityOptions
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)