Insert save checkpoint

** * Module install and initialize. return false on failed * and only invocation on WriteController is preparing */

IsCommitOp is commitTransaction oplog

** * Bridge of tunnel reader and aggregater(replayer) * */

NewOplogReader creates reader with mongodb url

NewOplogSyncer return a new OplogSyncer. OplogSyncer is used to fetch oplog from source MongoDB and then send to different workers which can be seen a

Next returns an oplog by raw bytes which is []byte

Next returns an oplog by raw bytes which is []byte

NextDoc returns a document by raw bytes which is []byte reader.docCursor.Current is valid only before next docCursor.Next(), So must be copy

** * prepare stage of the tunnel such as create the network connection or initialize * something etc before the Send() invocation. * return true

RestAPI restful api

RunCommand is synced from executor.RunCommand

Start to polling oplog

reader name

StartFetcher start fetcher if not exist

Stop shuts down processing and cleans up. Subsequent calls to Stop() will return nil. All other methods error after this is called.

TxnOpTimeIsEmpty returns true if opTime is uninitialized, false otherwise.

TxnOpTimeLessThan returns true if lhs comes before rhs, false otherwise. We first check if both the terms exist. If they don't or they're equal, we co

start sync single collection