chore: remove apm instrumentation decoration

NODE-3160

Author: durran

src/apm.ts

@@ -1,180 +1,8 @@
 import { GetMore, KillCursor, Msg, WriteProtocolMessageType } from './commands';
 import { calculateDurationInMs, deepCopy } from '../utils';
-import { ConnectionPool, ConnectionPoolOptions } from './connection_pool';
+import type { ConnectionPool } from './connection_pool';
 import type { Connection } from './connection';
 import type { Document } from '../bson';
-import type { AnyError } from '../error';
-
-/**
- * The base export class for all monitoring events published from the connection pool
- * @public
- * @category Event
- */
-export class ConnectionPoolMonitoringEvent {
-  /** A timestamp when the event was created  */
-  time: Date;
-  /** The address (host/port pair) of the pool */
-  address: string;
-
-  constructor(pool: ConnectionPool) {
-    this.time = new Date();
-    this.address = pool.address;
-  }
-}
-
-/**
- * An event published when a connection pool is created
- * @public
- * @category Event
- */
-export class ConnectionPoolCreatedEvent extends ConnectionPoolMonitoringEvent {
-  /** The options used to create this connection pool */
-  options?: ConnectionPoolOptions;
-
-  constructor(pool: ConnectionPool) {
-    super(pool);
-    this.options = pool.options;
-  }
-}
-
-/**
- * An event published when a connection pool is closed
- * @public
- * @category Event
- */
-export class ConnectionPoolClosedEvent extends ConnectionPoolMonitoringEvent {
-  constructor(pool: ConnectionPool) {
-    super(pool);
-  }
-}
-
-/**
- * An event published when a connection pool creates a new connection
- * @public
- * @category Event
- */
-export class ConnectionCreatedEvent extends ConnectionPoolMonitoringEvent {
-  /** A monotonically increasing, per-pool id for the newly created connection */
-  connectionId: number | '<monitor>';
-
-  constructor(pool: ConnectionPool, connection: Connection) {
-    super(pool);
-    this.connectionId = connection.id;
-  }
-}
-
-/**
- * An event published when a connection is ready for use
- * @public
- * @category Event
- */
-export class ConnectionReadyEvent extends ConnectionPoolMonitoringEvent {
-  /** The id of the connection */
-  connectionId: number | '<monitor>';
-
-  constructor(pool: ConnectionPool, connection: Connection) {
-    super(pool);
-    this.connectionId = connection.id;
-  }
-}
-
-/**
- * An event published when a connection is closed
- * @public
- * @category Event
- */
-export class ConnectionClosedEvent extends ConnectionPoolMonitoringEvent {
-  /** The id of the connection */
-  connectionId: number | '<monitor>';
-  /** The reason the connection was closed */
-  reason: string;
-
-  constructor(pool: ConnectionPool, connection: Connection, reason: string) {
-    super(pool);
-    this.connectionId = connection.id;
-    this.reason = reason || 'unknown';
-  }
-}
-
-/**
- * An event published when a request to check a connection out begins
- * @public
- * @category Event
- */
-export class ConnectionCheckOutStartedEvent extends ConnectionPoolMonitoringEvent {
-  constructor(pool: ConnectionPool) {
-    super(pool);
-  }
-}
-
-/**
- * An event published when a request to check a connection out fails
- * @public
- * @category Event
- */
-export class ConnectionCheckOutFailedEvent extends ConnectionPoolMonitoringEvent {
-  /** The reason the attempt to check out failed */
-  reason: AnyError | string;
-
-  constructor(pool: ConnectionPool, reason: AnyError | string) {
-    super(pool);
-    this.reason = reason;
-  }
-}
-
-/**
- * An event published when a connection is checked out of the connection pool
- * @public
- * @category Event
- */
-export class ConnectionCheckedOutEvent extends ConnectionPoolMonitoringEvent {
-  /** The id of the connection */
-  connectionId: number | '<monitor>';
-
-  constructor(pool: ConnectionPool, connection: Connection) {
-    super(pool);
-    this.connectionId = connection.id;
-  }
-}
-
-/**
- * An event published when a connection is checked into the connection pool
- * @public
- * @category Event
- */
-export class ConnectionCheckedInEvent extends ConnectionPoolMonitoringEvent {
-  /** The id of the connection */
-  connectionId: number | '<monitor>';
-
-  constructor(pool: ConnectionPool, connection: Connection) {
-    super(pool);
-    this.connectionId = connection.id;
-  }
-}
-
-/**
- * An event published when a connection pool is cleared
- * @public
- * @category Event
- */
-export class ConnectionPoolClearedEvent extends ConnectionPoolMonitoringEvent {
-  constructor(pool: ConnectionPool) {
-    super(pool);
-  }
-}
-
-export const CMAP_EVENT_NAMES = [
-  ConnectionPool.CONNECTION_POOL_CREATED,
-  ConnectionPool.CONNECTION_POOL_CLOSED,
-  ConnectionPool.CONNECTION_CREATED,
-  ConnectionPool.CONNECTION_READY,
-  ConnectionPool.CONNECTION_CLOSED,
-  ConnectionPool.CONNECTION_CHECK_OUT_STARTED,
-  ConnectionPool.CONNECTION_CHECK_OUT_FAILED,
-  ConnectionPool.CONNECTION_CHECKED_OUT,
-  ConnectionPool.CONNECTION_CHECKED_IN,
-  ConnectionPool.CONNECTION_POOL_CLEARED
-] as const;
 
 /**
  * An event indicating the start of a given

src/cmap/events.ts renamed to src/cmap/command_monitoring_events.ts

@@ -1,7 +1,11 @@
 import { EventEmitter } from 'events';
 import { MessageStream, OperationDescription } from './message_stream';
 import { StreamDescription, StreamDescriptionOptions } from './stream_description';
-import { CommandStartedEvent, CommandFailedEvent, CommandSucceededEvent } from './events';
+import {
+  CommandStartedEvent,
+  CommandFailedEvent,
+  CommandSucceededEvent
+} from './command_monitoring_events';
 import { applySession, ClientSession, updateSessionFromResponse } from '../sessions';
 import {
   uuidV4,

src/cmap/connection.ts

@@ -17,7 +17,7 @@ import {
   ConnectionCheckedOutEvent,
   ConnectionCheckedInEvent,
   ConnectionPoolClearedEvent
-} from './events';
+} from './connection_pool_events';
 
 const kLogger = Symbol('logger');
 const kConnections = Symbol('connections');
@@ -522,6 +522,19 @@ function processWaitQueue(pool: ConnectionPool) {
   }
 }
 
+export const CMAP_EVENT_NAMES = [
+  ConnectionPool.CONNECTION_POOL_CREATED,
+  ConnectionPool.CONNECTION_POOL_CLOSED,
+  ConnectionPool.CONNECTION_CREATED,
+  ConnectionPool.CONNECTION_READY,
+  ConnectionPool.CONNECTION_CLOSED,
+  ConnectionPool.CONNECTION_CHECK_OUT_STARTED,
+  ConnectionPool.CONNECTION_CHECK_OUT_FAILED,
+  ConnectionPool.CONNECTION_CHECKED_OUT,
+  ConnectionPool.CONNECTION_CHECKED_IN,
+  ConnectionPool.CONNECTION_POOL_CLEARED
+] as const;
+
 /**
  * A callback provided to `withConnection`
  * @public