countChunks count the number of chunks for specified sharded collection, support all db versions

extractOriginalSpecs extracts originalSpec from each index in a commitIndexBuild oplog. For indexes that have originalSpec, it uses the originalSpec a

* * fetch all indexes. * the cost is low so that no need to run in parallel. */

filterNsByRules checks namespace against white/black list regex rules.

return $nr oplog inside

* * return the last oplog, if the current batch is empty(first oplog in this batch is ddl), * just return the last oplog in the previous batch. * i

getShardKeyAndUuid return shard key, type(range/hashed) and uuid if exists

priority use mongo_s_url

haveMinMaxKey return true if bound have 'minKey' or 'maxKey'

isNumericBsonType returns true if the BSON type is a numeric type. MongoDB treats int32, int64, double, and decimal128 as comparable in sort order, so

************************************************************/

mock change stream event

parse the address (topic@broker1,broker2,...)

preSharingForRange does the pre-sharing work for range sharding

Because state is currently kept in memory, purge merely drops the reference so the GC will eventually clean up. Eventually, this might clean up a fil

Bind bind different worker

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

DistributeOplogByMod We need to ensure that oplog entry will be sent to the same job[$hash] if they have the same ObjectID. thus we can consume the op

EnsureNetwork establish the mongodb connection at first if current connection is not ready or disconnected

ensure network

GetAllTimestamp get all newest timestamp

input given namespace, return all keys and shard type(range or hashed)

GetDBVersion return string of db version with format like "3.0.1"

GetNewestTimestampByConn return newest oplog

GetOldestTimestampByConn return oldest oplog

GetTxnOpTimeFromOplogEntry returns an TxnOpTime struct from the relevant fields in an ParsedLog struct.

** * Handle outstanding request message. and messages * are passed one by one. Any changes of message in * Handle() will be preserved and delive

Handle is called on every oplog consumed