io.flamingock.targetsystem.mongodb.sync

Class MongoDBSyncTargetSystemAuditMarker

java.lang.Object

io.flamingock.targetsystem.mongodb.sync.MongoDBSyncTargetSystemAuditMarker

All Implemented Interfaces:

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

public class MongoDBSyncTargetSystemAuditMarker
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	MongoDBSyncTargetSystemAuditMarker.Builder

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	OPERATION

Constructor Summary

Constructors

Constructor and Description
MongoDBSyncTargetSystemAuditMarker(com.mongodb.client.MongoCollection<org.bson.Document> onGoingTaskStatusCollection, io.flamingock.internal.core.transaction.TransactionManager<com.mongodb.client.ClientSession> txManager)

Method Summary

Modifier and Type	Method and Description
static MongoDBSyncTargetSystemAuditMarker.Builder	builder(com.mongodb.client.MongoDatabase mongoDatabase, io.flamingock.internal.core.transaction.TransactionManager<com.mongodb.client.ClientSession> txManager)
void	clearMark(java.lang.String changeId)
java.util.Set<io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMark>	listAll()
static io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMark	mapToOnGoingStatus(org.bson.Document document)
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

OPERATION

public static final java.lang.String OPERATION

See Also:

Constant Field Values

Constructor Detail

MongoDBSyncTargetSystemAuditMarker

public MongoDBSyncTargetSystemAuditMarker(com.mongodb.client.MongoCollection<org.bson.Document> onGoingTaskStatusCollection,
                                          io.flamingock.internal.core.transaction.TransactionManager<com.mongodb.client.ClientSession> txManager)

Method Detail

builder

public static MongoDBSyncTargetSystemAuditMarker.Builder builder(com.mongodb.client.MongoDatabase mongoDatabase,
                                                                 io.flamingock.internal.core.transaction.TransactionManager<com.mongodb.client.ClientSession> 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

mapToOnGoingStatus

public static io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMark mapToOnGoingStatus(org.bson.Document document)