Searched refs:ApplyOps (Results 1 – 7 of 7) sorted by relevance
98 err = restore.ApplyOps(session, []interface{}{entryAsOplog})117 func (restore *MongoRestore) ApplyOps(session *mgo.Session, entries []interface{}) error { func228 ApplyOps []db.Oplog `bson:"applyOps"` member248 return cmd.ApplyOps, nil255 cmd := &nestedApplyOps{ApplyOps: ops}
146 return restore.ApplyOps(oplogCtx.session, []interface{}{op})200 func (restore *MongoRestore) ApplyOps(session *mongo.Client, entries []interface{}) error { func357 ApplyOps []db.Oplog `bson:"applyOps"` member377 return cmd.ApplyOps, nil384 cmd := &nestedApplyOps{ApplyOps: ops}
289 return restore.ApplyOps(session, []interface{}{createOp})
61 constexpr StringData ApplyOps::kPreconditionFieldName;62 constexpr StringData ApplyOps::kOplogApplicationModeFieldName;306 return applyOpCmd[ApplyOps::kPreconditionFieldName].type() == Array; in _hasPrecondition()315 for (auto elem : applyOpCmd[ApplyOps::kPreconditionFieldName].Obj()) { in _checkPrecondition()448 if (name == ApplyOps::kPreconditionFieldName) in applyOps()
39 class ApplyOps {
418 cmdObj, ApplyOps::kOplogApplicationModeFieldName, &oplogApplicationModeString); in errmsgRun()427 ApplyOps::kOplogApplicationModeFieldName)); in errmsgRun()436 << ApplyOps::kOplogApplicationModeFieldName in errmsgRun()
1218 #region ApplyOps