@@ -348,108 +348,133 @@ public struct ServerHeartbeatFailedEvent: MongoEvent, InitializableFromOpaquePoi
348348
349349/// A callback that will be set for "command started" events if the user enables command monitoring.
350350private func commandStarted( _event: OpaquePointer ? ) {
351- postNotification ( type: CommandStartedEvent . self,
352- _event: _event,
353- contextFunc: mongoc_apm_command_started_get_context)
351+ postNotification (
352+ type: CommandStartedEvent . self,
353+ _event: _event,
354+ contextFunc: mongoc_apm_command_started_get_context
355+ )
354356}
355357
356358/// A callback that will be set for "command succeeded" events if the user enables command monitoring.
357359private func commandSucceeded( _event: OpaquePointer ? ) {
358- postNotification ( type: CommandSucceededEvent . self,
359- _event: _event,
360- contextFunc: mongoc_apm_command_succeeded_get_context)
360+ postNotification (
361+ type: CommandSucceededEvent . self,
362+ _event: _event,
363+ contextFunc: mongoc_apm_command_succeeded_get_context
364+ )
361365}
362366
363367/// A callback that will be set for "command failed" events if the user enables command monitoring.
364368private func commandFailed( _event: OpaquePointer ? ) {
365- postNotification ( type: CommandFailedEvent . self,
366- _event: _event,
367- contextFunc: mongoc_apm_command_failed_get_context)
369+ postNotification (
370+ type: CommandFailedEvent . self,
371+ _event: _event,
372+ contextFunc: mongoc_apm_command_failed_get_context
373+ )
368374}
369375
370376/// A callback that will be set for "server description changed" events if the user enables server monitoring.
371377private func serverDescriptionChanged( _event: OpaquePointer ? ) {
372- postNotification ( type: ServerDescriptionChangedEvent . self,
373- _event: _event,
374- contextFunc: mongoc_apm_server_changed_get_context)
378+ postNotification (
379+ type: ServerDescriptionChangedEvent . self,
380+ _event: _event,
381+ contextFunc: mongoc_apm_server_changed_get_context
382+ )
375383}
376384
377385/// A callback that will be set for "server opening" events if the user enables server monitoring.
378386private func serverOpening( _event: OpaquePointer ? ) {
379- postNotification ( type: ServerOpeningEvent . self,
380- _event: _event,
381- contextFunc: mongoc_apm_server_opening_get_context)
387+ postNotification (
388+ type: ServerOpeningEvent . self,
389+ _event: _event,
390+ contextFunc: mongoc_apm_server_opening_get_context
391+ )
382392}
383393
384394/// A callback that will be set for "server closed" events if the user enables server monitoring.
385395private func serverClosed( _event: OpaquePointer ? ) {
386- postNotification ( type: ServerClosedEvent . self,
387- _event: _event,
388- contextFunc: mongoc_apm_server_closed_get_context)
396+ postNotification (
397+ type: ServerClosedEvent . self,
398+ _event: _event,
399+ contextFunc: mongoc_apm_server_closed_get_context
400+ )
389401}
390402
391403/// A callback that will be set for "topology description changed" events if the user enables server monitoring.
392404private func topologyDescriptionChanged( _event: OpaquePointer ? ) {
393- postNotification ( type: TopologyDescriptionChangedEvent . self,
394- _event: _event,
395- contextFunc: mongoc_apm_topology_changed_get_context)
405+ postNotification (
406+ type: TopologyDescriptionChangedEvent . self,
407+ _event: _event,
408+ contextFunc: mongoc_apm_topology_changed_get_context
409+ )
396410}
397411
398412/// A callback that will be set for "topology opening" events if the user enables server monitoring.
399413private func topologyOpening( _event: OpaquePointer ? ) {
400- postNotification ( type: TopologyOpeningEvent . self,
401- _event: _event,
402- contextFunc: mongoc_apm_topology_opening_get_context)
414+ postNotification (
415+ type: TopologyOpeningEvent . self,
416+ _event: _event,
417+ contextFunc: mongoc_apm_topology_opening_get_context
418+ )
403419}
404420
405421/// A callback that will be set for "topology closed" events if the user enables server monitoring.
406422private func topologyClosed( _event: OpaquePointer ? ) {
407- postNotification ( type: TopologyClosedEvent . self,
408- _event: _event,
409- contextFunc: mongoc_apm_topology_closed_get_context)
423+ postNotification (
424+ type: TopologyClosedEvent . self,
425+ _event: _event,
426+ contextFunc: mongoc_apm_topology_closed_get_context
427+ )
410428}
411429
412430/// A callback that will be set for "server heartbeat started" events if the user enables server monitoring.
413431private func serverHeartbeatStarted( _event: OpaquePointer ? ) {
414- postNotification ( type: ServerHeartbeatStartedEvent . self,
415- _event: _event,
416- contextFunc: mongoc_apm_server_heartbeat_started_get_context)
432+ postNotification (
433+ type: ServerHeartbeatStartedEvent . self,
434+ _event: _event,
435+ contextFunc: mongoc_apm_server_heartbeat_started_get_context
436+ )
417437}
418438
419439/// A callback that will be set for "server heartbeat succeeded" events if the user enables server monitoring.
420440private func serverHeartbeatSucceeded( _event: OpaquePointer ? ) {
421- postNotification ( type: ServerHeartbeatSucceededEvent . self,
422- _event: _event,
423- contextFunc: mongoc_apm_server_heartbeat_succeeded_get_context)
441+ postNotification (
442+ type: ServerHeartbeatSucceededEvent . self,
443+ _event: _event,
444+ contextFunc: mongoc_apm_server_heartbeat_succeeded_get_context
445+ )
424446}
425447
426448/// A callback that will be set for "server heartbeat failed" events if the user enables server monitoring.
427449private func serverHeartbeatFailed( _event: OpaquePointer ? ) {
428- postNotification ( type: ServerHeartbeatFailedEvent . self,
429- _event: _event,
430- contextFunc: mongoc_apm_server_heartbeat_failed_get_context)
450+ postNotification (
451+ type: ServerHeartbeatFailedEvent . self,
452+ _event: _event,
453+ contextFunc: mongoc_apm_server_heartbeat_failed_get_context
454+ )
431455}
432456
433457/// Posts a Notification with the specified name, containing an event of type T generated using the provided _event
434458/// and context function.
435- private func postNotification< T: MongoEvent > ( type: T . Type ,
436- _event: OpaquePointer ? ,
437- contextFunc: ( OpaquePointer ) -> UnsafeMutableRawPointer ?
438- ) where T: InitializableFromOpaquePointer {
459+ private func postNotification< T: MongoEvent > (
460+ type: T . Type ,
461+ _event: OpaquePointer ? ,
462+ contextFunc: ( OpaquePointer ) -> UnsafeMutableRawPointer ?
463+ ) where T: InitializableFromOpaquePointer {
439464 guard let event = _event else {
440465 fatalError ( " Missing event pointer for \( type) " )
441466 }
442467
443468 let eventStruct = type. init ( event)
444469
445- // TODO SWIFT-524: remove workaround for CDRIVER-3256
470+ // TODO: SWIFT-524: remove workaround for CDRIVER-3256
446471 if let tdChanged = eventStruct as? TopologyDescriptionChangedEvent ,
447- tdChanged. previousDescription == tdChanged. newDescription {
472+ tdChanged. previousDescription == tdChanged. newDescription {
448473 return
449474 }
450475
451476 if let sdChanged = eventStruct as? ServerDescriptionChangedEvent ,
452- sdChanged. previousDescription == sdChanged. newDescription {
477+ sdChanged. previousDescription == sdChanged. newDescription {
453478 return
454479 }
455480
0 commit comments