io.flamingock.internal.core.pipeline.loaded.stage

Class AbstractLoadedStage

java.lang.Object

io.flamingock.internal.core.pipeline.loaded.stage.AbstractLoadedStage

All Implemented Interfaces:

io.flamingock.internal.common.core.error.validation.Validatable<PipelineValidationContext>

Direct Known Subclasses:

DefaultLoadedStage, LegacyLoadedStage, SystemLoadedStage

public abstract class AbstractLoadedStage
extends java.lang.Object
implements io.flamingock.internal.common.core.error.validation.Validatable<PipelineValidationContext>

It's the result of adding the loaded task to the ProcessDefinition

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractLoadedStage.Builder

Constructor Summary

Constructors

Constructor and Description
AbstractLoadedStage(java.lang.String name, io.flamingock.api.StageType type, java.util.Collection<AbstractLoadedTask> tasks, StageValidationContext validationContext)

Method Summary

Modifier and Type	Method and Description
ExecutableStage	applyActions(io.flamingock.internal.common.core.recovery.action.ChangeActionMap actionPlan) Applies the specified action plan to this stage, creating an ExecutableStage with tasks configured according to their assigned actions.
static AbstractLoadedStage.Builder	builder()
java.lang.String	getName()
protected java.util.Optional<io.flamingock.internal.common.core.error.validation.ValidationError>	getTaskIdDuplicationError()
java.util.Set<java.lang.String>	getTaskIds() Returns a set of all task IDs defined within this stage.
java.util.Collection<AbstractLoadedTask>	getTasks()
io.flamingock.api.StageType	getType()
java.util.List<io.flamingock.internal.common.core.error.validation.ValidationError>	getValidationErrors(PipelineValidationContext context) Validates the stage and returns a list of validation errors Validations: 1.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.flamingock.internal.common.core.error.validation.Validatable

isValid

Constructor Detail

AbstractLoadedStage

public AbstractLoadedStage(java.lang.String name,
                           io.flamingock.api.StageType type,
                           java.util.Collection<AbstractLoadedTask> tasks,
                           StageValidationContext validationContext)

Method Detail

builder

public static AbstractLoadedStage.Builder builder()

applyActions

public ExecutableStage applyActions(io.flamingock.internal.common.core.recovery.action.ChangeActionMap actionPlan)

Applies the specified action plan to this stage, creating an ExecutableStage with tasks configured according to their assigned actions. This method provides a unified interface for both community (audit-based) and cloud (orchestrator-based) execution planning.

Parameters:

actionPlan - the action plan specifying what action to take for each change

Returns:

an ExecutableStage ready for execution

getName

public java.lang.String getName()

getType

public io.flamingock.api.StageType getType()

getTasks

public java.util.Collection<AbstractLoadedTask> getTasks()

getTaskIds

public java.util.Set<java.lang.String> getTaskIds()

Returns a set of all task IDs defined within this stage.

It is assumed that task IDs within a stage are unique, so the returned Set will not contain duplicates.

Returns:

a set of task IDs in this stage

getValidationErrors

public java.util.List<io.flamingock.internal.common.core.error.validation.ValidationError> getValidationErrors(PipelineValidationContext context)

Validates the stage and returns a list of validation errors Validations: 1. has name 2. no duplicate task IDs within stage 3. all tasks in the stage are valid

Specified by:

getValidationErrors in interface io.flamingock.internal.common.core.error.validation.Validatable<PipelineValidationContext>

Returns:

list of validation errors, or empty list if the stage is valid

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getTaskIdDuplicationError

protected java.util.Optional<io.flamingock.internal.common.core.error.validation.ValidationError> getTaskIdDuplicationError()