here-leslie-lau/mongo-plus

Secondary encapsulation based on mongo go driver

Hi there 👋

• 🔭 I'm open sourcing something I'm passionate about
• 📖 I'm learning english now💪
• I'm a gopher now😄
• I'm a vimer🐛

---

Personal Blog links

Blog

---

Individual statistics

Homepage page View Statistics:  

mongo-plus's Issues

请问有类似Monitor的针对不同事件触发的监视器吗？

类似qmgo的CommandMonitor，比如我想在qmgo里设置一个监听每次MongoDB成功和失败操作请求的监视器来打印日志，便于维护和定位问题，在qmgo里代码类似这样：

        // 创建cmdMonitor，用于打印日志
	startedCommands := sync.Map{} 
	cmdMonitor := &event.CommandMonitor{
		Started: func(_ context.Context, evt *event.CommandStartedEvent) {
			startedCommands.Store(evt.RequestID, evt.Command)
		},
		Succeeded: func(_ context.Context, evt *event.CommandSucceededEvent) {
			var commands bson.Raw
			v, ok := startedCommands.Load(evt.RequestID)
			if ok {
				commands = v.(bson.Raw)
			}
			defer mLog.Sync()
			mLog.Infof("\n[MongoDB] [%.3fms] [%v] %v \n", float64(evt.DurationNanos)/1e6, commands, evt.Reply)
		},
		Failed: func(_ context.Context, evt *event.CommandFailedEvent) {
			var commands bson.Raw
			v, ok := startedCommands.Load(evt.RequestID)
			if ok {
				commands = v.(bson.Raw)
			}
			defer mLog.Sync()
			mLog.Fatalf("\n[MongoDB] [%.3fms] [%v] \n %v \n", float64(evt.DurationNanos)/1e6, commands, evt.Failure)
		},
	}
	ops.SetMonitor(cmdMonitor)