Move equality test in the throttle

pkg/server/configurationwatcher.go

@@ -129,12 +129,6 @@ func (c *ConfigurationWatcher) listenConfigurations(ctx context.Context) {
 func (c *ConfigurationWatcher) loadMessage(configMsg dynamic.Message) {
 	currentConfigurations := c.currentConfigurations.Get().(dynamic.Configurations)
 
-	if reflect.DeepEqual(currentConfigurations[configMsg.ProviderName], configMsg.Configuration) {
-		logger := log.WithoutContext().WithField(log.ProviderName, configMsg.ProviderName)
-		logger.Infof("Skipping same configuration for provider %s", configMsg.ProviderName)
-		return
-	}
-
 	// Copy configurations to new map so we don't change current if LoadConfig fails
 	newConfigurations := currentConfigurations.DeepCopy()
 	newConfigurations[configMsg.ProviderName] = configMsg.Configuration
@@ -210,11 +204,18 @@ func (c *ConfigurationWatcher) throttleProviderConfigReload(ctx context.Context,
 		}
 	})
 
+	var previousConfig dynamic.Message
 	for {
 		select {
 		case <-ctx.Done():
 			return
 		case nextConfig := <-in:
+			if reflect.DeepEqual(previousConfig, nextConfig) {
+				logger := log.WithoutContext().WithField(log.ProviderName, nextConfig.ProviderName)
+				logger.Info("Skipping same configuration")
+				continue
+			}
+			previousConfig = nextConfig
 			ring.In() <- nextConfig
 		}
 	}