io.flamingock.targetsystem.dynamodb

Class DynamoDBTargetSystemAuditMarker

java.lang.Object

io.flamingock.targetsystem.dynamodb.DynamoDBTargetSystemAuditMarker

All Implemented Interfaces:

io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMarker

public class DynamoDBTargetSystemAuditMarker
extends java.lang.Object
implements io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMarker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DynamoDBTargetSystemAuditMarker.Builder

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	logger
protected software.amazon.awssdk.enhanced.dynamodb.DynamoDbTable<OngoingTaskEntity>	onGoingTaskStatusTable
static java.lang.String	OPERATION

Constructor Summary

Constructors

Constructor and Description
DynamoDBTargetSystemAuditMarker(software.amazon.awssdk.enhanced.dynamodb.DynamoDbTable<OngoingTaskEntity> onGoingTaskStatusTable, io.flamingock.internal.core.transaction.TransactionManager<software.amazon.awssdk.enhanced.dynamodb.model.TransactWriteItemsEnhancedRequest.Builder> txManager)

Method Summary

Modifier and Type	Method and Description
static DynamoDBTargetSystemAuditMarker.Builder	builder(software.amazon.awssdk.services.dynamodb.DynamoDbClient dynamoDBClient, io.flamingock.internal.core.transaction.TransactionManager<software.amazon.awssdk.enhanced.dynamodb.model.TransactWriteItemsEnhancedRequest.Builder> txManager)
void	clearMark(java.lang.String changeId)
java.util.Set<io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMark>	listAll()
void	mark(io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMark auditMark)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMarker

markApplied

Field Detail

logger

protected static final org.slf4j.Logger logger

OPERATION

public static final java.lang.String OPERATION

See Also:

Constant Field Values

onGoingTaskStatusTable

protected software.amazon.awssdk.enhanced.dynamodb.DynamoDbTable<OngoingTaskEntity> onGoingTaskStatusTable

Constructor Detail

DynamoDBTargetSystemAuditMarker

public DynamoDBTargetSystemAuditMarker(software.amazon.awssdk.enhanced.dynamodb.DynamoDbTable<OngoingTaskEntity> onGoingTaskStatusTable,
                                       io.flamingock.internal.core.transaction.TransactionManager<software.amazon.awssdk.enhanced.dynamodb.model.TransactWriteItemsEnhancedRequest.Builder> txManager)

Method Detail

builder

public static DynamoDBTargetSystemAuditMarker.Builder builder(software.amazon.awssdk.services.dynamodb.DynamoDbClient dynamoDBClient,
                                                              io.flamingock.internal.core.transaction.TransactionManager<software.amazon.awssdk.enhanced.dynamodb.model.TransactWriteItemsEnhancedRequest.Builder> txManager)

listAll

public java.util.Set<io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMark> listAll()

Specified by:

listAll in interface io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMarker

clearMark

public void clearMark(java.lang.String changeId)

Specified by:

clearMark in interface io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMarker

mark

public void mark(io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMark auditMark)

Specified by:

mark in interface io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMarker