From 1625b769879dc6f3dc307db44ddf8fadbd6e74c1 Mon Sep 17 00:00:00 2001 From: Dean Coakley Date: Mon, 28 Aug 2023 10:49:31 +0100 Subject: [PATCH] Remove trailing async config feature --- src/plugins/features.go | 14 -------------- .../nginx/agent/v2/src/plugins/features.go | 14 -------------- 2 files changed, 28 deletions(-) diff --git a/src/plugins/features.go b/src/plugins/features.go index 64b00626a..7a17686a3 100644 --- a/src/plugins/features.go +++ b/src/plugins/features.go @@ -118,20 +118,6 @@ func (f *Features) Process(msg *core.Message) { } } -func (f *Features) enableNginxConfigAsyncFeature(data string) []core.Plugin { - if !f.pipeline.IsPluginAlreadyRegistered(agent_config.FeatureNginxConfigAsync) { - conf, err := config.GetConfig(f.conf.ClientID) - if err != nil { - log.Warnf("Unable to get agent config, %v", err) - } - f.conf = conf - - nginx := NewNginx(f.commander, f.binary, f.env, f.conf) - return []core.Plugin{nginx} - } - return []core.Plugin{} -} - func (f *Features) enableMetricsFeature(data string) []core.Plugin { if !f.pipeline.IsPluginAlreadyRegistered(agent_config.FeatureMetrics) { diff --git a/test/performance/vendor/github.com/nginx/agent/v2/src/plugins/features.go b/test/performance/vendor/github.com/nginx/agent/v2/src/plugins/features.go index 64b00626a..7a17686a3 100644 --- a/test/performance/vendor/github.com/nginx/agent/v2/src/plugins/features.go +++ b/test/performance/vendor/github.com/nginx/agent/v2/src/plugins/features.go @@ -118,20 +118,6 @@ func (f *Features) Process(msg *core.Message) { } } -func (f *Features) enableNginxConfigAsyncFeature(data string) []core.Plugin { - if !f.pipeline.IsPluginAlreadyRegistered(agent_config.FeatureNginxConfigAsync) { - conf, err := config.GetConfig(f.conf.ClientID) - if err != nil { - log.Warnf("Unable to get agent config, %v", err) - } - f.conf = conf - - nginx := NewNginx(f.commander, f.binary, f.env, f.conf) - return []core.Plugin{nginx} - } - return []core.Plugin{} -} - func (f *Features) enableMetricsFeature(data string) []core.Plugin { if !f.pipeline.IsPluginAlreadyRegistered(agent_config.FeatureMetrics) {