diff --git a/src/go/mongolib/proto/system.profile.go b/src/go/mongolib/proto/system.profile.go index 3bb4494d..fb45b1f0 100644 --- a/src/go/mongolib/proto/system.profile.go +++ b/src/go/mongolib/proto/system.profile.go @@ -2,11 +2,13 @@ package proto import "time" +// docsExamined is renamed from nscannedObjects in 3.2.0 type SystemProfile struct { AllUsers []interface{} `bson:"allUsers"` Client string `bson:"client"` CursorExhausted bool `bson:"cursorExhausted"` DocsExamined int `bson:"docsExamined"` + NscannedObjects int `bson:"nscannedObjects"` ExecStats struct { Advanced int `bson:"advanced"` ExecutionTimeMillisEstimate int `bson:"executionTimeMillisEstimate"` diff --git a/src/go/mongolib/stats/stats.go b/src/go/mongolib/stats/stats.go index 0534b029..408377b2 100644 --- a/src/go/mongolib/stats/stats.go +++ b/src/go/mongolib/stats/stats.go @@ -91,7 +91,12 @@ func (s *Stats) Add(doc proto.SystemProfile) error { s.setQueryInfoAndCounters(key, qiac) } qiac.Count++ - qiac.NScanned = append(qiac.NScanned, float64(doc.DocsExamined)) + // docsExamined is renamed from nscannedObjects in 3.2.0. + if doc.NscannedObjects > 0 { + qiac.NScanned = append(qiac.NScanned, float64(doc.NscannedObjects)) + } else { + qiac.NScanned = append(qiac.NScanned, float64(doc.DocsExamined)) + } qiac.NReturned = append(qiac.NReturned, float64(doc.Nreturned)) qiac.QueryTime = append(qiac.QueryTime, float64(doc.Millis)) qiac.ResponseLength = append(qiac.ResponseLength, float64(doc.ResponseLength))