io.flamingock.internal.common.core.pipeline

Class PipelineHelper

java.lang.Object

io.flamingock.internal.common.core.pipeline.PipelineHelper

public class PipelineHelper
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	LEGACY_STAGE_ID
static java.lang.String	SYSTEM_STAGE_ID

Constructor Summary

Constructors

Constructor and Description
PipelineHelper(PipelineDescriptor pipelineDescriptor)

Method Summary

Modifier and Type	Method and Description
java.lang.IllegalArgumentException	generateTaskIdException(java.lang.String taskIdInPipeline)
java.lang.String	getBaseTaskId(AuditEntry auditEntry)
java.lang.String	getStageId(AuditEntry auditEntryFromOrigin)
java.lang.String	getStorableTaskId(AuditEntry auditEntry)

Methods inherited from class java.lang.Object

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

Field Detail

SYSTEM_STAGE_ID

public static final java.lang.String SYSTEM_STAGE_ID

See Also:

Constant Field Values

LEGACY_STAGE_ID

public static final java.lang.String LEGACY_STAGE_ID

See Also:

Constant Field Values

Constructor Detail

PipelineHelper

public PipelineHelper(PipelineDescriptor pipelineDescriptor)

Method Detail

getStageId

public java.lang.String getStageId(AuditEntry auditEntryFromOrigin)

getBaseTaskId

public java.lang.String getBaseTaskId(AuditEntry auditEntry)

getStorableTaskId

public java.lang.String getStorableTaskId(AuditEntry auditEntry)

generateTaskIdException

@NotNull
public java.lang.IllegalArgumentException generateTaskIdException(java.lang.String taskIdInPipeline)