Package org.nuxeo.drive.mongodb

Class MongoDBAuditChangeFinder

java.lang.Object

org.nuxeo.drive.service.impl.AuditChangeFinder

org.nuxeo.drive.mongodb.MongoDBAuditChangeFinder

All Implemented Interfaces:

FileSystemChangeFinder

public class MongoDBAuditChangeFinder
extends AuditChangeFinder

Since:

11.3

Field Summary

Fields inherited from class org.nuxeo.drive.service.impl.AuditChangeFinder

parameters

Constructor Summary

Constructors

Constructor	Description
MongoDBAuditChangeFinder()

Method Summary

Modifier and Type	Method	Description
protected org.bson.conversions.Bson	addRoots(org.bson.conversions.Bson baseFilter, Set<String> rootPaths, Set<String> collectionSyncRootMemberIds)
long	getUpperBound()	Returns the last available log id in the audit log table (primary key) to be used as the upper bound of the event log id range clause in the change query.
protected List<LogEntry>	queryAuditEntries(CoreSession session, SynchronizationRoots activeRoots, Set<String> collectionSyncRootMemberIds, long lowerBound, long upperBound, int limit)

Methods inherited from class org.nuxeo.drive.service.impl.AuditChangeFinder

getCollectionSyncRootFilteringClause, getCurrentRootFilteringClause, getFileSystemChanges, getFileSystemItemChange, getJPARangeClause, handleParameters

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.drive.service.FileSystemChangeFinder

getUpperBound

Constructor Details

MongoDBAuditChangeFinder

public MongoDBAuditChangeFinder()

Method Details

getUpperBound

public long getUpperBound()

Description copied from class: AuditChangeFinder

Returns the last available log id in the audit log table (primary key) to be used as the upper bound of the event log id range clause in the change query.

Specified by:

getUpperBound in interface FileSystemChangeFinder

Overrides:

getUpperBound in class AuditChangeFinder

queryAuditEntries

protected List<LogEntry> queryAuditEntries(CoreSession session,
 SynchronizationRoots activeRoots,
 Set<String> collectionSyncRootMemberIds,
 long lowerBound,
 long upperBound,
 int limit)

Overrides:

queryAuditEntries in class AuditChangeFinder

addRoots

protected org.bson.conversions.Bson addRoots(org.bson.conversions.Bson baseFilter,
 Set<String> rootPaths,
 Set<String> collectionSyncRootMemberIds)