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<AbstractLoadedChange>	getLoadedChange(java.lang.String changeId)
java.util.Optional<java.lang.String>	getStageByChange(java.lang.String changeId)
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 change 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()

getLoadedChange

public java.util.Optional<AbstractLoadedChange> getLoadedChange(java.lang.String changeId)

Specified by:

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

getStageByChange

public java.util.Optional<java.lang.String> getStageByChange(java.lang.String changeId)

Specified by:

getStageByChange 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