Package kalix.javasdk.workflow

Class AbstractWorkflow.WorkflowDef<S>

Object

kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef<S>

Enclosing class:

AbstractWorkflow<S>

public static class AbstractWorkflow.WorkflowDef<S>
extends Object

Method Summary

Modifier and Type	Method	Description
AbstractWorkflow.WorkflowDef<S>	addStep(AbstractWorkflow.Step step)	Add step to workflow definition.
AbstractWorkflow.WorkflowDef<S>	addStep(AbstractWorkflow.Step step, AbstractWorkflow.RecoverStrategy<?> recoverStrategy)	Add step to workflow definition with a dedicated AbstractWorkflow.RecoverStrategy.
AbstractWorkflow.WorkflowDef<S>	defaultStepRecoverStrategy(AbstractWorkflow.RecoverStrategy recoverStrategy)	Define a default step recovery strategy.
AbstractWorkflow.WorkflowDef<S>	defaultStepTimeout(Duration timeout)	Define a default step timeout.
<I> AbstractWorkflow.WorkflowDef<S>	failoverTo(String stepName, I stepInput, AbstractWorkflow.RecoverStrategy.MaxRetries maxRetries)	Define a failover step name after workflow timeout.
AbstractWorkflow.WorkflowDef<S>	failoverTo(String stepName, AbstractWorkflow.RecoverStrategy.MaxRetries maxRetries)	Define a failover step name after workflow timeout.
Optional<AbstractWorkflow.Step>	findByName(String name)
Optional<AbstractWorkflow.RecoverStrategy.MaxRetries>	getFailoverMaxRetries()
Optional<?>	getFailoverStepInput()
Optional<String>	getFailoverStepName()
List<AbstractWorkflow.StepConfig>	getStepConfigs()
Optional<AbstractWorkflow.RecoverStrategy<?>>	getStepRecoverStrategy()
List<AbstractWorkflow.Step>	getSteps()
Optional<Duration>	getStepTimeout()
Optional<Duration>	getWorkflowTimeout()
AbstractWorkflow.WorkflowDef<S>	timeout(Duration timeout)	Define a timeout for the duration of the entire workflow.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

findByName

public Optional<AbstractWorkflow.Step> findByName(String name)

addStep

public AbstractWorkflow.WorkflowDef<S> addStep(AbstractWorkflow.Step step)

Add step to workflow definition. Step name must be unique.

Parameters:

step - A workflow step

addStep

public AbstractWorkflow.WorkflowDef<S> addStep(AbstractWorkflow.Step step,
 AbstractWorkflow.RecoverStrategy<?> recoverStrategy)

Add step to workflow definition with a dedicated AbstractWorkflow.RecoverStrategy. Step name must be unique.

Parameters:

step - A workflow step

recoverStrategy - A Step recovery strategy

timeout

public AbstractWorkflow.WorkflowDef<S> timeout(Duration timeout)

Define a timeout for the duration of the entire workflow. When the timeout expires, the workflow is finished and no transitions are allowed.

Parameters:

timeout - Timeout duration

failoverTo

public AbstractWorkflow.WorkflowDef<S> failoverTo(String stepName,
 AbstractWorkflow.RecoverStrategy.MaxRetries maxRetries)

Define a failover step name after workflow timeout. Note that recover strategy for this step can set only the number of max retries.

Parameters:

stepName - A failover step name

maxRetries - A recovery strategy for failover step.

failoverTo

public <I> AbstractWorkflow.WorkflowDef<S> failoverTo(String stepName,
 I stepInput,
 AbstractWorkflow.RecoverStrategy.MaxRetries maxRetries)

Define a failover step name after workflow timeout. Note that recover strategy for this step can set only the number of max retries.

Parameters:

stepName - A failover step name

stepInput - A failover step input

maxRetries - A recovery strategy for failover step.

defaultStepTimeout

public AbstractWorkflow.WorkflowDef<S> defaultStepTimeout(Duration timeout)

Define a default step timeout. If not set, a default value of 5 seconds is used. Can be overridden with step configuration.

defaultStepRecoverStrategy

public AbstractWorkflow.WorkflowDef<S> defaultStepRecoverStrategy(AbstractWorkflow.RecoverStrategy recoverStrategy)

Define a default step recovery strategy. Can be overridden with step configuration.

getWorkflowTimeout

public Optional<Duration> getWorkflowTimeout()

getStepTimeout

public Optional<Duration> getStepTimeout()

getStepRecoverStrategy

public Optional<AbstractWorkflow.RecoverStrategy<?>> getStepRecoverStrategy()

getSteps

public List<AbstractWorkflow.Step> getSteps()

getStepConfigs

public List<AbstractWorkflow.StepConfig> getStepConfigs()

getFailoverStepName

public Optional<String> getFailoverStepName()

getFailoverStepInput

public Optional<?> getFailoverStepInput()

getFailoverMaxRetries

public Optional<AbstractWorkflow.RecoverStrategy.MaxRetries> getFailoverMaxRetries()