[Non-Inclusive Language] Replace isDevClusterMaster with isDevCluster…

…Manager

As part of the meta issue opensearch-project/OpenSearch#2589 to track the plan and progress of applying inclusive naming across OpenSearch Repositories
Every repository that uses non-inclusive words should replace all the non-inclusive usages in the code base.

In this change we are replacing the instances of the terminology "isDevClusterMaster" with "isDevClusterManager".

Signed-off-by: manasvis <manasvis@amazon.com>

packages/osd-config/src/__mocks__/env.ts

@@ -54,5 +54,7 @@ export function getEnvOptions(options: DeepPartial<EnvOptions> = {}): EnvOptions
     },
     isDevClusterMaster:
       options.isDevClusterMaster !== undefined ? options.isDevClusterMaster : false,
+    isDevClusterManager:
+      options.isDevClusterManager !== undefined ? options.isDevClusterManager : false,
   };
 }

packages/osd-config/src/env.test.ts

@@ -59,6 +59,7 @@ test('correctly creates default environment in dev mode.', () => {
     getEnvOptions({
       configs: ['/test/cwd/config/opensearch_dashboards.yml'],
       isDevClusterMaster: true,
+      isDevClusterManager: true,
     })
   );
 

packages/osd-config/src/env.ts

@@ -36,7 +36,9 @@ import { PackageInfo, EnvironmentMode } from './types';
 export interface EnvOptions {
   configs: string[];
   cliArgs: CliArgs;
+  /** @deprecated use isDevClusterManager */
   isDevClusterMaster: boolean;
+  isDevClusterManager: boolean;
 }
 
 /** @internal */
@@ -110,11 +112,18 @@ export class Env {
   public readonly configs: readonly string[];
 
   /**
-   * Indicates that this OpenSearch Dashboards  instance is run as development Node Cluster master.
+   * Indicates that this OpenSearch Dashboards  instance is run as development Node master.
    * @internal
+   * @deprecated use isDevClusterManager
    */
   public readonly isDevClusterMaster: boolean;
 
+  /**
+   * Indicates that this OpenSearch Dashboards  instance is run as development Node Cluster manager.
+   * @internal
+   */
+  public readonly isDevClusterManager: boolean;
+
   /**
    * @internal
    */
@@ -138,6 +147,7 @@ export class Env {
     this.cliArgs = Object.freeze(options.cliArgs);
     this.configs = Object.freeze(options.configs);
     this.isDevClusterMaster = options.isDevClusterMaster;
+    this.isDevClusterManager = options.isDevClusterManager;
 
     const isDevMode = this.cliArgs.dev || this.cliArgs.envName === 'development';
     this.mode = Object.freeze<EnvironmentMode>({

src/core/server/bootstrap.ts

@@ -29,7 +29,7 @@
  */
 
 import chalk from 'chalk';
-import { isMaster } from 'cluster';
+import { isMaster as isClusterManager } from 'cluster';
 import { CliArgs, Env, RawConfigService } from './config';
 import { Root } from './root';
 import { CriticalError } from './errors';
@@ -82,7 +82,8 @@ export async function bootstrap({
   const env = Env.createDefault(REPO_ROOT, {
     configs,
     cliArgs,
-    isDevClusterMaster: isMaster && cliArgs.dev && features.isClusterModeSupported,
+    isDevClusterMaster: isClusterManager && cliArgs.dev && features.isClusterModeSupported,
+    isDevClusterManager: isClusterManager && cliArgs.dev && features.isClusterModeSupported,
   });
 
   const rawConfigService = new RawConfigService(env.configs, applyConfigOverrides);

src/core/server/http/http_service.test.ts

@@ -275,7 +275,13 @@ test('does not start http server if process is dev cluster master', async () =>
   const service = new HttpService({
     coreId,
     configService,
-    env: Env.createDefault(REPO_ROOT, getEnvOptions({ isDevClusterMaster: true })),
+    env: Env.createDefault(
+      REPO_ROOT,
+      getEnvOptions({
+        isDevClusterManager: true,
+        isDevClusterMaster: true,
+      })
+    ),
     logger,
   });
 

src/core/server/http/http_service.ts

@@ -169,7 +169,10 @@ export class HttpService
    * @internal
    * */
   private shouldListen(config: HttpConfig) {
-    return !this.coreContext.env.isDevClusterMaster && config.autoListen;
+    return (
+      !(this.coreContext.env.isDevClusterMaster || this.coreContext.env.isDevClusterManager) &&
+      config.autoListen
+    );
   }
 
   public async stop() {

src/core/server/legacy/legacy_service.test.ts

@@ -374,6 +374,7 @@ describe('once LegacyService is set up in `devClusterMaster` mode', () => {
         getEnvOptions({
           cliArgs: { silent: true, basePath: false },
           isDevClusterMaster: true,
+          isDevClusterManager: true,
         })
       ),
       logger,
@@ -403,6 +404,7 @@ describe('once LegacyService is set up in `devClusterMaster` mode', () => {
         getEnvOptions({
           cliArgs: { quiet: true, basePath: true },
           isDevClusterMaster: true,
+          isDevClusterManager: true,
         })
       ),
       logger,

src/core/server/legacy/legacy_service.ts

@@ -155,7 +155,7 @@ export class LegacyService implements CoreService {
     this.log.debug('starting legacy service');
 
     // Receive initial config and create osdServer/ClusterManager.
-    if (this.coreContext.env.isDevClusterMaster) {
+    if (this.coreContext.env.isDevClusterMaster || this.coreContext.env.isDevClusterManager) {
       await this.createClusterManager(this.legacyRawConfig!);
     } else {
       this.osdServer = await this.createOsdServer(

src/core/server/plugins/plugins_service.ts

@@ -137,7 +137,9 @@ export class PluginsService implements CoreService<PluginsServiceSetup, PluginsS
     const config = await this.config$.pipe(first()).toPromise();
 
     let contracts = new Map<PluginName, unknown>();
-    const initialize = config.initialize && !this.coreContext.env.isDevClusterMaster;
+    const initialize =
+      config.initialize &&
+      !(this.coreContext.env.isDevClusterMaster || this.coreContext.env.isDevClusterManager);
     if (initialize) {
       contracts = await this.pluginsSystem.setupPlugins(deps);
       this.registerPluginStaticDirs(deps);

src/core/test_helpers/osd_server.ts

@@ -91,6 +91,7 @@ export function createRootWithSettings(
       ...cliArgs,
     },
     isDevClusterMaster: false,
+    isDevClusterManager: false,
   });
 
   return new Root(

src/legacy/server/logging/rotate/index.ts

@@ -28,7 +28,7 @@
  * under the License.
  */
 
-import { isMaster, isWorker } from 'cluster';
+import { isMaster as isClusterManager, isWorker } from 'cluster';
 import { Server } from '@hapi/hapi';
 import { LogRotator } from './log_rotator';
 import { OpenSearchDashboardsConfig } from '../../osd_server';
@@ -43,7 +43,7 @@ export async function setupLoggingRotate(server: Server, config: OpenSearchDashb
 
   // We just want to start the logging rotate service once
   // and we choose to use the master (prod) or the worker server (dev)
-  if (!isMaster && isWorker && process.env.osdWorkerType !== 'server') {
+  if (!isClusterManager && isWorker && process.env.osdWorkerType !== 'server') {
     return;
   }
 

src/legacy/server/logging/rotate/log_rotator.ts

@@ -29,7 +29,7 @@
  */
 
 import * as chokidar from 'chokidar';
-import { isMaster } from 'cluster';
+import { isMaster as isClusterManager } from 'cluster';
 import fs from 'fs';
 import { Server } from '@hapi/hapi';
 import { throttle } from 'lodash';
@@ -359,7 +359,7 @@ export class LogRotator {
   }
 
   _sendReloadLogConfigSignal() {
-    if (isMaster) {
+    if (isClusterManager) {
       (process as NodeJS.EventEmitter).emit('SIGHUP');
       return;
     }