You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
56 lines
1.8 KiB
56 lines
1.8 KiB
3 years ago
|
"use strict";
|
||
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||
|
|
exports._advanceClusterTime = exports.drainTimerQueue = exports.ServerType = exports.TopologyType = exports.STATE_CONNECTED = exports.STATE_CONNECTING = exports.STATE_CLOSED = exports.STATE_CLOSING = void 0;
|
||
|
|
const timers_1 = require("timers");
|
||
|
|
// shared state names
|
||
|
|
exports.STATE_CLOSING = 'closing';
|
||
|
|
exports.STATE_CLOSED = 'closed';
|
||
|
|
exports.STATE_CONNECTING = 'connecting';
|
||
|
|
exports.STATE_CONNECTED = 'connected';
|
||
|
|
/**
|
||
|
|
* An enumeration of topology types we know about
|
||
|
|
* @public
|
||
|
|
*/
|
||
|
|
exports.TopologyType = Object.freeze({
|
||
|
|
Single: 'Single',
|
||
|
|
ReplicaSetNoPrimary: 'ReplicaSetNoPrimary',
|
||
|
|
ReplicaSetWithPrimary: 'ReplicaSetWithPrimary',
|
||
|
|
Sharded: 'Sharded',
|
||
|
|
Unknown: 'Unknown',
|
||
|
|
LoadBalanced: 'LoadBalanced'
|
||
|
|
});
|
||
|
|
/**
|
||
|
|
* An enumeration of server types we know about
|
||
|
|
* @public
|
||
|
|
*/
|
||
|
|
exports.ServerType = Object.freeze({
|
||
|
|
Standalone: 'Standalone',
|
||
|
|
Mongos: 'Mongos',
|
||
|
|
PossiblePrimary: 'PossiblePrimary',
|
||
|
|
RSPrimary: 'RSPrimary',
|
||
|
|
RSSecondary: 'RSSecondary',
|
||
|
|
RSArbiter: 'RSArbiter',
|
||
|
|
RSOther: 'RSOther',
|
||
|
|
RSGhost: 'RSGhost',
|
||
|
|
Unknown: 'Unknown',
|
||
|
|
LoadBalancer: 'LoadBalancer'
|
||
|
|
});
|
||
|
|
/** @internal */
|
||
|
|
function drainTimerQueue(queue) {
|
||
|
|
queue.forEach(timers_1.clearTimeout);
|
||
|
|
queue.clear();
|
||
|
|
}
|
||
|
|
exports.drainTimerQueue = drainTimerQueue;
|
||
|
|
/** Shared function to determine clusterTime for a given topology or session */
|
||
|
|
function _advanceClusterTime(entity, $clusterTime) {
|
||
|
|
if (entity.clusterTime == null) {
|
||
|
|
entity.clusterTime = $clusterTime;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
if ($clusterTime.clusterTime.greaterThan(entity.clusterTime.clusterTime)) {
|
||
|
|
entity.clusterTime = $clusterTime;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
exports._advanceClusterTime = _advanceClusterTime;
|
||
|
|
//# sourceMappingURL=common.js.map
|