|
@@ -43,7 +43,7 @@ func MgoNewClient(mgoConfig MgoConfig) *qmgo.Client {
|
|
|
|
|
|
startedCommands := sync.Map{}
|
|
|
|
|
|
- cmdMonitor := &event.CommandMonitor{
|
|
|
+ _ = &event.CommandMonitor{
|
|
|
Started: func(_ context.Context, evt *event.CommandStartedEvent) {
|
|
|
startedCommands.Store(evt.RequestID, evt.Command)
|
|
|
|
|
@@ -76,7 +76,7 @@ func MgoNewClient(mgoConfig MgoConfig) *qmgo.Client {
|
|
|
|
|
|
|
|
|
ops := options.ClientOptions{ClientOptions: &mgoptions.ClientOptions{}}
|
|
|
- ops.SetMonitor(cmdMonitor)
|
|
|
+
|
|
|
|
|
|
ctx := context.Background()
|
|
|
|