ZIO Temporal
v1.0.0-RC3
API
Generated with
ZIO Temporal/zio.temporal/zio.temporal.internal/TemporalWorkflowFacade

TemporalWorkflowFacade

zio.temporal.internal.TemporalWorkflowFacade
object TemporalWorkflowFacade

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Type members

Classlikes

object FunctionConverters

Attributes

Supertypes
class Object
trait Matchable
class Any
Self type

Value members

Concrete methods

def buildActivityStubTyped[A : ClassTag]: ActivityOptions => Of[A]
def buildActivityStubUntyped: ActivityOptions => Untyped
def buildChildWorkflowStubTyped[A : ClassTag]: ChildWorkflowOptions => Of[A]
def buildChildWorkflowStubUntyped(workflowType: String): ChildWorkflowOptions => Untyped
def buildLocalActivityStubTyped[A : ClassTag]: LocalActivityOptions => Of[A]
def buildLocalActivityStubUntyped: LocalActivityOptions => Untyped
def continueAsNew[R](workflowType: String, options: ContinueAsNewOptions, args: List[Any]): R
def createWorkflowStubTyped[A : ClassTag](client: WorkflowClient): WorkflowOptions => UIO[Of[A]]
def createWorkflowStubUntyped(workflowType: String, client: WorkflowClient): WorkflowOptions => UIO[Untyped]
def execute[R](stub: WorkflowStub, args: List[Any])(implicit codec: ZTemporalCodec[R]): CompletableFuture[R]
def executeActivity[R](stub: ActivityStub, stubbedClass: Class[_], methodName: String, args: List[Any])(implicit codec: ZTemporalCodec[R]): R
def executeActivityAsync[R](stub: ActivityStub, stubbedClass: Class[_], methodName: String, args: List[Any])(implicit codec: ZTemporalCodec[R]): Promise[R]
def executeChild[R](stub: ChildWorkflowStub, args: List[Any])(implicit codec: ZTemporalCodec[R]): R
def executeChildAsync[R](stub: ChildWorkflowStub, args: List[Any])(implicit codec: ZTemporalCodec[R]): Promise[R]
def executeWithTimeout[R](stub: WorkflowStub, timeout: Duration, args: List[Any])(implicit codec: ZTemporalCodec[R]): CompletableFuture[R]
def query[R](stub: WorkflowStub, name: String, args: List[Any])(implicit codec: ZTemporalCodec[R]): R
def signal(stub: WorkflowStub, signalName: String, args: List[Any]): Unit
def signal(stub: ChildWorkflowStub, signalName: String, args: List[Any]): Unit
def signal(stub: ExternalWorkflowStub, signalName: String, args: List[Any]): Unit
def signalWithStart(stub: WorkflowStub, signalName: String, signalArgs: Array[Any], startArgs: Array[Any]): WorkflowExecution
def start(stub: WorkflowStub, args: List[Any]): WorkflowExecution
def startScheduleAction(stubbedClass: Class[_], header: Header, workflowOptions: WorkflowOptions, args: List[Any]): StartWorkflow
Generated with