GODRIVER-3173 Add duration to failure; update tests

Author: prestonvasquez

internal/integration/unified/schema_version.go

@@ -16,7 +16,7 @@ import (
 
 var (
 	supportedSchemaVersions = map[int]string{
-		1: "1.22",
+		1: "1.24",
 	}
 )
 

testdata/specifications

@@ -362,6 +362,7 @@ func TestCMAPProse(t *testing.T) {
 		assert.Equal(t, conn.driverConnectionID, failed[0].ConnectionID)
 		assert.Equal(t, requestID, failed[0].RequestID)
 		assert.Equal(t, "error", failed[0].Reason)
+		assert.Greater(t, int(failed[0].Duration), 0)
 		assert.ErrorIs(t, failed[0].Error, io.EOF)
 
 		// There should be 0 ConnectionPendingResponseSucceeded event.

x/mongo/driver/topology/cmap_prose_test.go

@@ -820,7 +820,7 @@ func publishPendingResponseStarted(pool *pool, conn *connection) {
 	}
 }
 
-func publishPendingResponseFailed(pool *pool, conn *connection, err error) {
+func publishPendingResponseFailed(pool *pool, conn *connection, dur time.Duration, err error) {
 	prs := conn.pendingResponseState
 	if prs == nil {
 		return
@@ -850,6 +850,7 @@ func publishPendingResponseFailed(pool *pool, conn *connection, err error) {
 			RequestID:    prs.requestID,
 			Reason:       reason,
 			Error:        err,
+			Duration:     dur,
 		}
 		pool.monitor.Event(e)
 	}
@@ -1028,7 +1029,8 @@ func awaitPendingResponse(ctx context.Context, pool *pool, conn *connection) err
 		// operations. This is likely a bug in the Go Driver. So it's possible that
 		// the connection is idle at the point of check-in.
 		defer func() {
-			publishPendingResponseFailed(pool, conn, err)
+			dur := time.Since(st)
+			publishPendingResponseFailed(pool, conn, dur, err)
 
 			_ = pool.checkInNoEvent(conn)
 		}()