Package fr.gouv.vitam.common.database.server

Class OplogReader

java.lang.Object

fr.gouv.vitam.common.database.server.OplogReader

public class OplogReader
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	COLLECTION_NAME
static java.lang.String	DELETE_OPERATION
static java.lang.String	FIELD_ID
static java.lang.String	FIELD_INCREMENT
static java.lang.String	FIELD_O
static java.lang.String	FIELD_O_2
static java.lang.String	FIELD_TIME
static java.lang.String	INSERT_OPERATION
static java.lang.String	NATURAL
static java.lang.String	OPERATION_TIME
static java.lang.String	OPERATION_TYPE
static java.lang.String	PATH
static java.lang.String	UPDATE_OPERATION

Constructor Summary

Constructors

Constructor	Description
OplogReader(com.mongodb.MongoClient mongoClient, java.lang.Integer dataMaxSize)

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.String,org.bson.Document>	readDocumentsFromOplogByShardAndCollections(java.util.List<java.lang.String> collectionsToReadOplog, org.bson.BsonTimestamp maxTimeStamp)

Methods inherited from class java.lang.Object

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

Field Detail

OPERATION_TYPE

public static final java.lang.String OPERATION_TYPE

See Also:

Constant Field Values

COLLECTION_NAME

public static final java.lang.String COLLECTION_NAME

See Also:

Constant Field Values

OPERATION_TIME

public static final java.lang.String OPERATION_TIME

See Also:

Constant Field Values

FIELD_TIME

public static final java.lang.String FIELD_TIME

See Also:

Constant Field Values

FIELD_INCREMENT

public static final java.lang.String FIELD_INCREMENT

See Also:

Constant Field Values

FIELD_O_2

public static final java.lang.String FIELD_O_2

See Also:

Constant Field Values

FIELD_O

public static final java.lang.String FIELD_O

See Also:

Constant Field Values

FIELD_ID

public static final java.lang.String FIELD_ID

See Also:

Constant Field Values

INSERT_OPERATION

public static final java.lang.String INSERT_OPERATION

See Also:

Constant Field Values

UPDATE_OPERATION

public static final java.lang.String UPDATE_OPERATION

See Also:

Constant Field Values

DELETE_OPERATION

public static final java.lang.String DELETE_OPERATION

See Also:

Constant Field Values

PATH

public static final java.lang.String PATH

See Also:

Constant Field Values

NATURAL

public static final java.lang.String NATURAL

See Also:

Constant Field Values

Constructor Detail

OplogReader

public OplogReader(com.mongodb.MongoClient mongoClient,
                   java.lang.Integer dataMaxSize)

Method Detail

readDocumentsFromOplogByShardAndCollections

public java.util.Map<java.lang.String,org.bson.Document> readDocumentsFromOplogByShardAndCollections(java.util.List<java.lang.String> collectionsToReadOplog,
                                                                                                           org.bson.BsonTimestamp maxTimeStamp)