io.flamingock.targetsystem.dynamodb

Class DynamoDBTargetSystem

java.lang.Object

io.flamingock.internal.core.external.targets.AbstractTargetSystem<HOLDER>

io.flamingock.internal.core.external.targets.TransactionalTargetSystem<DynamoDBTargetSystem>

io.flamingock.targetsystem.dynamodb.DynamoDBTargetSystem

All Implemented Interfaces:

io.flamingock.api.external.ExternalSystem, io.flamingock.api.external.TargetSystem, io.flamingock.externalsystem.dynamodb.api.DynamoDBExternalSystem, io.flamingock.internal.common.core.context.ContextConfigurable<DynamoDBTargetSystem>, io.flamingock.internal.common.core.context.ContextInitializable, io.flamingock.internal.common.core.context.ContextProvider

public class DynamoDBTargetSystem
extends io.flamingock.internal.core.external.targets.TransactionalTargetSystem<DynamoDBTargetSystem>
implements io.flamingock.externalsystem.dynamodb.api.DynamoDBExternalSystem

Field Summary

Fields inherited from class io.flamingock.internal.core.external.targets.TransactionalTargetSystem

autoCreate, markerRepository, onGoingTasksRepositoryName

Fields inherited from class io.flamingock.internal.core.external.targets.AbstractTargetSystem

targetSystemContext

Constructor Summary

Constructors

Constructor and Description
DynamoDBTargetSystem(java.lang.String id, software.amazon.awssdk.services.dynamodb.DynamoDbClient dynamoDBClient)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<io.flamingock.internal.common.core.audit.AuditHistoryReader>	getAuditAuditReader(io.flamingock.internal.common.core.audit.AuditReaderType type)
software.amazon.awssdk.services.dynamodb.DynamoDbClient	getClient()
protected DynamoDBTargetSystem	getSelf()
io.flamingock.internal.core.transaction.TransactionManager<software.amazon.awssdk.enhanced.dynamodb.model.TransactWriteItemsEnhancedRequest.Builder>	getTxManager()
io.flamingock.internal.core.transaction.TransactionWrapper	getTxWrapper()
void	initialize(io.flamingock.internal.common.core.context.ContextResolver baseContext)

Methods inherited from class io.flamingock.internal.core.external.targets.TransactionalTargetSystem

applyChangeTransactional, getOnGoingTaskStatusRepository, hasMarker

Methods inherited from class io.flamingock.internal.core.external.targets.AbstractTargetSystem

addDependency, addDependency, addDependency, addDependency, applyChange, enhanceExecutionRuntime, getContext, getId, rollbackChange, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.flamingock.api.external.ExternalSystem

getId

Constructor Detail

DynamoDBTargetSystem

public DynamoDBTargetSystem(java.lang.String id,
                            software.amazon.awssdk.services.dynamodb.DynamoDbClient dynamoDBClient)

Method Detail

getClient

public software.amazon.awssdk.services.dynamodb.DynamoDbClient getClient()

Specified by:

getClient in interface io.flamingock.externalsystem.dynamodb.api.DynamoDBExternalSystem

getTxManager

public io.flamingock.internal.core.transaction.TransactionManager<software.amazon.awssdk.enhanced.dynamodb.model.TransactWriteItemsEnhancedRequest.Builder> getTxManager()

initialize

public void initialize(io.flamingock.internal.common.core.context.ContextResolver baseContext)

Specified by:

initialize in interface io.flamingock.internal.common.core.context.ContextInitializable

getSelf

protected DynamoDBTargetSystem getSelf()

Specified by:

getSelf in class io.flamingock.internal.core.external.targets.AbstractTargetSystem<DynamoDBTargetSystem>

getTxWrapper

public io.flamingock.internal.core.transaction.TransactionWrapper getTxWrapper()

Specified by:

getTxWrapper in class io.flamingock.internal.core.external.targets.TransactionalTargetSystem<DynamoDBTargetSystem>

getAuditAuditReader

public java.util.Optional<io.flamingock.internal.common.core.audit.AuditHistoryReader> getAuditAuditReader(io.flamingock.internal.common.core.audit.AuditReaderType type)

Overrides:

getAuditAuditReader in class io.flamingock.internal.core.external.targets.TransactionalTargetSystem<DynamoDBTargetSystem>