io.flamingock.targetsystem.mongodb.sync

Class MongoDBSyncAuditMarker

java.lang.Object

io.flamingock.targetsystem.mongodb.sync.MongoDBSyncAuditMarker

All Implemented Interfaces:

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

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

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static MongoDBSyncAuditMarker.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

MongoDBSyncAuditMarker

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

Method Detail

builder

public static MongoDBSyncAuditMarker.Builder builder(com.mongodb.client.MongoDatabase mongoDatabase,
                                                     io.flamingock.internal.core.transaction.TransactionManager<com.mongodb.client.ClientSession> txManager)

mapToOnGoingStatus

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

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