shouldFilterApplyOpsInnerOp reports whether the given inner applyOps op should be filtered by the current DML filter configuration.

fetch all oplog from logs queue, batched together and then send to different workers.

this is the main connector function

* * * [ Before transfer ] * * batch |9,10,11| * listSent |1,2,3,4,5,6,7,8| * * [ After transfer ] * * batch | (empty) | * listSent

KafkaWriter.AckRequired() is always false, return 0 directly

ConvertBsonM2E convert a bson.M with only 1 elem to bson.E, which can be added to other bson.D

fetch next oplog/event

** * Ack offset value * */

GetAllNamespace return all namespace. return: @map[NS]struct{}: namespace set where key is the namespace while value is useless, e.g., "a.b"->nil, "a.

GetAllTimestampInUT is only used in unit test

func ParseIntFromInterface(input interface{}) (int64, error) { switch src := input.(type) { case int: return int64(src), nil case int8: return

HaveIdIndexKey return true if index key is just '_id'