io.flamingock.internal.core.pipeline.loaded

Class LoadedPipeline

java.lang.Object

io.flamingock.internal.core.pipeline.loaded.LoadedPipeline

All Implemented Interfaces:

io.flamingock.internal.common.core.context.ContextContributor, io.flamingock.internal.common.core.pipeline.PipelineDescriptor

public class LoadedPipeline
extends java.lang.Object
implements io.flamingock.internal.common.core.pipeline.PipelineDescriptor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LoadedPipeline.LoadedPipelineBuilder

Method Summary

Modifier and Type	Method and Description
static LoadedPipeline.LoadedPipelineBuilder	builder()
void	contributeToContext(io.flamingock.internal.common.core.context.ContextInjectable contextInjectable)
java.util.Optional<AbstractLoadedTask>	getLoadedTask(java.lang.String taskId)
java.util.Optional<java.lang.String>	getStageByTask(java.lang.String taskId)
java.util.List<AbstractLoadedStage>	getStages()
java.util.Optional<AbstractLoadedStage>	getSystemStage()
void	validate() Validates the entire pipeline configuration and throws an exception if validation fails.

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static LoadedPipeline.LoadedPipelineBuilder builder()

validate

public void validate()
              throws io.flamingock.internal.common.core.error.FlamingockException

Validates the entire pipeline configuration and throws an exception if validation fails. This method performs comprehensive validation including:

• Ensures the pipeline contains at least one stage
• Validates each individual stage within the pipeline
• Checks for duplicate task IDs across all stages

Throws:

io.flamingock.internal.common.core.error.FlamingockException - if any validation errors are found, containing a formatted message with all validation issues discovered

getSystemStage

public java.util.Optional<AbstractLoadedStage> getSystemStage()

getStages

public java.util.List<AbstractLoadedStage> getStages()

getLoadedTask

public java.util.Optional<AbstractLoadedTask> getLoadedTask(java.lang.String taskId)

Specified by:

getLoadedTask in interface io.flamingock.internal.common.core.pipeline.PipelineDescriptor

getStageByTask

public java.util.Optional<java.lang.String> getStageByTask(java.lang.String taskId)

Specified by:

getStageByTask in interface io.flamingock.internal.common.core.pipeline.PipelineDescriptor

contributeToContext

public void contributeToContext(io.flamingock.internal.common.core.context.ContextInjectable contextInjectable)

Specified by:

contributeToContext in interface io.flamingock.internal.common.core.context.ContextContributor