S3C supports having different queueProcessor probeserver configuratio…

extensions/replication/ReplicationConfigValidator.js

@@ -1,7 +1,7 @@
 const fs = require('fs');
 const joi = require('joi');
 const { hostPortJoi, transportJoi, bootstrapListJoi, adminCredsJoi,
-        retryParamsJoi, probeServerJoi } =
+        retryParamsJoi, probeServerJoi, probeServerPerSite } =
     require('../../lib/config/configItems.joi');
 
 const qpRetryJoi = joi.object({
@@ -71,7 +71,10 @@ const joiSchema = joi.object({
         concurrency: joi.number().greater(0).default(10),
         mpuPartsConcurrency: joi.number().greater(0).default(10),
         minMPUSizeMB: joi.number().greater(0).default(20),
-        probeServer: probeServerJoi.default(),
+        probeServer: joi.alternatives().try(
+            probeServerJoi,
+            probeServerPerSite
+        ).default({ bindAddress: 'localhost', port: '' }),
         circuitBreaker: joi.object().optional(),
     }).required(),
     replicationStatusProcessor: {

extensions/replication/queueProcessor/task.js

@@ -239,8 +239,28 @@
             }
         });
 
+        /**
+         * Get probe config will pull the configuration for the probe server based on
+         * the provided site key, and if the probe server config is not an array, it will
+         * return the global probe server config.
+         *
+         *  Get the probe server config for the first site in the site names list,
+         *  as if the probeConfig is an array there is only one element in site names
+         *
+         * @param {Object} queueProcessorConfig - Configuration of the queue processor that
+         *      holds the probe server configs for all sites
+         * @param {Array<String>} siteNames - List of site names
+         * @returns {ProbeServerConfig} Config for site or global config
+         */
+        function getProbeConfig(queueProcessorConfig, siteNames) {
+            if (Array.isArray(queueProcessorConfig.probeServer) && siteNames[0]) {
+                return queueProcessorConfig.probeServer.filter(probe => probe.site === siteNames[0])[0];
+            }
+            return queueProcessorConfig.probeServer;
+        }
+
         startProbeServer(
-            repConfig.queueProcessor.probeServer,
+            getProbeConfig(repConfig.queueProcessor, siteNames),
             (err, probeServer) => {
                 if (err) {
                     log.fatal('error creating probe server', {

lib/config/configItems.joi.js

@@ -112,6 +112,14 @@ const probeServerJoi = joi.object({
     port: joi.number().required(),
 });
 
+const probeServerPerSite = joi.array().items(
+    joi.object({
+        bindAddress: joi.string().default('localhost'),
+        port: joi.number().required(),
+        site: joi.string().required()
+    })
+);
+
 const mongoJoi = joi.object({
     replicaSetHosts: joi.string().default('localhost:27017'),
     logName: joi.string().default('s3-recordlog'),
@@ -161,6 +169,7 @@ module.exports = {
     retryParamsJoi,
     certFilePathsJoi,
     probeServerJoi,
+    probeServerPerSite,
     stsConfigJoi,
     mongoJoi,
     qpKafkaJoi,