constants.js 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. exports.TOPOLOGY_EVENTS = exports.CMAP_EVENTS = exports.HEARTBEAT_EVENTS = exports.RESUME_TOKEN_CHANGED = exports.END = exports.CHANGE = exports.INIT = exports.MORE = exports.RESPONSE = exports.SERVER_HEARTBEAT_FAILED = exports.SERVER_HEARTBEAT_SUCCEEDED = exports.SERVER_HEARTBEAT_STARTED = exports.COMMAND_FAILED = exports.COMMAND_SUCCEEDED = exports.COMMAND_STARTED = exports.CLUSTER_TIME_RECEIVED = exports.CONNECTION_CHECKED_IN = exports.CONNECTION_CHECKED_OUT = exports.CONNECTION_CHECK_OUT_FAILED = exports.CONNECTION_CHECK_OUT_STARTED = exports.CONNECTION_CLOSED = exports.CONNECTION_READY = exports.CONNECTION_CREATED = exports.CONNECTION_POOL_READY = exports.CONNECTION_POOL_CLEARED = exports.CONNECTION_POOL_CLOSED = exports.CONNECTION_POOL_CREATED = exports.TOPOLOGY_DESCRIPTION_CHANGED = exports.TOPOLOGY_CLOSED = exports.TOPOLOGY_OPENING = exports.SERVER_DESCRIPTION_CHANGED = exports.SERVER_CLOSED = exports.SERVER_OPENING = exports.DESCRIPTION_RECEIVED = exports.UNPINNED = exports.PINNED = exports.MESSAGE = exports.ENDED = exports.CLOSED = exports.CONNECT = exports.OPEN = exports.CLOSE = exports.TIMEOUT = exports.ERROR = exports.SYSTEM_JS_COLLECTION = exports.SYSTEM_COMMAND_COLLECTION = exports.SYSTEM_USER_COLLECTION = exports.SYSTEM_PROFILE_COLLECTION = exports.SYSTEM_INDEX_COLLECTION = exports.SYSTEM_NAMESPACE_COLLECTION = void 0;
  4. exports.LEGACY_HELLO_COMMAND_CAMEL_CASE = exports.LEGACY_HELLO_COMMAND = exports.MONGO_CLIENT_EVENTS = exports.LOCAL_SERVER_EVENTS = exports.SERVER_RELAY_EVENTS = exports.APM_EVENTS = void 0;
  5. exports.SYSTEM_NAMESPACE_COLLECTION = 'system.namespaces';
  6. exports.SYSTEM_INDEX_COLLECTION = 'system.indexes';
  7. exports.SYSTEM_PROFILE_COLLECTION = 'system.profile';
  8. exports.SYSTEM_USER_COLLECTION = 'system.users';
  9. exports.SYSTEM_COMMAND_COLLECTION = '$cmd';
  10. exports.SYSTEM_JS_COLLECTION = 'system.js';
  11. // events
  12. exports.ERROR = 'error';
  13. exports.TIMEOUT = 'timeout';
  14. exports.CLOSE = 'close';
  15. exports.OPEN = 'open';
  16. exports.CONNECT = 'connect';
  17. exports.CLOSED = 'closed';
  18. exports.ENDED = 'ended';
  19. exports.MESSAGE = 'message';
  20. exports.PINNED = 'pinned';
  21. exports.UNPINNED = 'unpinned';
  22. exports.DESCRIPTION_RECEIVED = 'descriptionReceived';
  23. exports.SERVER_OPENING = 'serverOpening';
  24. exports.SERVER_CLOSED = 'serverClosed';
  25. exports.SERVER_DESCRIPTION_CHANGED = 'serverDescriptionChanged';
  26. exports.TOPOLOGY_OPENING = 'topologyOpening';
  27. exports.TOPOLOGY_CLOSED = 'topologyClosed';
  28. exports.TOPOLOGY_DESCRIPTION_CHANGED = 'topologyDescriptionChanged';
  29. /** @internal */
  30. exports.CONNECTION_POOL_CREATED = 'connectionPoolCreated';
  31. /** @internal */
  32. exports.CONNECTION_POOL_CLOSED = 'connectionPoolClosed';
  33. /** @internal */
  34. exports.CONNECTION_POOL_CLEARED = 'connectionPoolCleared';
  35. /** @internal */
  36. exports.CONNECTION_POOL_READY = 'connectionPoolReady';
  37. /** @internal */
  38. exports.CONNECTION_CREATED = 'connectionCreated';
  39. /** @internal */
  40. exports.CONNECTION_READY = 'connectionReady';
  41. /** @internal */
  42. exports.CONNECTION_CLOSED = 'connectionClosed';
  43. /** @internal */
  44. exports.CONNECTION_CHECK_OUT_STARTED = 'connectionCheckOutStarted';
  45. /** @internal */
  46. exports.CONNECTION_CHECK_OUT_FAILED = 'connectionCheckOutFailed';
  47. /** @internal */
  48. exports.CONNECTION_CHECKED_OUT = 'connectionCheckedOut';
  49. /** @internal */
  50. exports.CONNECTION_CHECKED_IN = 'connectionCheckedIn';
  51. exports.CLUSTER_TIME_RECEIVED = 'clusterTimeReceived';
  52. exports.COMMAND_STARTED = 'commandStarted';
  53. exports.COMMAND_SUCCEEDED = 'commandSucceeded';
  54. exports.COMMAND_FAILED = 'commandFailed';
  55. exports.SERVER_HEARTBEAT_STARTED = 'serverHeartbeatStarted';
  56. exports.SERVER_HEARTBEAT_SUCCEEDED = 'serverHeartbeatSucceeded';
  57. exports.SERVER_HEARTBEAT_FAILED = 'serverHeartbeatFailed';
  58. exports.RESPONSE = 'response';
  59. exports.MORE = 'more';
  60. exports.INIT = 'init';
  61. exports.CHANGE = 'change';
  62. exports.END = 'end';
  63. exports.RESUME_TOKEN_CHANGED = 'resumeTokenChanged';
  64. /** @public */
  65. exports.HEARTBEAT_EVENTS = Object.freeze([
  66. exports.SERVER_HEARTBEAT_STARTED,
  67. exports.SERVER_HEARTBEAT_SUCCEEDED,
  68. exports.SERVER_HEARTBEAT_FAILED
  69. ]);
  70. /** @public */
  71. exports.CMAP_EVENTS = Object.freeze([
  72. exports.CONNECTION_POOL_CREATED,
  73. exports.CONNECTION_POOL_READY,
  74. exports.CONNECTION_POOL_CLEARED,
  75. exports.CONNECTION_POOL_CLOSED,
  76. exports.CONNECTION_CREATED,
  77. exports.CONNECTION_READY,
  78. exports.CONNECTION_CLOSED,
  79. exports.CONNECTION_CHECK_OUT_STARTED,
  80. exports.CONNECTION_CHECK_OUT_FAILED,
  81. exports.CONNECTION_CHECKED_OUT,
  82. exports.CONNECTION_CHECKED_IN
  83. ]);
  84. /** @public */
  85. exports.TOPOLOGY_EVENTS = Object.freeze([
  86. exports.SERVER_OPENING,
  87. exports.SERVER_CLOSED,
  88. exports.SERVER_DESCRIPTION_CHANGED,
  89. exports.TOPOLOGY_OPENING,
  90. exports.TOPOLOGY_CLOSED,
  91. exports.TOPOLOGY_DESCRIPTION_CHANGED,
  92. exports.ERROR,
  93. exports.TIMEOUT,
  94. exports.CLOSE
  95. ]);
  96. /** @public */
  97. exports.APM_EVENTS = Object.freeze([
  98. exports.COMMAND_STARTED,
  99. exports.COMMAND_SUCCEEDED,
  100. exports.COMMAND_FAILED
  101. ]);
  102. /**
  103. * All events that we relay to the `Topology`
  104. * @internal
  105. */
  106. exports.SERVER_RELAY_EVENTS = Object.freeze([
  107. exports.SERVER_HEARTBEAT_STARTED,
  108. exports.SERVER_HEARTBEAT_SUCCEEDED,
  109. exports.SERVER_HEARTBEAT_FAILED,
  110. exports.COMMAND_STARTED,
  111. exports.COMMAND_SUCCEEDED,
  112. exports.COMMAND_FAILED,
  113. ...exports.CMAP_EVENTS
  114. ]);
  115. /**
  116. * All events we listen to from `Server` instances, but do not forward to the client
  117. * @internal
  118. */
  119. exports.LOCAL_SERVER_EVENTS = Object.freeze([
  120. exports.CONNECT,
  121. exports.DESCRIPTION_RECEIVED,
  122. exports.CLOSED,
  123. exports.ENDED
  124. ]);
  125. /** @public */
  126. exports.MONGO_CLIENT_EVENTS = Object.freeze([
  127. ...exports.CMAP_EVENTS,
  128. ...exports.APM_EVENTS,
  129. ...exports.TOPOLOGY_EVENTS,
  130. ...exports.HEARTBEAT_EVENTS
  131. ]);
  132. /**
  133. * @internal
  134. * The legacy hello command that was deprecated in MongoDB 5.0.
  135. */
  136. exports.LEGACY_HELLO_COMMAND = 'ismaster';
  137. /**
  138. * @internal
  139. * The legacy hello command that was deprecated in MongoDB 5.0.
  140. */
  141. exports.LEGACY_HELLO_COMMAND_CAMEL_CASE = 'isMaster';
  142. //# sourceMappingURL=constants.js.map