Rename metric to avoid unnecessary name

- also fix a comment Issue: BB-601
scality · Sep 19, 2024 · 7396ddc · 7396ddc
1 parent ccd7d42
commit 7396ddc
Show file tree

Hide file tree

Showing 6 changed files with 7 additions and 6 deletions.
diff --git a/extensions/oplogPopulator/OplogPopulator.js b/extensions/oplogPopulator/OplogPopulator.js
@@ -291,7 +291,7 @@ class OplogPopulator {
                 this._allocationStrategy.onConnectorUpdatedOrDestroyed(connector));
             this._allocator.on(constants.bucketRemovedFromConnectorEvent, (bucket, connector) =>
                 this._allocationStrategy.onBucketRemoved(bucket, connector));
-            this._connectorsManager.on('connectors-reconciled', bucketsExceedingLimit => {
+            this._connectorsManager.on(constants.connectorsReconciledEvent, bucketsExceedingLimit => {
                 this._metricsHandler.onConnectorsReconciled(
                     bucketsExceedingLimit,
                     this._allocationStrategy.retainedBucketsCount,

diff --git a/extensions/oplogPopulator/OplogPopulatorMetrics.js b/extensions/oplogPopulator/OplogPopulatorMetrics.js
@@ -34,11 +34,11 @@ class OplogPopulatorMetrics {
             labelNames: ['connector'],
         });
         this.bucketsExceedingLimit = ZenkoMetrics.createGauge({
-            name: 's3_oplog_populator_connector_buckets_exceeding_limit',
+            name: 's3_oplog_populator_buckets_exceeding_limit',
             help: 'Total number of buckets exceeding the limit for all connectors',
         });
         this.retainedBuckets = ZenkoMetrics.createGauge({
-            name: 's3_oplog_populator_connector_retained_buckets',
+            name: 's3_oplog_populator_retained_buckets',
             help: 'Current number of buckets still listened to by immutable connectors despite intended removal',
         });
         this.requestSize = ZenkoMetrics.createCounter({

diff --git a/extensions/oplogPopulator/allocationStrategy/RetainBucketsDecorator.js b/extensions/oplogPopulator/allocationStrategy/RetainBucketsDecorator.js
@@ -18,7 +18,7 @@ class RetainBucketsDecorator extends AllocationStrategy {
         super(params);
         this._strategy = strategy;
 
-        // Stores buckets that should are removed from the connector
+        // Stores buckets that should be removed from the connector
         // but still in use
         this._retainedBuckets = new Map();
     }

diff --git a/extensions/oplogPopulator/constants.js b/extensions/oplogPopulator/constants.js
@@ -8,6 +8,7 @@ const constants = {
     mongodbVersionWithImmutablePipelines: '6.0.0',
     connectorUpdatedEvent: 'connector-updated',
     bucketRemovedFromConnectorEvent: 'bucket-removed',
+    connectorsReconciledEvent: 'connectors-reconciled',
     defaultConnectorConfig: {
         'connector.class': 'com.mongodb.kafka.connect.MongoSourceConnector',
         'pipeline': '[]',

diff --git a/extensions/oplogPopulator/modules/ConnectorsManager.js b/extensions/oplogPopulator/modules/ConnectorsManager.js
@@ -317,7 +317,7 @@ class ConnectorsManager extends EventEmitter {
                 });
             }
         });
-        this.emit('connectors-reconciled', bucketsExceedingLimit);
+        this.emit(constants.connectorsReconciledEvent, bucketsExceedingLimit);
         if (Object.keys(connectorsStatus).length > 0) {
             this._logger.info('Successfully updated connectors', {
                 method: 'ConnectorsManager._updateConnectors',

diff --git a/tests/unit/oplogPopulator/oplogPopulator.js b/tests/unit/oplogPopulator/oplogPopulator.js
@@ -240,7 +240,7 @@ describe('OplogPopulator', () => {
             assert(setMetastoreChangeStreamStub.calledOnce);
             assert(initializeConnectorsManagerStub.calledOnce);
             const onConnectorsReconciledStub = sinon.stub(oplogPopulator._metricsHandler, 'onConnectorsReconciled');
-            oplogPopulator._connectorsManager.emit('connectors-reconciled');
+            oplogPopulator._connectorsManager.emit(constants.connectorsReconciledEvent);
             assert(onConnectorsReconciledStub.calledOnce);
         });
     });