wip

scality · Oct 31, 2024 · 226f219 · 226f219
1 parent 6694ca8
commit 226f219
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 403 deletions.
diff --git a/lib/MetricsConsumer.js b/lib/MetricsConsumer.js
diff --git a/lib/MetricsProducer.js b/lib/MetricsProducer.js
diff --git a/lib/queuePopulator/IngestionPopulator.js b/lib/queuePopulator/IngestionPopulator.js
@@ -9,8 +9,6 @@ const Logger = require('werelogs').Logger;
 const config = require('../Config');
 const IngestionReader = require('./IngestionReader');
 const BackbeatProducer = require('../BackbeatProducer');
-const MetricsConsumer = require('../MetricsConsumer');
-const MetricsProducer = require('../MetricsProducer');
 const { metricsExtension } = require('../../extensions/ingestion/constants');
 const IngestionPopulatorMetrics = require('./IngestionPopulatorMetrics');
 const {
@@ -79,11 +77,6 @@ class IngestionPopulator {
         // shared producer across readers
         this._producer = null;
 
-        // metrics clients
-        this._mProducer = null;
-        this._mConsumer = null;
-        this._redis = null;
-
         // all ingestion readers (including paused ones)
         // i.e.: { zenko-bucket-name: IngestionReader() }
         this._ingestionSources = {};
@@ -152,17 +145,6 @@ class IngestionPopulator {
         });
     }
 
-    _setupMetricsClients(cb) {
-        // Metrics Consumer
-        this._mConsumer = new MetricsConsumer(this.rConfig, this.mConfig,
-            this.kafkaConfig, metricsExtension);
-        this._mConsumer.start();
-
-        // Metrics Producer
-        this._mProducer = new MetricsProducer(this.kafkaConfig, this.mConfig);
-        this._mProducer.setupProducer(cb);
-    }
-
     _setupProducer(cb) {
         if (this._producer) {
             return process.nextTick(cb);
@@ -580,7 +562,6 @@ class IngestionPopulator {
             logger: this.log,
             extensions: [this._extension],
             producer: this._producer,
-            metricsProducer: this._mProducer,
             qpConfig: this.qpConfig,
             s3Config: this.s3Config,
         });
@@ -662,30 +643,6 @@ class IngestionPopulator {
      */
     close(done) {
         async.series([
-            next => {
-                if (this._mProducer) {
-                    this.log.debug('closing metrics producer', {
-                        method: 'IngestionPopulator.close',
-                    });
-                    return this._mProducer.close(next);
-                }
-                this.log.debug('no metrics producer to close', {
-                    method: 'IngestionPopulator.close',
-                });
-                return next();
-            },
-            next => {
-                if (this._mConsumer) {
-                    this.log.debug('closing metrics consumer', {
-                        method: 'IngestionPopulator.close',
-                    });
-                    return this._mConsumer.close(next);
-                }
-                this.log.debug('no metrics consumer to close', {
-                    method: 'IngestionPopulator.close',
-                });
-                return next();
-            },
             next => {
                 if (this._producer) {
                     this.log.debug('closing producer', {