feat(NODE-5169): Implement emergency logger

src/cmap/command_monitoring_events.ts

@@ -50,6 +50,10 @@ export class CommandStartedEvent {
   get hasServiceId(): boolean {
     return !!this.serviceId;
   }
+
+  get name(): string {
+    return 'CommandStarted';
+  }
 }
 
 /**
@@ -98,6 +102,10 @@ export class CommandSucceededEvent {
   get hasServiceId(): boolean {
     return !!this.serviceId;
   }
+
+  get name(): string {
+    return 'CommandSucceeded';
+  }
 }
 
 /**
@@ -147,6 +155,10 @@ export class CommandFailedEvent {
   get hasServiceId(): boolean {
     return !!this.serviceId;
   }
+
+  get name(): string {
+    return 'CommandFailed';
+  }
 }
 
 /**

src/cmap/connection_pool_events.ts

@@ -29,11 +29,18 @@ export class ConnectionPoolMonitoringEvent {
 export class ConnectionPoolCreatedEvent extends ConnectionPoolMonitoringEvent {
   /** The options used to create this connection pool */
   options?: ConnectionPoolOptions;
+  /** The size of the ConnectionPool's waitQueue */
+  waitQueueSize: number;
 
   /** @internal */
   constructor(pool: ConnectionPool) {
     super(pool);
     this.options = pool.options;
+    this.waitQueueSize = pool.waitQueueSize;
+  }
+
+  get name(): string {
+    return 'ConnectionPoolCreated';
   }
 }
 
@@ -47,6 +54,9 @@ export class ConnectionPoolReadyEvent extends ConnectionPoolMonitoringEvent {
   constructor(pool: ConnectionPool) {
     super(pool);
   }
+  get name(): string {
+    return 'ConnectionPoolReady';
+  }
 }
 
 /**
@@ -59,6 +69,9 @@ export class ConnectionPoolClosedEvent extends ConnectionPoolMonitoringEvent {
   constructor(pool: ConnectionPool) {
     super(pool);
   }
+  get name(): string {
+    return 'ConnectionPoolClosed';
+  }
 }
 
 /**
@@ -75,6 +88,9 @@ export class ConnectionCreatedEvent extends ConnectionPoolMonitoringEvent {
     super(pool);
     this.connectionId = connection.id;
   }
+  get name(): string {
+    return 'ConnectionCreated';
+  }
 }
 
 /**
@@ -91,6 +107,9 @@ export class ConnectionReadyEvent extends ConnectionPoolMonitoringEvent {
     super(pool);
     this.connectionId = connection.id;
   }
+  get name(): string {
+    return 'ConnectionReady';
+  }
 }
 
 /**
@@ -116,6 +135,9 @@ export class ConnectionClosedEvent extends ConnectionPoolMonitoringEvent {
     this.reason = reason || 'unknown';
     this.serviceId = connection.serviceId;
   }
+  get name(): string {
+    return 'ConnectionClosed';
+  }
 }
 
 /**
@@ -128,6 +150,9 @@ export class ConnectionCheckOutStartedEvent extends ConnectionPoolMonitoringEven
   constructor(pool: ConnectionPool) {
     super(pool);
   }
+  get name(): string {
+    return 'ConnectionCheckOutStarted';
+  }
 }
 
 /**
@@ -144,6 +169,9 @@ export class ConnectionCheckOutFailedEvent extends ConnectionPoolMonitoringEvent
     super(pool);
     this.reason = reason;
   }
+  get name(): string {
+    return 'ConnectionCheckOutFailed';
+  }
 }
 
 /**
@@ -160,6 +188,9 @@ export class ConnectionCheckedOutEvent extends ConnectionPoolMonitoringEvent {
     super(pool);
     this.connectionId = connection.id;
   }
+  get name(): string {
+    return 'ConnectionCheckedOut';
+  }
 }
 
 /**
@@ -176,6 +207,9 @@ export class ConnectionCheckedInEvent extends ConnectionPoolMonitoringEvent {
     super(pool);
     this.connectionId = connection.id;
   }
+  get name(): string {
+    return 'ConnectionCheckedIn';
+  }
 }
 
 /**
@@ -198,4 +232,8 @@ export class ConnectionPoolClearedEvent extends ConnectionPoolMonitoringEvent {
     this.serviceId = options.serviceId;
     this.interruptInUseConnections = options.interruptInUseConnections;
   }
+
+  get name(): string {
+    return 'ConnectionPoolCleared';
+  }
 }