INNER CODE UNIT · Go
validOps
rwynn/gtm · gtm.go:954
func validOps() bson.M {
return bson.M{"op": bson.M{"$in": opCodes}}
}
func LastOpTimestamp(client *mongo.Client, o *Options) (primitive.Timestamp, error) {
opLog := OpLog{}
filter := validOps()
opts := &options.FindOneOptions{}
opts.SetSort(bson.M{"$natural": -1})
c := OpLogCollection(client, o)
err := c.FindOne(context.Background(), filter, opts).Decode(&opLog)
return opLog.Timestamp, err
}
func FirstOpTimestamp(client *mongo.Client, o *Options) (primitive.Timestamp, error) {
opLog := OpLog{}
filter := validOps()
opts := &options.FindOneOptions{}