We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent eb7d5d3 commit 26368d8Copy full SHA for 26368d8
x/mongo/driver/topology/server.go
@@ -799,6 +799,11 @@ func (s *Server) check() (description.Server, error) {
799
// Create a new connection if this is the first check, the connection was closed after an error during the previous
800
// check, or the previous check was cancelled.
801
if s.conn == nil || s.conn.closed() || s.checkWasCancelled() {
802
+ connID := "0"
803
+ if s.conn != nil {
804
+ connID = s.conn.ID()
805
+ }
806
+ s.publishServerHeartbeatStartedEvent(connID, false)
807
// Create a new connection and add it's handshake RTT as a sample.
808
err = s.setupHeartbeatConnection()
809
duration = time.Since(start)
0 commit comments