Add txObservers and make use of TXN Stats Collector

Signed-off-by: [email protected] <[email protected]>
hyperledger-caliper · Aug 3, 2020 · 479d789 · 479d789
1 parent c84d59f
commit 479d789
Show file tree

Hide file tree

Showing 73 changed files with 2,900 additions and 3,001 deletions.
diff --git a/packages/caliper-cli/lib/launch/lib/launchWorker.js b/packages/caliper-cli/lib/launch/lib/launchWorker.js
@@ -14,7 +14,7 @@
 
 'use strict';
 
-const { CaliperUtils, ConfigUtil, Constants, MessageHandler } = require('@hyperledger/caliper-core');
+const { CaliperUtils, ConfigUtil, Constants, WorkerMessageHandler } = require('@hyperledger/caliper-core');
 const BindCommon = require('./../../lib/bindCommon');
 const logger = CaliperUtils.getLogger('cli-launch-worker');
 
@@ -79,7 +79,7 @@ class LaunchWorker {
          * @type {MessengerInterface}
          */
         const messenger = messengerFactory({});
-        const messageHandler = new MessageHandler(messenger, connectorFactory);
+        const messageHandler = new WorkerMessageHandler(messenger, connectorFactory);
 
         await messenger.initialize();
         await messenger.configureProcessInstances([process]);

diff --git a/packages/caliper-core/index.js b/packages/caliper-core/index.js
@@ -21,7 +21,7 @@ module.exports.TxStatus = require('./lib/common/core/transaction-status');
 module.exports.CaliperUtils = require('./lib/common/utils/caliper-utils');
 module.exports.Version = require('./lib/common/utils/version');
 module.exports.ConfigUtil = require('./lib/common/config/config-util');
-module.exports.MessageHandler = require('./lib/worker/message-handler');
+module.exports.WorkerMessageHandler = require('./lib/worker/worker-message-handler');
 module.exports.MessengerInterface = require('./lib/common/messengers/messenger-interface');
 module.exports.CaliperEngine = require('./lib/manager/caliper-engine');
 module.exports.MonitorOrchestrator = require('./lib/manager/orchestrators/monitor-orchestrator');

diff --git a/packages/caliper-core/lib/common/config/Config.js b/packages/caliper-core/lib/common/config/Config.js
@@ -37,13 +37,19 @@ const keys = {
             Transparency: 'caliper-report-charting-transparency'
         }
     },
+    Progress: {
+        Reporting: {
+            Enabled: 'caliper-progress-reporting-enabled',
+            Interval: 'caliper-progress-reporting-interval'
+        }
+    },
     Workspace: 'caliper-workspace',
     ProjectConfig: 'caliper-projectconfig',
     UserConfig: 'caliper-userconfig',
     MachineConfig: 'caliper-machineconfig',
     BenchConfig: 'caliper-benchconfig',
     NetworkConfig: 'caliper-networkconfig',
-    TxUpdateTime: 'caliper-txupdatetime',
+    MonitorConfig: 'caliper-monitorconfig',
     LoggingRoot: 'caliper-logging',
     Logging: {
         Template: 'caliper-logging-template',
@@ -92,7 +98,9 @@ const keys = {
             Method: 'caliper-worker-communication-method',
             Address: 'caliper-worker-communication-address',
         },
-        MaxTxPromises: 'caliper-worker-maxtxpromises'
+        Update: {
+            Interval: 'caliper-worker-update-interval'
+        }
     },
     Flow: {
         Skip: {

diff --git a/packages/caliper-core/lib/common/config/default.yaml b/packages/caliper-core/lib/common/config/default.yaml
@@ -50,8 +50,14 @@ caliper:
     benchconfig:
     # Path to the blockchain configuration file that contains information required to interact with the SUT
     networkconfig:
-    # Sets the frequency of the progress reports in milliseconds
-    txupdatetime: 5000
+    # Configurations related to caliper test progress
+    progress:
+        # Progress reports
+        reporting:
+            # Enable the reporting
+            enabled: true
+            # Report frequency
+            interval: 5000
     # Configurations related to the logging mechanism
     logging:
         # Specifies the message structure through placeholders
@@ -114,15 +120,16 @@ caliper:
     worker:
         # Indicate if workers are in distributed mode
         remote: false
-        # Polling interval to use once created, in milliseconds
-        pollinterval: 5000
         # Worker communication details
         communication:
             # Method used (process | mqtt)
             method: process
             # Address used for mqtt communications
             address: mqtt://localhost:1883
-        maxtxpromises: 100
+        # Worker update configuration
+        update:
+            # update interval for sending round statistics to the manager
+            interval: 1000
     # Caliper flow options
     flow:
         # Skip options