1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
// Copyright (C) MongoDB, Inc. 2017-present.
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License. You may obtain
// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
package unified
import (
"strings"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/event"
"go.mongodb.org/mongo-driver/mongo/description"
)
type monitoringEventType string
const (
commandStartedEvent monitoringEventType = "CommandStartedEvent"
commandSucceededEvent monitoringEventType = "CommandSucceededEvent"
commandFailedEvent monitoringEventType = "CommandFailedEvent"
poolCreatedEvent monitoringEventType = "PoolCreatedEvent"
poolReadyEvent monitoringEventType = "PoolReadyEvent"
poolClearedEvent monitoringEventType = "PoolClearedEvent"
poolClosedEvent monitoringEventType = "PoolClosedEvent"
connectionCreatedEvent monitoringEventType = "ConnectionCreatedEvent"
connectionReadyEvent monitoringEventType = "ConnectionReadyEvent"
connectionClosedEvent monitoringEventType = "ConnectionClosedEvent"
connectionCheckOutStartedEvent monitoringEventType = "ConnectionCheckOutStartedEvent"
connectionCheckOutFailedEvent monitoringEventType = "ConnectionCheckOutFailedEvent"
connectionCheckedOutEvent monitoringEventType = "ConnectionCheckedOutEvent"
connectionCheckedInEvent monitoringEventType = "ConnectionCheckedInEvent"
serverDescriptionChangedEvent monitoringEventType = "ServerDescriptionChangedEvent"
serverHeartbeatFailedEvent monitoringEventType = "ServerHeartbeatFailedEvent"
serverHeartbeatStartedEvent monitoringEventType = "ServerHeartbeatStartedEvent"
serverHeartbeatSucceededEvent monitoringEventType = "ServerHeartbeatSucceededEvent"
topologyDescriptionChangedEvent monitoringEventType = "TopologyDescriptionChangedEvent"
)
func monitoringEventTypeFromString(eventStr string) (monitoringEventType, bool) {
switch strings.ToLower(eventStr) {
case "commandstartedevent":
return commandStartedEvent, true
case "commandsucceededevent":
return commandSucceededEvent, true
case "commandfailedevent":
return commandFailedEvent, true
case "poolcreatedevent":
return poolCreatedEvent, true
case "poolreadyevent":
return poolReadyEvent, true
case "poolclearedevent":
return poolClearedEvent, true
case "poolclosedevent":
return poolClosedEvent, true
case "connectioncreatedevent":
return connectionCreatedEvent, true
case "connectionreadyevent":
return connectionReadyEvent, true
case "connectionclosedevent":
return connectionClosedEvent, true
case "connectioncheckoutstartedevent":
return connectionCheckOutStartedEvent, true
case "connectioncheckoutfailedevent":
return connectionCheckOutFailedEvent, true
case "connectioncheckedoutevent":
return connectionCheckedOutEvent, true
case "connectioncheckedinevent":
return connectionCheckedInEvent, true
case "serverdescriptionchangedevent":
return serverDescriptionChangedEvent, true
case "serverheartbeatfailedevent":
return serverHeartbeatFailedEvent, true
case "serverheartbeatstartedevent":
return serverHeartbeatStartedEvent, true
case "serverheartbeatsucceededevent":
return serverHeartbeatSucceededEvent, true
case "topologydescriptionchangedevent":
return topologyDescriptionChangedEvent, true
default:
return "", false
}
}
func monitoringEventTypeFromPoolEvent(evt *event.PoolEvent) monitoringEventType {
switch evt.Type {
case event.PoolCreated:
return poolCreatedEvent
case event.PoolReady:
return poolReadyEvent
case event.PoolCleared:
return poolClearedEvent
case event.PoolClosedEvent:
return poolClosedEvent
case event.ConnectionCreated:
return connectionCreatedEvent
case event.ConnectionReady:
return connectionReadyEvent
case event.ConnectionClosed:
return connectionClosedEvent
case event.GetStarted:
return connectionCheckOutStartedEvent
case event.GetFailed:
return connectionCheckOutFailedEvent
case event.GetSucceeded:
return connectionCheckedOutEvent
case event.ConnectionReturned:
return connectionCheckedInEvent
default:
return ""
}
}
// serverDescription represents a description of a server.
type serverDescription struct {
// Type is the type of the server in the description. Test runners MUST
// assert that the type in the published event matches this value.
Type string
}
// serverDescriptionChangedEventInfo represents an event generated when the server
// description changes.
type serverDescriptionChangedEventInfo struct {
// NewDescription corresponds to the server description as it was after
// the change that triggered this event.
NewDescription serverDescription
// PreviousDescription corresponds to the server description as it was
// before the change that triggered this event
PreviousDescription serverDescription
}
// newServerDescriptionChangedEventInfo returns a new serverDescriptionChangedEvent
// instance for the given event.
func newServerDescriptionChangedEventInfo(evt *event.ServerDescriptionChangedEvent) *serverDescriptionChangedEventInfo {
return &serverDescriptionChangedEventInfo{
NewDescription: serverDescription{
Type: evt.NewDescription.Kind.String(),
},
PreviousDescription: serverDescription{
Type: evt.PreviousDescription.Kind.String(),
},
}
}
// UnmarshalBSON unmarshals the event from BSON, used when trying to create the
// expected event from a unified spec test.
func (evt *serverDescriptionChangedEventInfo) UnmarshalBSON(data []byte) error {
if len(data) == 0 {
return nil
}
var raw bson.Raw
if err := bson.Unmarshal(data, &raw); err != nil {
return err
}
// Set the default case to "Unknown" for the NewDescription.Type field.
evt.NewDescription.Type = description.TopologyKind(description.Unknown).String()
// Lookup the previous description, if any.
if newDescription, err := raw.LookupErr("newDescription"); err == nil {
evt.NewDescription.Type = newDescription.Document().Lookup("type").StringValue()
}
// Set the default case to "Unknown" for the PreviousDescription.Type
// field.
evt.PreviousDescription.Type = description.TopologyKind(description.Unknown).String()
// Lookup the previous description, if any.
if previousDescription, err := raw.LookupErr("previousDescription"); err == nil {
evt.PreviousDescription.Type = previousDescription.Document().Lookup("type").StringValue()
}
return nil
}
|
