diff --git a/comp/networkpath/npcollector/npcollectorimpl/npcollector_test.go b/comp/networkpath/npcollector/npcollectorimpl/npcollector_test.go index 871af48905868a..4a0f14e9eb92aa 100644 --- a/comp/networkpath/npcollector/npcollectorimpl/npcollector_test.go +++ b/comp/networkpath/npcollector/npcollectorimpl/npcollector_test.go @@ -302,9 +302,9 @@ func Test_newNpCollectorImpl_defaultConfigs(t *testing.T) { assert.Equal(t, true, npCollector.collectorConfigs.networkPathCollectorEnabled()) assert.Equal(t, 4, npCollector.workers) - assert.Equal(t, 100000, cap(npCollector.pathtestInputChan)) - assert.Equal(t, 100000, cap(npCollector.pathtestProcessingChan)) - assert.Equal(t, 100000, npCollector.collectorConfigs.pathtestContextsLimit) + assert.Equal(t, 1000, cap(npCollector.pathtestInputChan)) + assert.Equal(t, 1000, cap(npCollector.pathtestProcessingChan)) + assert.Equal(t, 5000, npCollector.collectorConfigs.pathtestContextsLimit) assert.Equal(t, "default", npCollector.networkDevicesNamespace) } diff --git a/pkg/config/setup/config.go b/pkg/config/setup/config.go index 2dbcd7472bd84b..28751f3a55cf98 100644 --- a/pkg/config/setup/config.go +++ b/pkg/config/setup/config.go @@ -465,9 +465,9 @@ func InitConfig(config pkgconfigmodel.Setup) { config.BindEnvAndSetDefault("network_path.collector.workers", 4) config.BindEnvAndSetDefault("network_path.collector.timeout", DefaultNetworkPathTimeout) config.BindEnvAndSetDefault("network_path.collector.max_ttl", DefaultNetworkPathMaxTTL) - config.BindEnvAndSetDefault("network_path.collector.input_chan_size", 100000) - config.BindEnvAndSetDefault("network_path.collector.processing_chan_size", 100000) - config.BindEnvAndSetDefault("network_path.collector.pathtest_contexts_limit", 100000) + config.BindEnvAndSetDefault("network_path.collector.input_chan_size", 1000) + config.BindEnvAndSetDefault("network_path.collector.processing_chan_size", 1000) + config.BindEnvAndSetDefault("network_path.collector.pathtest_contexts_limit", 5000) config.BindEnvAndSetDefault("network_path.collector.pathtest_ttl", "15m") config.BindEnvAndSetDefault("network_path.collector.pathtest_interval", "5m") config.BindEnvAndSetDefault("network_path.collector.flush_interval", "10s") diff --git a/pkg/config/setup/config_test.go b/pkg/config/setup/config_test.go index f8b6e17052872b..a5a7ce5de9fbeb 100644 --- a/pkg/config/setup/config_test.go +++ b/pkg/config/setup/config_test.go @@ -692,9 +692,9 @@ func TestNetworkPathDefaults(t *testing.T) { assert.Equal(t, 4, config.GetInt("network_path.collector.workers")) assert.Equal(t, 1000, config.GetInt("network_path.collector.timeout")) assert.Equal(t, 30, config.GetInt("network_path.collector.max_ttl")) - assert.Equal(t, 100000, config.GetInt("network_path.collector.input_chan_size")) - assert.Equal(t, 100000, config.GetInt("network_path.collector.processing_chan_size")) - assert.Equal(t, 100000, config.GetInt("network_path.collector.pathtest_contexts_limit")) + assert.Equal(t, 1000, config.GetInt("network_path.collector.input_chan_size")) + assert.Equal(t, 1000, config.GetInt("network_path.collector.processing_chan_size")) + assert.Equal(t, 5000, config.GetInt("network_path.collector.pathtest_contexts_limit")) assert.Equal(t, 15*time.Minute, config.GetDuration("network_path.collector.pathtest_ttl")) assert.Equal(t, 5*time.Minute, config.GetDuration("network_path.collector.pathtest_interval")) assert.Equal(t, 10*time.Second, config.GetDuration("network_path.collector.flush_interval"))