io.flamingock.internal.core.pipeline.execution

Class StageExecutor

java.lang.Object

io.flamingock.internal.core.pipeline.execution.StageExecutor

public class StageExecutor
extends java.lang.Object

Executes stages and returns structured result data.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StageExecutor.Output

Field Summary

Fields

Modifier and Type	Field and Description
protected TransactionWrapper	auditStoreTxWrapper
protected LifecycleAuditWriter	auditWriter

Constructor Summary

Constructors

Constructor and Description
StageExecutor(io.flamingock.internal.common.core.context.ContextResolver dependencyContext, java.util.Set<java.lang.Class<?>> nonGuardedTypes, LifecycleAuditWriter auditWriter, TargetSystemManager targetSystemManager, TransactionWrapper auditStoreTxWrapper)

Method Summary

Modifier and Type	Method and Description
StageExecutor.Output	executeStage(ExecutableStage executableStage, ExecutionContext executionContext, Lock lock)
protected java.util.stream.Stream<? extends ExecutableTask>	getTasksStream(ExecutableStage executableStage)

Methods inherited from class java.lang.Object

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

Field Detail

auditWriter

protected final LifecycleAuditWriter auditWriter

auditStoreTxWrapper

protected final TransactionWrapper auditStoreTxWrapper

Constructor Detail

StageExecutor

public StageExecutor(io.flamingock.internal.common.core.context.ContextResolver dependencyContext,
                     java.util.Set<java.lang.Class<?>> nonGuardedTypes,
                     LifecycleAuditWriter auditWriter,
                     TargetSystemManager targetSystemManager,
                     TransactionWrapper auditStoreTxWrapper)

Method Detail

executeStage

public StageExecutor.Output executeStage(ExecutableStage executableStage,
                                         ExecutionContext executionContext,
                                         Lock lock)
                                  throws StageExecutionException

Throws:

StageExecutionException

getTasksStream

protected java.util.stream.Stream<? extends ExecutableTask> getTasksStream(ExecutableStage executableStage)