BatchMore ** * This function is used to gather oplogs together. * Honestly speaking, it's complicate so that reading unit tests may help you to make

* * return oplogs array with length=input length. * ddlGiven array marks the ddl. * noopGiven array marks the noop. * sameTsGiven array marks the

if the oplog of checkpoint timestamp exist in all source db, then only do oplog replication instead of document replication

NewDbWriter return a new writer, could be: 1) SingleWriter; 2) BulkWriter; (by default for MongoDB3.2+) 3) CommandWriter; (for gid enabled)

update operation

insert operation

Get return persistent checkpoint

String return log info

Update checkpoint update memory & persistence(db or file)

update query timestamp

Inject inject data

** * Replay oplog entry with batched Oplog * */

update when insert duplicated

IgnoreError return true if error can be ignored https://github.com/mongodb/mongo/blob/master/src/mongo/base/error_codes.yml

RemoveFiled remove specified field in bson.D and return the one after modify

if no need to transform namespace, return original logs for no command log, transform namespace in DBRef by conf.Options.TransformDBRef for command lo

BlockMongoUrlPassword block password in two kinds of mongo_urls: 1) "mongodb://username:password@address" 2) "username:password@address"

GetAndCompareVersion get current db version and compare to threshold. Return whether the result is bigger or equal to the input threshold.

NewOpTypeFilter trusts sanitize to provide normalized op type values.

split oplogs into safety segments

NormalizeApplyOps extracts and normalizes applyOps into []bson.D so callers can share one BSON-container compatibility path while keeping their own ap

* * if delay > 0, this function wait till delay timeout. * However, if the mergeBatch contain may oplogs, the delay time will depend on the first *

mock oplog with different namespace

newMongoClient only used in unit test

ConvertBsonD2M convert bson.D to bson.M

GetInMemory return in-memory checkpoint

IsTxn is true if the oplog entry is part of any transaction, i.e. the lsid field exists.

DiffUpdateOplogToNormal convert diff update oplog(v2) to normal one(v1) * Oplog from mongod(5.0) in sharding&replica》 Example 1: { "ts": {"T": 165

Get read checkpoint from remote storage. and encapsulation with CheckpointContext struct bool means whether exists on remote

NewTxnMeta extracts transaction metadata from an oplog entry. A non-transaction will return a zero-value TxnMeta struct, not an error. Currently the

delete operation

internal get next oplog. Used in Next() and NextOplog(). The channel and current function may both return timeout which is acceptable.

hasOriginalSpec checks if a commitIndexBuild/createIndexes oplog contains originalSpec in any of its indexes. Time-series collection indexes have orig

create specific Tunnel with tunnel name and pass connection or usefully meta

Dump will dump oplog according to the given keys, "all" == true means ignore keys