Configuration for Wazuh monitoring shards and replicas

config.yml

@@ -88,3 +88,6 @@
 # Default: 3600 (s)
 #wazuh.monitoring.frequency: 3600
 #
+# Configure wazuh-monitoring-3.x-* indices shards and replicas.
+#wazuh.monitoring.shards: 5
+#wazuh.monitoring.replicas: 1

public/services/resolves/get-config.js

@@ -28,12 +28,14 @@ export default async ($q, genericReq, errorHandler, wazuhConfig) => {
         timeout                : 8000,
         'wazuh.shards'         : 1,
         'wazuh.replicas'       : 1,
+        'wazuh-version.shards'  : 1,
+        'wazuh-version.replicas': 1,   
         'ip.selector'          : true,
         'xpack.rbac.enabled'   : true,
-        'wazuh.wazuh-version.shards'  : 1,
-        'wazuh.wazuh-version.shards.replicas': 1,            
         'wazuh.monitoring.enabled'  : true,
-        'wazuh.monitoring.frequency': 3600
+        'wazuh.monitoring.frequency': 3600,
+        'wazuh.monitoring.shards'  : 5,
+        'wazuh.monitoring.replicas': 1
     };
 
     try {

server/lib/elastic-wrapper.js

@@ -664,11 +664,18 @@ export default class ElasticWrapper {
          }
     }
 
-    async createIndexByName(name) {
+    async createIndexByName(name, configuration = null) {
         try {
             if(!name) return Promise.reject(new Error('No valid name given'));
+
+            const raw = { 
+                index: name,
+                body: configuration
+            }
+
+            if(!configuration) delete raw.body;
 
-            const data = await this.elasticRequest.callWithInternalUser('indices.create', { index: name });
+            const data = await this.elasticRequest.callWithInternalUser('indices.create', raw);
 
             return data;
 

server/monitoring.js

@@ -234,7 +234,25 @@ export default (server, options) => {
     const createIndex = async (todayIndex,clusterName) => {
         try {
             if(!ENABLED) return;
-            await wzWrapper.createIndexByName(todayIndex);
+            const configFile = getConfiguration();
+
+            const shards = configFile && typeof configFile['wazuh.monitoring.shards'] !== 'undefined' ?
+                           configFile['wazuh.monitoring.shards'] : 5;
+
+            const replicas = configFile && typeof configFile['wazuh.monitoring.replicas'] !== 'undefined' ?
+                             configFile['wazuh.monitoring.replicas'] : 1;
+
+            const configuration = {
+                settings: {
+                    index: {
+                        number_of_shards: shards,
+                        number_of_replicas: replicas
+                    }
+                }
+            };
+
+            await wzWrapper.createIndexByName(todayIndex, configuration);
+
             log('[monitoring][createIndex]', 'Successfully created today index.', 'info');
             server.log([blueWazuh, 'monitoring', 'info'], 'Successfully created today index.');
             await insertDocument(todayIndex,clusterName);