io.flamingock.internal.core.external.targets.operations

Class TargetSystemOpsImpl

java.lang.Object

io.flamingock.internal.core.external.targets.operations.TargetSystemOpsImpl

All Implemented Interfaces:

io.flamingock.api.external.ExternalSystem, io.flamingock.api.external.TargetSystem, TargetSystemOps

Direct Known Subclasses:

TransactionalTargetSystemOpsImpl

public class TargetSystemOpsImpl
extends java.lang.Object
implements TargetSystemOps

Constructor Summary

Constructors

Constructor and Description
TargetSystemOpsImpl(AbstractTargetSystem<?> targetSystem)

Method Summary

Modifier and Type	Method and Description
<T> T	applyChange(java.util.function.Function<ExecutionRuntime,T> changeApplier, ExecutionRuntime executionRuntime) Applies a change operation to this target system.
java.lang.String	getId()
io.flamingock.internal.common.core.targets.OperationType	getOperationType() Returns the type of operations supported by this target system.
<T> T	rollbackChange(java.util.function.Function<ExecutionRuntime,T> changeRollbacker, ExecutionRuntime executionRuntime) Rolls back (reverts) a previously applied change in this target system.

Methods inherited from class java.lang.Object

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

Constructor Detail

TargetSystemOpsImpl

public TargetSystemOpsImpl(AbstractTargetSystem<?> targetSystem)

Method Detail

getOperationType

public io.flamingock.internal.common.core.targets.OperationType getOperationType()

Description copied from interface: TargetSystemOps

Returns the type of operations supported by this target system.

Specified by:

getOperationType in interface TargetSystemOps

Returns:

the operation type (e.g., NON_TX, TX_AUDIT_STORE_SYNC, TX_NON_SYNC)

applyChange

public final <T> T applyChange(java.util.function.Function<ExecutionRuntime,T> changeApplier,
                               ExecutionRuntime executionRuntime)

Description copied from interface: TargetSystemOps

Applies a change operation to this target system.

This method coordinates the execution of a change by:

• Injecting session-scoped dependencies via the target system
• Executing the change function with the enhanced runtime

Specified by:

applyChange in interface TargetSystemOps

Type Parameters:

T - the return type of the change operation

Parameters:

changeApplier - the function that executes the actual change

executionRuntime - the runtime context for dependency resolution

Returns:

the result of the change operation

rollbackChange

public final <T> T rollbackChange(java.util.function.Function<ExecutionRuntime,T> changeRollbacker,
                                  ExecutionRuntime executionRuntime)

Description copied from interface: TargetSystemOps

Rolls back (reverts) a previously applied change in this target system.

This method coordinates the execution of a rollback by:

• Injecting session-scoped dependencies via the target system
• Executing the rollback function with the enhanced runtime

Implementations should strive for idempotency: invoking the rollback more than once should not produce side effects beyond the first successful revert.

Specified by:

rollbackChange in interface TargetSystemOps

Type Parameters:

T - the return type of the rollback operation

Parameters:

changeRollbacker - the function that executes the actual rollback

executionRuntime - the runtime context for dependency resolution

Returns:

the result of the rollback operation

getId

public java.lang.String getId()

Specified by:

getId in interface io.flamingock.api.external.ExternalSystem