io.flamingock.internal.core.plan

Class ExecutionPlan

java.lang.Object

io.flamingock.internal.core.plan.ExecutionPlan

All Implemented Interfaces:

java.lang.AutoCloseable

public class ExecutionPlan
extends java.lang.Object
implements java.lang.AutoCloseable

Method Summary

Modifier and Type	Method and Description
void	applyOnEach(io.flamingock.internal.util.TriConsumer<java.lang.String,Lock,ExecutableStage> consumer)
void	close()
static ExecutionPlan	CONTINUE(java.util.List<ExecutableStage> stages)
ExecutablePipeline	getPipeline()
boolean	isExecutionRequired()
static ExecutionPlan	newExecution(java.lang.String executionId, Lock lock, java.util.List<ExecutableStage> stages)
void	validate() Validates the execution plan for manual intervention requirements.

Methods inherited from class java.lang.Object

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

Method Detail

newExecution

public static ExecutionPlan newExecution(java.lang.String executionId,
                                         Lock lock,
                                         java.util.List<ExecutableStage> stages)

CONTINUE

public static ExecutionPlan CONTINUE(java.util.List<ExecutableStage> stages)

isExecutionRequired

public boolean isExecutionRequired()

getPipeline

public ExecutablePipeline getPipeline()

applyOnEach

public void applyOnEach(io.flamingock.internal.util.TriConsumer<java.lang.String,Lock,ExecutableStage> consumer)

validate

public void validate()

Validates the execution plan for manual intervention requirements. This method analyzes all executable stages and their tasks to identify any that require manual intervention, throwing an exception if found.

This centralized validation follows DDD principles by keeping validation logic at the appropriate architectural layer (ExecutionPlan domain).

Throws:

io.flamingock.internal.common.core.recovery.ManualInterventionRequiredException - if any tasks require manual intervention

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable