Draft: feat: implement markDead and markAlive in Connection [CCI]

CHANGELOG.md

@@ -73,6 +73,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 - Removed unnecessary `data` argument when invoking `OpenSearchClientError` ([#421](https://github.com/opensearch-project/opensearch-js/pull/421))
 - Fixed typos in `ConnectionPool` ([#427](https://github.com/opensearch-project/opensearch-js/pull/427))
 - Added the solution for the possible error during yarn installation on Windows OS ([#435](https://github.com/opensearch-project/opensearch-js/issues/435))
+- Added `markAlive` and `markDead` methods to `Connection` ([#477](https://github.com/opensearch-project/opensearch-js/pull/477))
 
 ### Dependencies
 

USER_GUIDE.md

@@ -11,6 +11,7 @@
   - [Delete the document](#delete-the-document)
   - [Delete the index](#delete-the-index)
   - [Empty all Pool Connections](#empty-all-pool-connections)
+  - [Change Connection Status](#change-connection-status)
 
 ## Initializing a Client
 
@@ -265,3 +266,13 @@ pool.empty(() => {
   // Do something after emptying the pool
 });
 ```
+
+## Change Connection Status
+
+```javascript
+var connection = new Connection({
+  url: new URL('http://localhost:9200'),
+});
+connection.markDead();
+connection.markAlive();
+```

lib/Connection.js

@@ -204,6 +204,17 @@ class Connection {
     this._status = status;
   }
 
+  markAlive() {
+    this._status = Connection.statuses.ALIVE;
+    this.deadCount = 0;
+    this.resurrectTimeout = 0;
+  }
+
+  markDead() {
+    this._status = Connection.statuses.DEAD;
+    this.deadCount++;
+  }
+
   buildRequestObject(params) {
     const url = this.url;
     const request = {

test/unit/connection.test.js

@@ -1116,3 +1116,28 @@ test('Abort with a slow body', (t) => {
 
   setImmediate(() => request.abort());
 });
+
+test('Connection markDead', (t) => {
+  t.plan(2);
+
+  const connection = new Connection({
+    url: new URL('http://localhost:9200'),
+  });
+
+  connection.markDead();
+  t.equal(connection.status, Connection.statuses.DEAD);
+  t.equal(connection.deadCount, 1);
+});
+
+test('Connection markAlive', (t) => {
+  t.plan(2);
+
+  const connection = new Connection({
+    url: new URL('http://localhost:9200'),
+  });
+
+  connection.markDead();
+  connection.markAlive();
+  t.equal(connection.status, Connection.statuses.ALIVE);
+  t.equal(connection.deadCount, 0);
+});