Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 bson.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "errors" "io/ioutil" "path/filepath" "go.mongodb.org/mongo-driver/bson" ) const ( perfDataDir = "perf" bsonDataDir = "extended_bson" flatBSONData = "flat_bson.json" deepBSONData = "deep_bson.json" fullBSONData = "full_bson.json" ) // utility functions for the bson benchmarks func loadSourceDocument(pathParts ...string) (bson.D, error) { data, err := ioutil.ReadFile(filepath.Join(pathParts...)) if err != nil { return nil, err } var doc bson.D err = bson.UnmarshalExtJSON(data, true, &doc) if err != nil { return nil, err } if len(doc) == 0 { return nil, errors.New("empty bson document") } return doc, nil } func loadSourceRaw(pathParts ...string) (bson.Raw, error) { doc, err := loadSourceDocument(pathParts...) if err != nil { return nil, err } raw, err := bson.Marshal(doc) if err != nil { return nil, err } return bson.Raw(raw), nil }	1.16 KB	2025-05-25 12:27
📄 bson_document.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" "errors" "go.mongodb.org/mongo-driver/bson" ) func bsonDocumentEncoding(tm TimerManager, iters int, source string) error { doc, err := loadSourceDocument(getProjectRoot(), perfDataDir, bsonDataDir, source) if err != nil { return err } tm.ResetTimer() for i := 0; i < iters; i++ { out, err := bson.Marshal(doc) if err != nil { return err } if len(out) == 0 { return errors.New("marshaling error") } } return nil } func bsonDocumentDecodingLazy(tm TimerManager, iters int, source string) error { doc, err := loadSourceDocument(getProjectRoot(), perfDataDir, bsonDataDir, source) if err != nil { return err } raw, err := bson.Marshal(doc) if err != nil { return err } tm.ResetTimer() for i := 0; i < iters; i++ { var out bson.D err := bson.Unmarshal(raw, &out) if err != nil { return err } if len(out) == 0 { return errors.New("marshaling error") } } return nil } func bsonDocumentDecoding(tm TimerManager, iters, numKeys int, source string) error { doc, err := loadSourceDocument(getProjectRoot(), perfDataDir, bsonDataDir, source) if err != nil { return err } raw, err := bson.Marshal(doc) if err != nil { return err } tm.ResetTimer() for i := 0; i < iters; i++ { var out bson.D err := bson.Unmarshal(raw, &out) if err != nil { return err } if len(out) != numKeys { return errors.New("document parsing error") } } return nil } func BSONFlatDocumentEncoding(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentEncoding(tm, iters, flatBSONData) } func BSONFlatDocumentDecodingLazy(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentDecodingLazy(tm, iters, flatBSONData) } func BSONFlatDocumentDecoding(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentDecoding(tm, iters, 145, flatBSONData) } func BSONDeepDocumentEncoding(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentEncoding(tm, iters, deepBSONData) } func BSONDeepDocumentDecodingLazy(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentDecodingLazy(tm, iters, deepBSONData) } func BSONDeepDocumentDecoding(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentDecoding(tm, iters, 126, deepBSONData) } func BSONFullDocumentEncoding(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentEncoding(tm, iters, fullBSONData) } func BSONFullDocumentDecodingLazy(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentDecodingLazy(tm, iters, fullBSONData) } func BSONFullDocumentDecoding(_ context.Context, tm TimerManager, iters int) error { return bsonDocumentDecoding(tm, iters, 145, fullBSONData) }	2.99 KB	2025-05-25 12:27
📄 bson_map.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" "errors" "fmt" "go.mongodb.org/mongo-driver/bson" ) func bsonMapDecoding(tm TimerManager, iters int, dataSet string) error { r, err := loadSourceRaw(getProjectRoot(), perfDataDir, bsonDataDir, dataSet) if err != nil { return err } tm.ResetTimer() for i := 0; i < iters; i++ { out := make(map[string]interface{}) err := bson.Unmarshal(r, &out) if err != nil { return nil } if len(out) == 0 { return fmt.Errorf("decoding failed") } } return nil } func bsonMapEncoding(tm TimerManager, iters int, dataSet string) error { r, err := loadSourceRaw(getProjectRoot(), perfDataDir, bsonDataDir, dataSet) if err != nil { return err } doc := make(map[string]interface{}) err = bson.Unmarshal(r, &doc) if err != nil { return err } var buf []byte tm.ResetTimer() for i := 0; i < iters; i++ { buf, err = bson.MarshalAppend(buf[:0], doc) if err != nil { return nil } if len(buf) == 0 { return errors.New("encoding failed") } } return nil } func BSONFlatMapDecoding(_ context.Context, tm TimerManager, iters int) error { return bsonMapDecoding(tm, iters, flatBSONData) } func BSONFlatMapEncoding(_ context.Context, tm TimerManager, iters int) error { return bsonMapEncoding(tm, iters, flatBSONData) } func BSONDeepMapDecoding(_ context.Context, tm TimerManager, iters int) error { return bsonMapDecoding(tm, iters, deepBSONData) } func BSONDeepMapEncoding(_ context.Context, tm TimerManager, iters int) error { return bsonMapEncoding(tm, iters, deepBSONData) } func BSONFullMapDecoding(_ context.Context, tm TimerManager, iters int) error { return bsonMapDecoding(tm, iters, fullBSONData) } func BSONFullMapEncoding(_ context.Context, tm TimerManager, iters int) error { return bsonMapEncoding(tm, iters, fullBSONData) }	2.05 KB	2025-05-25 12:27
📄 bson_struct.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" "errors" "go.mongodb.org/mongo-driver/bson" ) func BSONFlatStructDecoding(_ context.Context, tm TimerManager, iters int) error { r, err := loadSourceRaw(getProjectRoot(), perfDataDir, bsonDataDir, flatBSONData) if err != nil { return err } tm.ResetTimer() for i := 0; i < iters; i++ { out := flatBSON{} err := bson.Unmarshal(r, &out) if err != nil { return err } } return nil } func BSONFlatStructEncoding(_ context.Context, tm TimerManager, iters int) error { r, err := loadSourceRaw(getProjectRoot(), perfDataDir, bsonDataDir, flatBSONData) if err != nil { return err } doc := flatBSON{} err = bson.Unmarshal(r, &doc) if err != nil { return err } var buf []byte tm.ResetTimer() for i := 0; i < iters; i++ { buf, err = bson.Marshal(doc) if err != nil { return err } if len(buf) == 0 { return errors.New("encoding failed") } } return nil } func BSONFlatStructTagsEncoding(_ context.Context, tm TimerManager, iters int) error { r, err := loadSourceRaw(getProjectRoot(), perfDataDir, bsonDataDir, flatBSONData) if err != nil { return err } doc := flatBSONTags{} err = bson.Unmarshal(r, &doc) if err != nil { return err } var buf []byte tm.ResetTimer() for i := 0; i < iters; i++ { buf, err = bson.MarshalAppend(buf[:0], doc) if err != nil { return err } if len(buf) == 0 { return errors.New("encoding failed") } } return nil } func BSONFlatStructTagsDecoding(_ context.Context, tm TimerManager, iters int) error { r, err := loadSourceRaw(getProjectRoot(), perfDataDir, bsonDataDir, flatBSONData) if err != nil { return err } tm.ResetTimer() for i := 0; i < iters; i++ { out := flatBSONTags{} err := bson.Unmarshal(r, &out) if err != nil { return err } } return nil }	2.04 KB	2025-05-25 12:27
📄 bson_test.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import "testing" // func BenchmarkBSONFullReaderDecoding(b testing.B) { WrapCase(BSONFullReaderDecoding)(b) } func BenchmarkBSONFlatDocumentEncoding(b testing.B) { WrapCase(BSONFlatDocumentEncoding)(b) } func BenchmarkBSONFlatDocumentDecodingLazy(b testing.B) { WrapCase(BSONFlatDocumentDecodingLazy)(b) } func BenchmarkBSONFlatDocumentDecoding(b testing.B) { WrapCase(BSONFlatDocumentDecoding)(b) } func BenchmarkBSONDeepDocumentEncoding(b testing.B) { WrapCase(BSONDeepDocumentEncoding)(b) } func BenchmarkBSONDeepDocumentDecodingLazy(b testing.B) { WrapCase(BSONDeepDocumentDecodingLazy)(b) } func BenchmarkBSONDeepDocumentDecoding(b testing.B) { WrapCase(BSONDeepDocumentDecoding)(b) } // func BenchmarkBSONFullDocumentEncoding(b testing.B) { WrapCase(BSONFullDocumentEncoding)(b) } // func BenchmarkBSONFullDocumentDecodingLazy(b testing.B) { WrapCase(BSONFullDocumentDecodingLazy)(b) } // func BenchmarkBSONFullDocumentDecoding(b testing.B) { WrapCase(BSONFullDocumentDecoding)(b) } func BenchmarkBSONFlatMapDecoding(b testing.B) { WrapCase(BSONFlatMapDecoding)(b) } func BenchmarkBSONFlatMapEncoding(b testing.B) { WrapCase(BSONFlatMapEncoding)(b) } func BenchmarkBSONDeepMapDecoding(b testing.B) { WrapCase(BSONDeepMapDecoding)(b) } func BenchmarkBSONDeepMapEncoding(b testing.B) { WrapCase(BSONDeepMapEncoding)(b) } // func BenchmarkBSONFullMapDecoding(b testing.B) { WrapCase(BSONFullMapDecoding)(b) } // func BenchmarkBSONFullMapEncoding(b testing.B) { WrapCase(BSONFullMapEncoding)(b) } func BenchmarkBSONFlatStructDecoding(b testing.B) { WrapCase(BSONFlatStructDecoding)(b) } func BenchmarkBSONFlatStructTagsDecoding(b testing.B) { WrapCase(BSONFlatStructTagsDecoding)(b) } func BenchmarkBSONFlatStructEncoding(b testing.B) { WrapCase(BSONFlatStructEncoding)(b) } func BenchmarkBSONFlatStructTagsEncoding(b testing.B) { WrapCase(BSONFlatStructTagsEncoding)(b) }	2.19 KB	2025-05-25 12:27
📄 bson_types.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import "go.mongodb.org/mongo-driver/bson/primitive" type flatBSONTags struct { ID primitive.ObjectID `bson:"_id"` AA int64 `bson:"AAgSNVyBb"` AI bool `bson:"aicoMxZq"` AM int64 `bson:"AMQrGQmu"` Ag int `bson:"AgYYbYPr"` Ah int64 `bson:"ahFCBmqT"` At int64 `bson:"AtWNZJXa"` BB string `bson:"BBqZInWV"` BK int64 `bson:"bkuaZWRT"` Bw int `bson:"BwTXiovJ"` CD int `bson:"CDIGOuIZ"` CEA string `bson:"CEtYKsdd"` CEB string `bson:"cepcgozk"` CF int `bson:"CFujXoob"` CV int64 `bson:"cVjWCrlu"` CX string `bson:"cxOHMeDJ"` CY string `bson:"CYhSCkWB"` Cq string `bson:"CqCssWxW"` DC int `bson:"dCLfYqqM"` DDA int `bson:"ddPdLgGg"` DDB int `bson:"ddVenEkK"` DH string `bson:"dHsYhRbV"` DJ int `bson:"DJsnHZIC"` DN string `bson:"dNSuxlSU"` DO int64 `bson:"doshbrpF"` DP string `bson:"dpbwfSRb"` DQ int64 `bson:"DQBQcQFj"` DT string `bson:"dtywOLeD"` DV int `bson:"dVkWIafN"` EG bool `bson:"egxZaSsw"` ER string `bson:"eRTIdIJR"` FD int64 `bson:"FDYGeSiR"` FE string `bson:"fEheUtop"` Fp bool `bson:"FpduyhQP"` GE string `bson:"gErhgZTh"` GY int `bson:"gySFZeAE"` Gi uint `bson:"GiAHzFII"` HN string `bson:"hnVgYIQi"` HQA int `bson:"HQeCoswW"` HQB int `bson:"HQiykral"` HV int64 `bson:"HVHyetUM"` HW int `bson:"hwHOTmmW"` Hi bool `bson:"HicJbMpj"` Hr int `bson:"HrUPbFHD"` IF string `bson:"iFFGfTXc"` IJ int `bson:"ijwXMKqI"` IW int `bson:"iwfbMdcv"` Ib string `bson:"Ibrdrtgg"` Is bool `bson:"IsorvnMR"` JB string `bson:"jbUymqiB"` JM string `bson:"jmglLvAS"` JW int `bson:"jWaFvVAz"` JX int `bson:"JXMyYkfb"` Jh bool `bson:"JhImQOkw"` Jr string `bson:"JrJzKiIx"` Jz int `bson:"JzgaUWVG"` KF bool `bson:"kfvcFmKw"` KM int64 `bson:"KMKBtlov"` Kn string `bson:"KnhgtAOJ"` Ky int `bson:"KyxOoCqS"` LU string `bson:"LUPqMOHS"` LV bool `bson:"LVNIFCYm"` Ln int `bson:"LngvlnTV"` ML int `bson:"mlfZVfVT"` MN bool `bson:"MNuWZMLP"` MX int `bson:"MXMxLVBk"` Mc string `bson:"McpOBmaR"` Me string `bson:"MeUYSkPS"` Mq int `bson:"MqfkBZJF"` NB int `bson:"nBKWWUWk"` NK int `bson:"nKhiSITP"` OB int `bson:"obcwwqWZ"` OC string `bson:"OCsIhHxq"` OM int `bson:"omnwvBbA"` OR string `bson:"oRWMNJTE"` Of string `bson:"OfTmCvDx"` PA int `bson:"pacTBmxE"` PF int `bson:"PFZSRHNN"` PK bool `bson:"pKjOghFa"` PO int `bson:"pOMEwSod"` PP string `bson:"pPtPsgRl"` PQ int `bson:"pQyCJaEd"` Pj int `bson:"PjKiuWnQ"` Pv int `bson:"PvfnpsMV"` QH int `bson:"qHzOMXeT"` QR bool `bson:"qrJASGzU"` Qo string `bson:"QobifTeZ"` RE int64 `bson:"reiKnuza"` RM string `bson:"rmzUAgmk"` RP string `bson:"RPsQhgRD"` Rb uint `bson:"Rbxpznea"` ReA bool `bson:"RemSsnnR"` ReB int `bson:"ReOZakjB"` Rw string `bson:"RwAVVKHM"` SG bool `bson:"sGWJTAcT"` SU uint8 `bson:"SUWXijHT"` SYA int64 `bson:"sYtnozSc"` SYB string `bson:"SYtZkQbC"` Sq int64 `bson:"SqNvlUZF"` TA int `bson:"taoNnQYY"` TD string `bson:"TDUzNJiH"` TI string `bson:"tIJEYSYM"` TR bool `bson:"TRpgnInA"` Tg int `bson:"TgSwBbgp"` Tk int64 `bson:"TkXMwZlU"` Tm int64 `bson:"TmUnYUrv"` UK int `bson:"UKwbAKGw"` UM string `bson:"uMDWqLMf"` Up bool `bson:"UpdMADoN"` Ut int64 `bson:"UtbwOKLt"` VC int64 `bson:"VCSKFCoE"` VK string `bson:"vkEDWgmN"` VL string `bson:"vlSZaxCV"` VS string `bson:"vSLTtfDF"` VVA bool `bson:"vvUeXASH"` VVB int `bson:"VVvwKVRG"` Vc bool `bson:"VcCSqSmp"` Vp int16 `bson:"VplFgewF"` Vt string `bson:"VtzeOlCT"` WH bool `bson:"WHSQVLKG"` WJA bool `bson:"wjfyueDC"` WJB string `bson:"wjAWaOog"` WM int64 `bson:"wmDLUkXt"` WY string `bson:"WYJdGJLu"` Wm bool `bson:"WmMOvgFc"` Wo string `bson:"WoFGfdvb"` XE int `bson:"XEBqaXkB"` XG bool `bson:"XGxlHrXf"` XR string `bson:"xrzGnsEK"` XWA int64 `bson:"xWpeGNjl"` XWB string `bson:"xWUlYggc"` XX int64 `bson:"XXKbyIXG"` XZ int64 `bson:"xZOksssj"` Xe uint `bson:"XeRkAyCq"` Xx int `bson:"XxvXmHiQ"` YD string `bson:"YDHWnEXV"` YE bool `bson:"yeTUgNrU"` YK int `bson:"yKfZnGKG"` YX string `bson:"yXSBbPeT"` ZD bool `bson:"zDzSGNnW"` ZE bool `bson:"zEgGhhZf"` ZM string `bson:"zMCFzcWY"` ZSA int64 `bson:"zSYvADVf"` ZSB int64 `bson:"zswQbWEI"` Zm string `bson:"ZmtEJFSO"` } type flatBSON struct { AMQrGQmu int64 AAgSNVyBb int64 AgYYbYPr int AtWNZJXa int64 BBqZInWV string BwTXiovJ int CDIGOuIZ int CEtYKsdd string CFujXoob int CYhSCkWB string CqCssWxW string DJsnHZIC int DQBQcQFj int64 FDYGeSiR int64 FpduyhQP bool GiAHzFII uint HQeCoswW int HQiykral int HVHyetUM int64 HicJbMpj bool HrUPbFHD int Ibrdrtgg string IsorvnMR bool JXMyYkfb int JhImQOkw bool JrJzKiIx string JzgaUWVG int KMKBtlov int64 KnhgtAOJ string KyxOoCqS int LUPqMOHS string LVNIFCYm bool LngvlnTV int MNuWZMLP bool MXMxLVBk int McpOBmaR string MeUYSkPS string MqfkBZJF int OCsIhHxq string OfTmCvDx string PjKiuWnQ int PvfnpsMV int QobifTeZ string RPsQhgRD string Rbxpznea uint ReOZakjB int RemSsnnR bool RwAVVKHM string SUWXijHT uint8 SYtZkQbC string SqNvlUZF int64 TDUzNJiH string TRpgnInA bool TgSwBbgp int TkXMwZlU int64 TmUnYUrv int64 UKwbAKGw int UpdMADoN bool UtbwOKLt int64 VCSKFCoE int64 VVvwKVRG int VcCSqSmp bool VplFgewF int16 VtzeOlCT string WHSQVLKG bool WYJdGJLu string WmMOvgFc bool WoFGfdvb string XEBqaXkB int XGxlHrXf bool XXKbyIXG int64 XeRkAyCq uint XxvXmHiQ int YDHWnEXV string ZmtEJFSO string ID primitive.ObjectID `bson:"_id"` AhFCBmqT int64 AicoMxZq bool BkuaZWRT int64 CVjWCrlu int64 Cepcgozk string CxOHMeDJ string DCLfYqqM int DHsYhRbV string DNSuxlSU string DVkWIafN int DdPdLgGg int DdVenEkK int DoshbrpF int64 DpbwfSRb string DtywOLeD string ERTIdIJR string EgxZaSsw bool FEheUtop string GErhgZTh string GySFZeAE int HnVgYIQi string HwHOTmmW int IFFGfTXc string IjwXMKqI int IwfbMdcv int JWaFvVAz int JbUymqiB string JmglLvAS string KfvcFmKw bool MlfZVfVT int NBKWWUWk int NKhiSITP int ORWMNJTE string ObcwwqWZ int OmnwvBbA int PKjOghFa bool POMEwSod int PPtPsgRl string PQyCJaEd int PacTBmxE int QHzOMXeT int QrJASGzU bool ReiKnuza int64 RmzUAgmk string SGWJTAcT bool SYtnozSc int64 TIJEYSYM string TaoNnQYY int UMDWqLMf string VSLTtfDF string VkEDWgmN string VlSZaxCV string VvUeXASH bool WjAWaOog string WjfyueDC bool WmDLUkXt int64 XWUlYggc string XWpeGNjl int64 XZOksssj int64 XrzGnsEK string YKfZnGKG int YXSBbPeT string YeTUgNrU bool ZDzSGNnW bool ZEgGhhZf bool ZMCFzcWY string ZSYvADVf int64 ZswQbWEI int64 PfZSRHnn int }	7.01 KB	2025-05-25 12:27
📄 canary.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" ) // CanaryIncCase is a no-op. // // Deprecated: CanaryIncCase has no observable effect, so recent versions of the Go compiler may // bypass calls to it in the compiled binary. It should not be used in benchmarks. func CanaryIncCase(context.Context, TimerManager, int) error { return nil } // GlobalCanaryIncCase is a no-op. // // Deprecated: GlobalCanaryIncCase has no observable effect, so recent versions of the Go compiler // may bypass calls to it in the compiled binary. It should not be used in benchmarks. func GlobalCanaryIncCase(context.Context, TimerManager, int) error { return nil }	909 B	2025-05-25 12:27
📄 harness.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark // import "go.mongodb.org/mongo-driver/benchmark" import ( "context" "testing" "time" "go.mongodb.org/mongo-driver/internal/require" ) const ( five = 5 ten = 2 * five hundred = ten * ten thousand = ten * hundred tenThousand = ten * thousand hundredThousand = hundred * thousand million = hundred * hundredThousand ExecutionTimeout = five * time.Minute StandardRuntime = time.Minute MinimumRuntime = five * time.Second MinIterations = hundred ) type BenchCase func(context.Context, TimerManager, int) error type BenchFunction func(testing.B) func WrapCase(bench BenchCase) BenchFunction { name := getName(bench) return func(b testing.B) { ctx := context.Background() b.ResetTimer() b.ReportAllocs() err := bench(ctx, b, b.N) require.NoError(b, err, "case='%s'", name) } } func getAllCases() []CaseDefinition { return []CaseDefinition{ { Bench: BSONFlatDocumentEncoding, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: BSONFlatDocumentDecodingLazy, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: BSONFlatDocumentDecoding, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: BSONDeepDocumentEncoding, Count: tenThousand, Size: 19640000, Runtime: StandardRuntime, }, { Bench: BSONDeepDocumentDecodingLazy, Count: tenThousand, Size: 19640000, Runtime: StandardRuntime, }, { Bench: BSONDeepDocumentDecoding, Count: tenThousand, Size: 19640000, Runtime: StandardRuntime, }, // { // Bench: BSONFullDocumentEncoding, // Count: tenThousand, // Size: 57340000, // Runtime: StandardRuntime, // }, // { // Bench: BSONFullDocumentDecodingLazy, // Count: tenThousand, // Size: 57340000, // Runtime: StandardRuntime, // }, // { // Bench: BSONFullDocumentDecoding, // Count: tenThousand, // Size: 57340000, // Runtime: StandardRuntime, // }, // { // Bench: BSONFullReaderDecoding, // Count: tenThousand, // Size: 57340000, // Runtime: StandardRuntime, // }, { Bench: BSONFlatMapDecoding, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: BSONFlatMapEncoding, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: BSONDeepMapDecoding, Count: tenThousand, Size: 19640000, Runtime: StandardRuntime, }, { Bench: BSONDeepMapEncoding, Count: tenThousand, Size: 19640000, Runtime: StandardRuntime, }, // { // Bench: BSONFullMapDecoding, // Count: tenThousand, // Size: 57340000, // Runtime: StandardRuntime, // }, // { // Bench: BSONFullMapEncoding, // Count: tenThousand, // Size: 57340000, // Runtime: StandardRuntime, // }, { Bench: BSONFlatStructDecoding, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: BSONFlatStructTagsDecoding, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: BSONFlatStructEncoding, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: BSONFlatStructTagsEncoding, Count: tenThousand, Size: 75310000, Runtime: StandardRuntime, }, { Bench: SingleRunCommand, Count: tenThousand, Size: 160000, Runtime: StandardRuntime, }, { Bench: SingleFindOneByID, Count: tenThousand, Size: 16220000, Runtime: StandardRuntime, }, { Bench: SingleInsertSmallDocument, Count: tenThousand, Size: 2750000, Runtime: StandardRuntime, }, { Bench: SingleInsertLargeDocument, Count: ten, Size: 27310890, Runtime: StandardRuntime, }, { Bench: MultiFindMany, Count: tenThousand, Size: 16220000, Runtime: StandardRuntime, }, { Bench: MultiInsertSmallDocument, Count: tenThousand, Size: 2750000, Runtime: StandardRuntime, }, { Bench: MultiInsertLargeDocument, Count: ten, Size: 27310890, Runtime: StandardRuntime, RequiredIterations: tenThousand, }, } }	4.54 KB	2025-05-25 12:27
📄 harness_case.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" "errors" "fmt" "path/filepath" "reflect" "runtime" "strings" "time" ) type CaseDefinition struct { Bench BenchCase Count int Size int RequiredIterations int Runtime time.Duration cumulativeRuntime time.Duration elapsed time.Duration startAt time.Time isRunning bool } // TimerManager is a subset of the testing.B tool, used to manage // setup code. type TimerManager interface { ResetTimer() StartTimer() StopTimer() } func (c CaseDefinition) ResetTimer() { c.startAt = time.Now() c.elapsed = 0 c.isRunning = true } func (c CaseDefinition) StartTimer() { c.startAt = time.Now() c.isRunning = true } func (c CaseDefinition) StopTimer() { if !c.isRunning { return } c.elapsed += time.Since(c.startAt) c.isRunning = false } func (c CaseDefinition) Run(ctx context.Context) BenchResult { out := &BenchResult{ Trials: 1, DataSize: c.Size, Name: c.Name(), Operations: c.Count, } var cancel context.CancelFunc ctx, cancel = context.WithTimeout(ctx, 2ExecutionTimeout) defer cancel() fmt.Println("=== RUN", out.Name) if c.RequiredIterations == 0 { c.RequiredIterations = MinIterations } benchRepeat: for { if ctx.Err() != nil { break } if c.cumulativeRuntime >= c.Runtime { if out.Trials >= c.RequiredIterations { break } else if c.cumulativeRuntime >= ExecutionTimeout { break } } res := Result{ Iterations: c.Count, } c.StartTimer() res.Error = c.Bench(ctx, c, c.Count) c.StopTimer() res.Duration = c.elapsed c.cumulativeRuntime += res.Duration switch { case errors.Is(res.Error, context.DeadlineExceeded): break benchRepeat case errors.Is(res.Error, context.Canceled): break benchRepeat case res.Error == nil: out.Trials++ c.elapsed = 0 out.Raw = append(out.Raw, res) default: continue } } out.Duration = out.totalDuration() fmt.Printf(" --- REPORT: count=%d trials=%d requiredTrials=%d runtime=%s\n", c.Count, out.Trials, c.RequiredIterations, c.Runtime) if out.HasErrors() { fmt.Printf(" --- ERRORS: %s\n", strings.Join(out.errReport(), "\n ")) fmt.Printf("--- FAIL: %s (%s)\n", out.Name, out.roundedRuntime()) } else { fmt.Printf("--- PASS: %s (%s)\n", out.Name, out.roundedRuntime()) } return out } func (c CaseDefinition) String() string { return fmt.Sprintf("name=%s, count=%d, runtime=%s timeout=%s", c.Name(), c.Count, c.Runtime, ExecutionTimeout) } func (c CaseDefinition) Name() string { return getName(c.Bench) } func getName(i interface{}) string { n := runtime.FuncForPC(reflect.ValueOf(i).Pointer()).Name() parts := strings.Split(n, ".") if len(parts) > 1 { return parts[len(parts)-1] } return n } func getProjectRoot() string { return filepath.Dir(getDirectoryOfFile()) } func getDirectoryOfFile() string { _, file, _, _ := runtime.Caller(1) return filepath.Dir(file) }	3.2 KB	2025-05-25 12:27
📄 harness_main.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" "encoding/json" "flag" "fmt" "io/ioutil" "os" ) func DriverBenchmarkMain() int { var hasErrors bool var outputFileName string flag.StringVar(&outputFileName, "output", "perf.json", "path to write the 'perf.json' file") flag.Parse() ctx := context.Background() output := []interface{}{} for _, res := range runDriverCases(ctx) { if res.HasErrors() { hasErrors = true } evg, err := res.EvergreenPerfFormat() if err != nil { hasErrors = true continue } output = append(output, evg...) } evgOutput, err := json.MarshalIndent(output, "", " ") if err != nil { return 1 } evgOutput = append(evgOutput, []byte("\n")...) if outputFileName == "" { fmt.Println(string(evgOutput)) } else { // Ignore gosec warning "Expect WriteFile permissions to be 0600 or less" for benchmark // result file. /* #nosec G306 / err := ioutil.WriteFile(outputFileName, evgOutput, 0644) if err != nil { fmt.Fprintf(os.Stderr, "problem writing file '%s': %s", outputFileName, err.Error()) return 1 } } if hasErrors { return 1 } return 0 } func runDriverCases(ctx context.Context) []BenchResult { cases := getAllCases() results := []*BenchResult{} for _, bc := range cases { results = append(results, bc.Run(ctx)) } return results }	1.56 KB	2025-05-25 12:27
📄 harness_results.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "fmt" "time" "github.com/montanaflynn/stats" ) type BenchResult struct { Name string Trials int Duration time.Duration Raw []Result DataSize int Operations int hasErrors bool } type Metric struct { Name string `json:"name"` Value interface{} `json:"value"` } func (r BenchResult) EvergreenPerfFormat() ([]interface{}, error) { timings := r.timings() median, err := stats.Median(timings) if err != nil { return nil, err } min, err := stats.Min(timings) if err != nil { return nil, err } max, err := stats.Max(timings) if err != nil { return nil, err } out := []interface{}{ map[string]interface{}{ "info": map[string]interface{}{ "test_name": r.Name + "-throughput", "args": map[string]interface{}{ "threads": 1, }, }, "metrics": []Metric{ {Name: "seconds", Value: r.Duration.Round(time.Millisecond).Seconds()}, {Name: "ops_per_second", Value: r.getThroughput(median)}, {Name: "ops_per_second_min", Value: r.getThroughput(min)}, {Name: "ops_per_second_max", Value: r.getThroughput(max)}, }, }, } if r.DataSize > 0 { out = append(out, interface{}(map[string]interface{}{ "info": map[string]interface{}{ "test_name": r.Name + "-MB-adjusted", "args": map[string]interface{}{ "threads": 1, }, }, "metrics": []Metric{ {Name: "seconds", Value: r.Duration.Round(time.Millisecond).Seconds()}, {Name: "ops_per_second", Value: r.adjustResults(median)}, {Name: "ops_per_second_min", Value: r.adjustResults(min)}, {Name: "ops_per_second_max", Value: r.adjustResults(max)}, }, })) } return out, nil } func (r BenchResult) timings() []float64 { out := []float64{} for _, r := range r.Raw { out = append(out, r.Duration.Seconds()) } return out } func (r BenchResult) totalDuration() time.Duration { var out time.Duration for _, trial := range r.Raw { out += trial.Duration } return out } func (r BenchResult) adjustResults(data float64) float64 { return float64(r.DataSize) / data } func (r BenchResult) getThroughput(data float64) float64 { return float64(r.Operations) / data } func (r BenchResult) roundedRuntime() time.Duration { return roundDurationMS(r.Duration) } func (r BenchResult) String() string { return fmt.Sprintf("name=%s, trials=%d, secs=%s", r.Name, r.Trials, r.Duration) } func (r BenchResult) HasErrors() bool { if r.hasErrors == nil { var val bool for _, res := range r.Raw { if res.Error != nil { val = true break } } r.hasErrors = &val } return r.hasErrors } func (r *BenchResult) errReport() []string { errs := []string{} for _, res := range r.Raw { if res.Error != nil { errs = append(errs, res.Error.Error()) } } return errs } type Result struct { Duration time.Duration Iterations int Error error } func roundDurationMS(d time.Duration) time.Duration { rounded := d.Round(time.Millisecond) if rounded == 1<<63-1 { return 0 } return rounded }	3.23 KB	2025-05-25 12:27
📄 multi.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" "errors" "go.mongodb.org/mongo-driver/bson" ) func MultiFindMany(ctx context.Context, tm TimerManager, iters int) error { ctx, cancel := context.WithCancel(ctx) defer cancel() db, err := getClientDB(ctx) if err != nil { return err } defer func() { _ = db.Client().Disconnect(ctx) }() db = db.Client().Database("perftest") if err = db.Drop(ctx); err != nil { return err } doc, err := loadSourceDocument(getProjectRoot(), perfDataDir, singleAndMultiDataDir, tweetData) if err != nil { return err } coll := db.Collection("corpus") payload := make([]interface{}, iters) for idx := range payload { payload[idx] = doc } if _, err = coll.InsertMany(ctx, payload); err != nil { return err } tm.ResetTimer() cursor, err := coll.Find(ctx, bson.D{}) if err != nil { return err } defer cursor.Close(ctx) counter := 0 for cursor.Next(ctx) { err = cursor.Err() if err != nil { return err } if len(cursor.Current) == 0 { return errors.New("error retrieving document") } counter++ } if counter != iters { return errors.New("problem iterating cursors") } tm.StopTimer() if err = cursor.Close(ctx); err != nil { return err } return db.Drop(ctx) } func multiInsertCase(ctx context.Context, tm TimerManager, iters int, data string) error { ctx, cancel := context.WithCancel(ctx) defer cancel() db, err := getClientDB(ctx) if err != nil { return err } defer func() { _ = db.Client().Disconnect(ctx) }() db = db.Client().Database("perftest") if err = db.Drop(ctx); err != nil { return err } doc, err := loadSourceDocument(getProjectRoot(), perfDataDir, singleAndMultiDataDir, data) if err != nil { return err } err = db.RunCommand(ctx, bson.D{{"create", "corpus"}}).Err() if err != nil { return err } payload := make([]interface{}, iters) for idx := range payload { payload[idx] = doc } coll := db.Collection("corpus") tm.ResetTimer() res, err := coll.InsertMany(ctx, payload) if err != nil { return err } tm.StopTimer() if len(res.InsertedIDs) != iters { return errors.New("bulk operation did not complete") } return db.Drop(ctx) } func MultiInsertSmallDocument(ctx context.Context, tm TimerManager, iters int) error { return multiInsertCase(ctx, tm, iters, smallData) } func MultiInsertLargeDocument(ctx context.Context, tm TimerManager, iters int) error { return multiInsertCase(ctx, tm, iters, largeData) }	2.67 KB	2025-05-25 12:27
📄 multi_test.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import "testing" func BenchmarkMultiFindMany(b testing.B) { WrapCase(MultiFindMany)(b) } func BenchmarkMultiInsertSmallDocument(b testing.B) { WrapCase(MultiInsertSmallDocument)(b) } func BenchmarkMultiInsertLargeDocument(b *testing.B) { WrapCase(MultiInsertLargeDocument)(b) }	581 B	2025-05-25 12:27
📄 operation_test.go // Copyright (C) MongoDB, Inc. 2022-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" "testing" "go.mongodb.org/mongo-driver/bson" "go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo/options" ) var teststrings = []string{ "hello", "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Nunc hendrerit nibh eu lorem scelerisque iaculis. Mauris tincidunt est quis gravida sollicitudin. Vestibulum ante dolor, semper eget finibus accumsan, finibus id nulla. Nam mauris libero, mattis sed libero at, vestibulum vehicula tellus. Nullam in finibus neque. Ut bibendum blandit condimentum. Etiam tortor mauris, tempus et accumsan a, lobortis cursus lacus. Pellentesque fermentum gravida aliquam. Donec fermentum nisi ut venenatis convallis. Praesent ultrices, justo ac fringilla eleifend, augue libero tristique quam, imperdiet rutrum lectus odio id purus. Curabitur vel metus ullamcorper massa dapibus tincidunt. Nam mollis feugiat sapien ut sagittis. Cras sed ex ligula. Etiam nec nisi diam. Pellentesque id metus molestie, tempus velit et, malesuada eros. Praesent convallis arcu et semper molestie. Morbi eu orci tempor, blandit dui egestas, faucibus diam. Aenean ac tempor justo. Donec id lectus tristique, ultrices enim sed, suscipit sapien. In arcu mauris, venenatis sed venenatis id, mollis a risus. Phasellus id massa et magna volutpat elementum in quis libero. Aliquam a aliquam erat. Nunc leo massa, sagittis at egestas vel, iaculis vitae quam. Pellentesque placerat metus id velit lobortis euismod in non sapien. Duis a quam sed elit fringilla maximus at et purus. Nullam pharetra accumsan efficitur. Integer a mattis urna. Suspendisse vehicula, nunc euismod luctus suscipit, mi mauris sollicitudin diam, porta rhoncus libero metus vitae erat. Sed lacus sem, feugiat vitae nisi at, malesuada ultricies ipsum. Quisque hendrerit posuere metus. Donec magna erat, facilisis et dictum at, tempor in leo. Maecenas luctus vestibulum quam, eu ornare ex aliquam vitae. Mauris ac mauris posuere, mattis nisl nec, fringilla libero. Nulla in ipsum ut arcu condimentum mollis. Donec viverra massa nec lacus condimentum vulputate. Nulla at dictum eros, quis sodales ante. Duis condimentum accumsan consectetur. Aenean sodales at turpis vitae efficitur. Vestibulum in diam faucibus, consequat sem ut, auctor lorem. Duis tincidunt non eros pretium rhoncus. Sed quis eros ligula. Donec vulputate ultrices enim, quis interdum dui rhoncus eu. In at mollis ex. In sed pulvinar risus. Morbi efficitur leo magna, eget bibendum leo consequat id. Pellentesque ultricies ipsum leo, sit amet cursus est bibendum a. Mauris eget porta felis. Vivamus dignissim pellentesque risus eget interdum. Mauris ultrices metus at blandit tincidunt. Duis tempor sapien vel luctus mattis. Vivamus ac orci nibh. Nam eget tempor neque. Proin lacus nibh, porttitor nec pellentesque id, dignissim et eros. Nullam et libero faucibus, iaculis mi sed, faucibus leo. In mollis sem ac porta suscipit. Ut rutrum, justo a gravida lobortis, neque nibh tincidunt mi, id eleifend dolor dolor vel arcu. Fusce vel egestas ante, eu commodo eros. Donec augue odio, bibendum ut nulla ultricies, cursus eleifend lacus. Nulla viverra ac massa vel placerat. Duis aliquam, ipsum vitae ultricies imperdiet, tellus nisl venenatis mauris, et congue elit nulla vitae est. Suspendisse volutpat ullamcorper diam, et vehicula leo bibendum at. In hac habitasse platea dictumst. Donec mattis neque a lorem ullamcorper rutrum. Curabitur mattis auctor velit, vitae iaculis mauris convallis in. Donec vulputate sapien non ex pretium semper. Vestibulum ut ligula sit amet arcu pellentesque aliquam. Pellentesque odio diam, pharetra at nunc varius, pharetra consectetur sem. Integer pretium magna pretium, mattis lectus eget, laoreet libero. Morbi dictum et dolor eu finibus. Etiam vestibulum finibus quam, vel eleifend tortor mattis viverra. Donec porttitor est vitae ligula volutpat lobortis. Donec ac semper diam. Maecenas sapien eros, blandit non velit in, faucibus auctor risus. In quam nibh, congue a nisl sit amet, tempor volutpat tortor. Curabitur dignissim auctor orci a varius. Nulla faucibus lacus libero, vitae fringilla elit facilisis id. Aliquam id elit dui. Cras convallis ligula ac leo bibendum lacinia. Duis interdum ac lectus sed tristique. Maecenas sem magna, gravida quis sapien sit amet, varius luctus ligula. Curabitur eleifend mi nibh. Suspendisse iaculis commodo justo, vitae pretium risus scelerisque non. Sed pulvinar augue nec fermentum feugiat. Nam et ligula tellus. Vestibulum euismod accumsan nibh, at rutrum est tristique sit amet. Duis porttitor ex felis, quis consectetur nunc tempor ut. Nulla vitae consequat velit, id condimentum orci. Sed lacinia velit urna, nec laoreet est varius ac. Integer dapibus libero vel bibendum posuere. Curabitur cursus est vel ante euismod dapibus. Ut hendrerit odio id rhoncus efficitur. Nam luctus sem orci, in congue ipsum ultrices at. Morbi sed tortor ut metus elementum ultrices. Cras vehicula ante magna, nec faucibus neque placerat et. Vivamus justo lacus, aliquet sit amet semper ac, porta vehicula nibh. Duis et rutrum elit. In nisi eros, fringilla ut odio eget, vehicula laoreet elit. Suspendisse potenti. Vivamus ut ultricies lacus. Integer pellentesque posuere mauris, eget aliquet purus tincidunt in. Suspendisse potenti. Nam quis purus iaculis, cursus mauris a, tempus mi. Pellentesque ullamcorper lacus vitae lacus volutpat, quis ultricies metus sagittis. Etiam imperdiet libero vitae ante cursus tempus. Nulla eu mi sodales neque scelerisque eleifend id non nisi. Maecenas blandit vitae turpis nec lacinia. Duis posuere cursus metus. Orci varius natoque penatibus et magnis dis parturient montes, nascetur ridaculus mus. Ut ultrices hendrerit quam, sit amet condimentum massa finibus a. Donec et vehicula urna. Pellentesque lorem felis, fermentum vel feugiat et, congue eleifend orci. Suspendisse potenti. Sed dignissim massa at justo tristique, id feugiat neque vulputate. Pellentesque dui massa, maximus quis consequat quis, fringilla vel turpis. Etiam fermentum ex eget massa varius, a fringilla velit placerat. Sed fringilla convallis urna, ut finibus purus accumsan a. Vestibulum porttitor risus lorem, eu venenatis velit suscipit vel. Ut nec diam egestas, sollicitudin nulla sit amet, porttitor felis. Duis a nisl a ante interdum hendrerit. Integer sollicitudin scelerisque ex, et blandit magna blandit at. Vivamus a vulputate ante. Nam non tortor a lacus euismod venenatis. Vestibulum libero augue, consequat vitae turpis nec, mattis tristique nibh. Fusce pulvinar dolor vel ipsum eleifend varius. Morbi id ante eget tellus venenatis interdum non sit amet ante. Nulla luctus tempor purus, eget ultrices odio varius eget. Duis commodo eros ac molestie fermentum. Praesent vestibulum est eu massa posuere, et fermentum orci tincidunt. Duis dignissim nunc sit amet elit laoreet mollis. Aenean porttitor et nunc vel venenatis. Nunc viverra ligula nec tincidunt vehicula. Pellentesque in magna volutpat, consequat est eget, varius mauris. Maecenas in tellus eros. Aliquam erat volutpat. Phasellus blandit faucibus velit ac placerat. Donec luctus hendrerit pretium. Sed mauris purus, lobortis non erat sed, mattis ornare nulla. Fusce eu vulputate lacus. In enim justo, elementum at tortor nec, interdum semper ligula. Donec condimentum erat elit, non luctus augue rhoncus et. Quisque interdum elit dui, in vestibulum lacus aliquet et. Mauris aliquam sed ante id eleifend. Donec velit dolor, blandit et mattis non, bibendum at lorem. Nullam blandit quam sapien. Duis rutrum nunc vitae odio imperdiet condimentum. Nunc vel pellentesque purus. Cras iaculis dui est, quis cursus tortor mattis non. Donec non tincidunt lacus. Sed eget molestie lacus. Phasellus pharetra ullamcorper purus. Sed sit amet ultricies ligula, aliquam elementum velit. Cras commodo mauris vel sapien rutrum, ac pharetra libero mollis. Donec facilisis sit amet elit ac porttitor. Phasellus rutrum rhoncus sagittis. Interdum et malesuada fames ac ante ipsum primis in faucibus. Etiam iaculis ac odio eu sodales. Proin blandit fermentum arcu efficitur ornare. Vestibulum pharetra est quis mi lobortis interdum. Proin molestie pretium viverra. Integer pellentesque eros nisi, non rutrum odio interdum ut. Quisque vel ante et mi placerat mollis ut eget eros. Etiam vitae orci lectus. Nulla scelerisque dui in dictum ornare. Aliquam vestibulum fringilla eros, id fermentum dolor euismod eget. Ut vitae massa a augue suscipit bibendum non ac mi. Pellentesque id ligula in sapien fermentum fermentum. In ut sem molestie, consectetur ex tristique, tempor risus. Maecenas scelerisque, ex eget cursus ornare, dolor nisi condimentum tellus, in venenatis nibh elit rutrum turpis. Sed sed vestibulum ex, molestie sodales leo. Vivamus cursus aliquet consequat. Aliquam et enim eget lorem placerat egestas a at justo. Praesent congue vitae purus vel scelerisque. Praesent faucibus massa felis, non porttitor dolor varius at. Nam fringilla risus sit amet faucibus vestibulum. Aliquam rhoncus ex vel magna blandit, eu dapibus felis tristique. Nam dignissim vestibulum neque vitae suscipit. Nunc a pharetra dui. Etiam nec quam sed mauris pharetra finibus in a tellus. Ut vehicula molestie lectus in pretium. Donec sit amet dui purus. Nunc in vestibulum sapien. Donec elit quam, mollis luctus gravida ac, ullamcorper quis urna. Vivamus a urna egestas velit tempor interdum non eget dui. Maecenas maximus diam at consequat dictum. Etiam sed metus quis enim faucibus cursus condimentum ut nisi. In et iaculis odio. Curabitur sollicitudin ultrices finibus. Aliquam et nisi porta, vehicula urna id, dictum turpis. Sed id iaculis justo, non semper metus. Quisque euismod, tellus iaculis sagittis vestibulum, leo magna blandit felis, non pharetra velit lacus sed nunc. Curabitur mollis porttitor odio, sed feugiat leo rhoncus quis. Duis faucibus tellus id venenatis vestibulum. Duis interdum pretium cursus. Integer sed iaculis mi. Phasellus at odio at felis fermentum congue. Morbi at ante ut lacus posuere accumsan quis in orci. Nullam eget sapien eu nibh venenatis malesuada. Nulla sed ligula et metus mattis placerat sed eget nisl. Nunc cursus et nulla id dictum. Vivamus efficitur aliquam. ", } func BenchmarkClientWrite(b testing.B) { benchmarks := []struct { name string opt options.ClientOptions }{ {name: "not compressed", opt: options.Client().ApplyURI("mongodb://localhost:27017")}, {name: "snappy", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"snappy"})}, {name: "zlib", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"zlib"})}, {name: "zstd", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"zstd"})}, } for _, bm := range benchmarks { b.Run(bm.name, func(b testing.B) { client, err := mongo.NewClient(bm.opt) if err != nil { b.Fatalf("error creating client: %v", err) } ctx := context.Background() err = client.Connect(ctx) if err != nil { b.Fatalf("error connecting: %v", err) } defer func() { _ = client.Disconnect(context.Background()) }() coll := client.Database("test").Collection("test") _, err = coll.DeleteMany(context.Background(), bson.D{}) if err != nil { b.Fatalf("error deleting the document: %v", err) } b.ResetTimer() b.RunParallel(func(p testing.PB) { var cnt int for p.Next() { cnt = (cnt + 1) % len(teststrings) _, err = coll.InsertOne(context.Background(), bson.D{{"text", teststrings[cnt]}}) if err != nil { b.Fatalf("error inserting one document: %v", err) } } }) _, _ = coll.DeleteMany(context.Background(), bson.D{}) }) } } func BenchmarkClientBulkWrite(b testing.B) { benchmarks := []struct { name string opt options.ClientOptions }{ {name: "not compressed", opt: options.Client().ApplyURI("mongodb://localhost:27017")}, {name: "snappy", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"snappy"})}, {name: "zlib", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"zlib"})}, {name: "zstd", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"zstd"})}, } for _, bm := range benchmarks { b.Run(bm.name, func(b testing.B) { client, err := mongo.NewClient(bm.opt) if err != nil { b.Fatalf("error creating client: %v", err) } ctx := context.Background() err = client.Connect(ctx) if err != nil { b.Fatalf("error connecting: %v", err) } defer func() { _ = client.Disconnect(context.Background()) }() coll := client.Database("test").Collection("test") _, err = coll.DeleteMany(context.Background(), bson.D{}) if err != nil { b.Fatalf("error deleting the document: %v", err) } b.ResetTimer() b.RunParallel(func(p testing.PB) { var cnt int for p.Next() { cnt = (cnt + 1) % len(teststrings) _, err = coll.BulkWrite(context.Background(), []mongo.WriteModel{ mongo.NewInsertOneModel().SetDocument(bson.D{{"text", teststrings[cnt]}}), mongo.NewInsertOneModel().SetDocument(bson.D{{"text", teststrings[cnt]}}), mongo.NewInsertOneModel().SetDocument(bson.D{{"text", teststrings[cnt]}}), mongo.NewInsertOneModel().SetDocument(bson.D{{"text", teststrings[cnt]}}), }) if err != nil { b.Fatalf("error inserting one document: %v", err) } } }) _, _ = coll.DeleteMany(context.Background(), bson.D{}) }) } } func BenchmarkClientRead(b testing.B) { benchmarks := []struct { name string opt options.ClientOptions }{ {name: "not compressed", opt: options.Client().ApplyURI("mongodb://localhost:27017")}, {name: "snappy", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"snappy"})}, {name: "zlib", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"zlib"})}, {name: "zstd", opt: options.Client().ApplyURI("mongodb://localhost:27017").SetCompressors([]string{"zstd"})}, } for _, bm := range benchmarks { b.Run(bm.name, func(b testing.B) { client, err := mongo.NewClient(bm.opt) if err != nil { b.Fatalf("error creating client: %v", err) } ctx := context.Background() err = client.Connect(ctx) if err != nil { b.Fatalf("error connecting: %v", err) } defer func() { _ = client.Disconnect(context.Background()) }() coll := client.Database("test").Collection("test") _, err = coll.DeleteMany(context.Background(), bson.D{}) if err != nil { b.Fatalf("error deleting the document: %v", err) } for i, text := range teststrings { _, err = coll.InsertOne(context.Background(), bson.D{{"_id", i}, {"text", text}}) if err != nil { b.Fatalf("error inserting one document: %v", err) } } b.ResetTimer() b.RunParallel(func(p testing.PB) { var cnt int for p.Next() { cnt = (cnt + 1) % len(teststrings) var res bson.D err = coll.FindOne(context.Background(), bson.M{"_id": cnt}).Decode(&res) if err != nil { b.Errorf("error finding one document: %v", err) } } }) }) } }	15.14 KB	2025-05-25 12:27
📄 single.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import ( "context" "errors" "go.mongodb.org/mongo-driver/bson" "go.mongodb.org/mongo-driver/internal/handshake" "go.mongodb.org/mongo-driver/internal/integtest" "go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo/options" ) const ( singleAndMultiDataDir = "single_and_multi_document" tweetData = "tweet.json" smallData = "small_doc.json" largeData = "large_doc.json" ) func getClientDB(ctx context.Context) (*mongo.Database, error) { cs, err := integtest.GetConnString() if err != nil { return nil, err } client, err := mongo.NewClient(options.Client().ApplyURI(cs.String())) if err != nil { return nil, err } if err = client.Connect(ctx); err != nil { return nil, err } db := client.Database(integtest.GetDBName(cs)) return db, nil } func SingleRunCommand(ctx context.Context, tm TimerManager, iters int) error { ctx, cancel := context.WithCancel(ctx) defer cancel() db, err := getClientDB(ctx) if err != nil { return err } defer func() { _ = db.Client().Disconnect(ctx) }() cmd := bson.D{{handshake.LegacyHelloLowercase, true}} tm.ResetTimer() for i := 0; i < iters; i++ { var doc bson.D err := db.RunCommand(ctx, cmd).Decode(&doc) if err != nil { return err } // read the document and then throw it away to prevent out, err := bson.Marshal(doc) if err != nil { return err } if len(out) == 0 { return errors.New("output of command is empty") } } tm.StopTimer() return nil } func SingleFindOneByID(ctx context.Context, tm TimerManager, iters int) error { ctx, cancel := context.WithCancel(ctx) defer cancel() db, err := getClientDB(ctx) if err != nil { return err } db = db.Client().Database("perftest") if err = db.Drop(ctx); err != nil { return err } doc, err := loadSourceDocument(getProjectRoot(), perfDataDir, singleAndMultiDataDir, tweetData) if err != nil { return err } coll := db.Collection("corpus") for i := 0; i < iters; i++ { idDoc := make(bson.D, 0, len(doc)+1) idDoc = append(idDoc, bson.E{"_id", i}) idDoc = append(idDoc, doc...) res, err := coll.InsertOne(ctx, idDoc) if err != nil { return err } if res.InsertedID == nil { return errors.New("no inserted ID returned") } } tm.ResetTimer() for i := 0; i < iters; i++ { var res bson.D err := coll.FindOne(ctx, bson.D{{"_id", i}}).Decode(&res) if err != nil { return err } } tm.StopTimer() return db.Drop(ctx) } func singleInsertCase(ctx context.Context, tm TimerManager, iters int, data string) error { ctx, cancel := context.WithCancel(ctx) defer cancel() db, err := getClientDB(ctx) if err != nil { return err } defer func() { _ = db.Client().Disconnect(ctx) }() db = db.Client().Database("perftest") if err = db.Drop(ctx); err != nil { return err } doc, err := loadSourceDocument(getProjectRoot(), perfDataDir, singleAndMultiDataDir, data) if err != nil { return err } err = db.RunCommand(ctx, bson.D{{"create", "corpus"}}).Err() if err != nil { return err } coll := db.Collection("corpus") tm.ResetTimer() for i := 0; i < iters; i++ { if _, err = coll.InsertOne(ctx, doc); err != nil { return err } } tm.StopTimer() return db.Drop(ctx) } func SingleInsertSmallDocument(ctx context.Context, tm TimerManager, iters int) error { return singleInsertCase(ctx, tm, iters, smallData) } func SingleInsertLargeDocument(ctx context.Context, tm TimerManager, iters int) error { return singleInsertCase(ctx, tm, iters, largeData) }	3.74 KB	2025-05-25 12:27
📄 single_test.go // Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package benchmark import "testing" func BenchmarkSingleRunCommand(b testing.B) { WrapCase(SingleRunCommand)(b) } func BenchmarkSingleFindOneByID(b testing.B) { WrapCase(SingleFindOneByID)(b) } func BenchmarkSingleInsertSmallDocument(b testing.B) { WrapCase(SingleInsertSmallDocument)(b) } func BenchmarkSingleInsertLargeDocument(b testing.B) { WrapCase(SingleInsertLargeDocument)(b) }	678 B	2025-05-25 12:27

Terminal