chore: update version to 2.9-2024.2.19-7f1e9b76a

VERSION

@@ -1 +1 @@
-2.9-2024.2.19-5d3b6792c
+2.9-2024.2.19-7f1e9b76a

changelog/CHANGELOG-2.9-2024.2.19-7f1e9b76a.md

@@ -0,0 +1,2 @@
+### Features
+- fix: revert 2.9-2024.2.4-fc84c8a9c due to cmp issue

cmd/event-reporter-server/commands/event_reporter_server.go

@@ -3,7 +3,6 @@ package commands
 import (
 	"context"
 	"fmt"
-	"github.com/argoproj/argo-cd/v2/event_reporter/reporter"
 	"math"
 	"time"
 
@@ -177,11 +176,6 @@ func NewCommand() *cobra.Command {
 					BaseURL:   codefreshUrl,
 					AuthToken: codefreshToken,
 				},
-				RateLimiterOpts: &reporter.RateLimiterOpts{
-					Enabled:  rateLimiterEnabled,
-					Rate:     rateLimiterDuration,
-					Capacity: rateLimiterBucketSize,
-				},
 			}
 
 			log.Infof("Starting event reporter server with grpc transport %v", useGrpc)

event_reporter/controller/controller.go

@@ -41,8 +41,8 @@ type eventReporterController struct {
 	metricsServer            *metrics.MetricsServer
 }
 
-func NewEventReporterController(appInformer cache.SharedIndexInformer, cache *servercache.Cache, settingsMgr *settings.SettingsManager, applicationServiceClient appclient.ApplicationClient, appLister applisters.ApplicationLister, codefreshConfig *codefresh.CodefreshConfig, metricsServer *metrics.MetricsServer, featureManager *reporter.FeatureManager, rateLimiterOpts *reporter.RateLimiterOpts) EventReporterController {
-	appBroadcaster := reporter.NewBroadcaster(featureManager, metricsServer, rateLimiterOpts)
+func NewEventReporterController(appInformer cache.SharedIndexInformer, cache *servercache.Cache, settingsMgr *settings.SettingsManager, applicationServiceClient appclient.ApplicationClient, appLister applisters.ApplicationLister, codefreshConfig *codefresh.CodefreshConfig, metricsServer *metrics.MetricsServer, featureManager *reporter.FeatureManager) EventReporterController {
+	appBroadcaster := reporter.NewBroadcaster(featureManager, metricsServer)
 	appInformer.AddEventHandler(appBroadcaster)
 	return &eventReporterController{
 		appBroadcaster:           appBroadcaster,

event_reporter/reporter/broadcaster.go

@@ -40,17 +40,15 @@ type broadcasterHandler struct {
 	filter         sharding.ApplicationFilterFunction
 	featureManager *FeatureManager
 	metricsServer  *metrics.MetricsServer
-	rateLimiter    *RateLimiter
 }
 
-func NewBroadcaster(featureManager *FeatureManager, metricsServer *metrics.MetricsServer, rateLimiterOpts *RateLimiterOpts) Broadcaster {
+func NewBroadcaster(featureManager *FeatureManager, metricsServer *metrics.MetricsServer) Broadcaster {
 	// todo: pass real value here
 	filter := getApplicationFilter("")
 	return &broadcasterHandler{
 		filter:         filter,
 		featureManager: featureManager,
 		metricsServer:  metricsServer,
-		rateLimiter:    NewRateLimiter(rateLimiterOpts),
 	}
 }
 
@@ -78,13 +76,6 @@ func (b *broadcasterHandler) notify(event *appv1.ApplicationWatchEvent) {
 	for _, s := range subscribers {
 		if s.matches(event) {
 
-			duration, err := b.rateLimiter.Limit(event.Application.Name)
-			if err != nil {
-				log.Infof("adding application '%s' to channel failed, due to rate limit, duration left %s", event.Application.Name, duration.String())
-				b.metricsServer.IncAppEventsCounter(event.Application.Name, false)
-				continue
-			}
-
 			select {
 			case s.ch <- event:
 				{

event_reporter/server.go

@@ -93,7 +93,6 @@ type EventReporterServerOpts struct {
 	BaseHRef                 string
 	RootPath                 string
 	CodefreshConfig          *codefresh.CodefreshConfig
-	RateLimiterOpts          *reporter.RateLimiterOpts
 }
 
 type handlerSwitcher struct {
@@ -153,7 +152,7 @@ func (a *EventReporterServer) Init(ctx context.Context) {
 }
 
 func (a *EventReporterServer) RunController(ctx context.Context) {
-	controller := event_reporter.NewEventReporterController(a.appInformer, a.Cache, a.settingsMgr, a.ApplicationServiceClient, a.appLister, a.CodefreshConfig, a.serviceSet.MetricsServer, a.featureManager, a.RateLimiterOpts)
+	controller := event_reporter.NewEventReporterController(a.appInformer, a.Cache, a.settingsMgr, a.ApplicationServiceClient, a.appLister, a.CodefreshConfig, a.serviceSet.MetricsServer, a.featureManager)
 	go controller.Run(ctx)
 }