Spaces:
Runtime error
Runtime error
Download static/node_modules/mongodb/src/cmap/metrics.ts from kaab4321/NarrativeFlow: direct link, hf CLI and curl.
- Browser
- Download file 1.57 kB
-
https://huggingface.co/spaces/kaab4321/NarrativeFlow/resolve/main/static/node_modules/mongodb/src/cmap/metrics.ts
- Command line
-
hf download hf://spaces/kaab4321/NarrativeFlow/static/node_modules/mongodb/src/cmap/metrics.ts
-
curl -L -o metrics.ts https://huggingface.co/spaces/kaab4321/NarrativeFlow/resolve/main/static/node_modules/mongodb/src/cmap/metrics.ts
1.57 kB
| /** @internal */ | |
| export class ConnectionPoolMetrics { | |
| static readonly TXN = 'txn' as const; | |
| static readonly CURSOR = 'cursor' as const; | |
| static readonly OTHER = 'other' as const; | |
| txnConnections = 0; | |
| cursorConnections = 0; | |
| otherConnections = 0; | |
| /** | |
| * Mark a connection as pinned for a specific operation. | |
| */ | |
| markPinned(pinType: string): void { | |
| if (pinType === ConnectionPoolMetrics.TXN) { | |
| this.txnConnections += 1; | |
| } else if (pinType === ConnectionPoolMetrics.CURSOR) { | |
| this.cursorConnections += 1; | |
| } else { | |
| this.otherConnections += 1; | |
| } | |
| } | |
| /** | |
| * Unmark a connection as pinned for an operation. | |
| */ | |
| markUnpinned(pinType: string): void { | |
| if (pinType === ConnectionPoolMetrics.TXN) { | |
| this.txnConnections -= 1; | |
| } else if (pinType === ConnectionPoolMetrics.CURSOR) { | |
| this.cursorConnections -= 1; | |
| } else { | |
| this.otherConnections -= 1; | |
| } | |
| } | |
| /** | |
| * Return information about the cmap metrics as a string. | |
| */ | |
| info(maxPoolSize: number): string { | |
| return ( | |
| 'Timed out while checking out a connection from connection pool: ' + | |
| `maxPoolSize: ${maxPoolSize}, ` + | |
| `connections in use by cursors: ${this.cursorConnections}, ` + | |
| `connections in use by transactions: ${this.txnConnections}, ` + | |
| `connections in use by other operations: ${this.otherConnections}` | |
| ); | |
| } | |
| /** | |
| * Reset the metrics to the initial values. | |
| */ | |
| reset(): void { | |
| this.txnConnections = 0; | |
| this.cursorConnections = 0; | |
| this.otherConnections = 0; | |
| } | |
| } | |