File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change 7
7
package mongo
8
8
9
9
import (
10
+ "context"
10
11
"encoding/json"
11
12
"io/ioutil"
12
13
"os"
@@ -70,7 +71,7 @@ var retryMonitoredTopologyOnce sync.Once
70
71
var retryStartedChan = make (chan * event.CommandStartedEvent , 100 )
71
72
72
73
var retryMonitor = & event.CommandMonitor {
73
- Started : func (cse * event.CommandStartedEvent ) {
74
+ Started : func (ctx context. Context , cse * event.CommandStartedEvent ) {
74
75
retryStartedChan <- cse
75
76
},
76
77
}
Original file line number Diff line number Diff line change @@ -104,7 +104,7 @@ type transError struct {
104
104
var transStartedChan = make (chan * event.CommandStartedEvent , 100 )
105
105
106
106
var transMonitor = & event.CommandMonitor {
107
- Started : func (cse * event.CommandStartedEvent ) {
107
+ Started : func (ctx context. Context , cse * event.CommandStartedEvent ) {
108
108
//fmt.Printf("STARTED: %v\n", cse)
109
109
transStartedChan <- cse
110
110
},
You can’t perform that action at this time.
0 commit comments