From 1bf9d49139c48e352b33c1cf2fbb8bed937ebc80 Mon Sep 17 00:00:00 2001 From: Adrian Fernandez de la Torre Date: Sat, 7 Mar 2026 13:11:35 +0100 Subject: [PATCH] Migrate to new Kubernetes events API Replace deprecated record.EventRecorder with events.EventRecorder from k8s.io/client-go/tools/events. Update all controllers, event server, and tests to use the new API signature. Signed-off-by: Adrian Fernandez de la Torre --- go.mod | 8 +++---- go.sum | 24 ++++++++----------- internal/controller/alert_controller.go | 6 ++--- internal/controller/provider_controller.go | 4 ++-- internal/controller/receiver_controller.go | 10 ++++---- .../controller/receiver_controller_test.go | 6 ++--- internal/controller/suite_test.go | 18 +++++++------- internal/notifier/alertmanager.go | 2 +- internal/notifier/alertmanager_fuzz_test.go | 2 +- internal/notifier/azure_devops.go | 2 +- internal/notifier/azure_devops_fuzz_test.go | 2 +- internal/notifier/azure_devops_test.go | 2 +- internal/notifier/azure_eventhub.go | 2 +- internal/notifier/bitbucket.go | 2 +- internal/notifier/bitbucket_fuzz_test.go | 2 +- internal/notifier/bitbucketserver.go | 2 +- internal/notifier/bitbucketserver_test.go | 2 +- internal/notifier/client_test.go | 2 +- internal/notifier/datadog.go | 2 +- internal/notifier/datadog_fuzz_test.go | 2 +- internal/notifier/discord.go | 2 +- internal/notifier/discord_fuzz_test.go | 2 +- internal/notifier/forwarder.go | 2 +- internal/notifier/forwarder_fuzz_test.go | 2 +- internal/notifier/forwarder_test.go | 4 ++-- .../notifier/git_change_request_comment.go | 2 +- internal/notifier/gitea.go | 2 +- .../notifier/gitea_pull_request_comment.go | 2 +- internal/notifier/gitea_test.go | 5 ++-- internal/notifier/github.go | 2 +- internal/notifier/github_dispatch.go | 2 +- .../notifier/github_dispatch_fuzz_test.go | 2 +- internal/notifier/github_fuzz_test.go | 2 +- .../notifier/github_pull_request_comment.go | 2 +- internal/notifier/gitlab.go | 2 +- internal/notifier/gitlab_fuzz_test.go | 2 +- .../notifier/gitlab_merge_request_comment.go | 2 +- internal/notifier/google_chat.go | 2 +- internal/notifier/google_chat_fuzz_test.go | 2 +- internal/notifier/google_pubsub.go | 2 +- internal/notifier/google_pubsub_test.go | 8 +++---- internal/notifier/grafana.go | 2 +- internal/notifier/grafana_fuzz_test.go | 2 +- internal/notifier/lark.go | 2 +- internal/notifier/lark_fuzz_test.go | 2 +- internal/notifier/markdown.go | 2 +- internal/notifier/matrix.go | 2 +- internal/notifier/matrix_fuzz_test.go | 2 +- internal/notifier/matrix_test.go | 4 ++-- internal/notifier/nats.go | 2 +- internal/notifier/nats_test.go | 6 ++--- internal/notifier/notifier.go | 2 +- internal/notifier/opsgenie.go | 2 +- internal/notifier/opsgenie_fuzz_test.go | 2 +- internal/notifier/opsgenie_test.go | 6 ++--- internal/notifier/otel.go | 2 +- internal/notifier/otel_test.go | 7 +++--- internal/notifier/pagerduty.go | 2 +- internal/notifier/pagerduty_fuzz_test.go | 2 +- internal/notifier/pagerduty_test.go | 2 +- internal/notifier/rocket.go | 2 +- internal/notifier/rocket_fuzz_test.go | 2 +- internal/notifier/sentry.go | 2 +- internal/notifier/sentry_test.go | 2 +- internal/notifier/slack.go | 2 +- internal/notifier/slack_fuzz_test.go | 2 +- internal/notifier/teams.go | 2 +- internal/notifier/teams_fuzz_test.go | 2 +- internal/notifier/telegram.go | 2 +- internal/notifier/util.go | 2 +- internal/notifier/util_fuzz_test.go | 2 +- internal/notifier/util_test.go | 2 +- internal/notifier/webex.go | 2 +- internal/notifier/webex_fuzz_test.go | 2 +- internal/notifier/zulip.go | 2 +- internal/notifier/zulip_test.go | 2 +- internal/server/event_handlers.go | 18 +++++++------- internal/server/event_handlers_test.go | 22 ++++++++--------- internal/server/event_server.go | 8 +++---- internal/server/event_server_test.go | 6 ++--- internal/server/provider_change_request.go | 2 +- internal/server/provider_commit_status.go | 2 +- .../server/provider_commit_status_test.go | 2 +- main.go | 22 ++++++++--------- 84 files changed, 159 insertions(+), 163 deletions(-) diff --git a/go.mod b/go.mod index e12a07164..71a6dc056 100644 --- a/go.mod +++ b/go.mod @@ -15,16 +15,16 @@ require ( github.com/cdevents/sdk-go v0.4.1 github.com/chainguard-dev/git-urls v1.0.2 github.com/elazarl/goproxy v1.8.1 - github.com/fluxcd/cli-utils v0.37.2-flux.1 + github.com/fluxcd/cli-utils v1.2.0 github.com/fluxcd/notification-controller/api v1.8.0 - github.com/fluxcd/pkg/apis/event v0.25.0 - github.com/fluxcd/pkg/apis/meta v1.26.0 + github.com/fluxcd/pkg/apis/event v0.26.0 + github.com/fluxcd/pkg/apis/meta v1.27.0 github.com/fluxcd/pkg/auth v0.40.0 github.com/fluxcd/pkg/cache v0.13.0 github.com/fluxcd/pkg/git v0.46.0 github.com/fluxcd/pkg/masktoken v0.8.0 github.com/fluxcd/pkg/runtime v0.103.0 - github.com/fluxcd/pkg/ssa v0.70.0 + github.com/fluxcd/pkg/ssa v0.74.0 github.com/fluxcd/pkg/ssh v0.24.0 github.com/getsentry/sentry-go v0.42.0 github.com/go-logr/logr v1.4.3 diff --git a/go.sum b/go.sum index e0c50bfc8..dcdeace75 100644 --- a/go.sum +++ b/go.sum @@ -133,16 +133,14 @@ github.com/fatih/color v1.16.0 h1:zmkK9Ngbjj+K0yRhTVONQh1p/HknKYSlNT+vZCzyokM= github.com/fatih/color v1.16.0/go.mod h1:fL2Sau1YI5c0pdGEVCbKQbLXB6edEj1ZgiY4NijnWvE= github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg= github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U= -github.com/fluxcd/cli-utils v0.37.2-flux.1 h1:tQ588ghtRN+E+kHq415FddfqA9v4brn/1WWgrP6rQR0= -github.com/fluxcd/cli-utils v0.37.2-flux.1/go.mod h1:LcWSu1NYET8d8U7O326RhEm5JkQXCMK6ITu4G1CT02c= -github.com/fluxcd/pkg/apis/acl v0.9.0 h1:wBpgsKT+jcyZEcM//OmZr9RiF8klL3ebrDp2u2ThsnA= -github.com/fluxcd/pkg/apis/acl v0.9.0/go.mod h1:TttNS+gocsGLwnvmgVi3/Yscwqrjc17+vhgYfqkfrV4= -github.com/fluxcd/pkg/apis/event v0.25.0 h1:zdwytvDhG+fk+Ywl5DOtv7TklkrVgM21WHm1f+YhleE= -github.com/fluxcd/pkg/apis/event v0.25.0/go.mod h1:TlK8HWYrTwl0raqBRC+ROoNpYW5fdVnwcwOBOx5Kzw8= -github.com/fluxcd/pkg/apis/kustomize v1.16.0 h1:PhWXEhqQqsisIpwp1/wHvTvo+MO+GGzsBPoN0ZnRE3Y= -github.com/fluxcd/pkg/apis/kustomize v1.16.0/go.mod h1:IZOy4CCtR/hxMGb7erK1RfbGnczVv4/dRBoVD37AywI= -github.com/fluxcd/pkg/apis/meta v1.26.0 h1:dxP1FfBpTCYso6odzRcltVnnRuBb2VyhhgV0VX9YbUE= -github.com/fluxcd/pkg/apis/meta v1.26.0/go.mod h1:c7o6mJGLCMvNrfdinGZehkrdZuFT9vZdZNrn66DtVD0= +github.com/fluxcd/cli-utils v1.2.0 h1:1o07pXTMxJ/XJ1GpAbLtjdXwfCUMq4Ku1OcnvJHLohI= +github.com/fluxcd/cli-utils v1.2.0/go.mod h1:d5HdTDdR5sCbsIbgtOQ7x7srKYwYeZORU6CD2yn4j/M= +github.com/fluxcd/pkg/apis/acl v0.10.0 h1:KPfAmELNvtvaz8wixnm/MYXqa+MJf7ntVVMUU93Aenk= +github.com/fluxcd/pkg/apis/acl v0.10.0/go.mod h1:a87i2A7AlFO5N2J8CxtzaUCCDmuLLWOHwkKu3eJF5fY= +github.com/fluxcd/pkg/apis/kustomize v1.18.0 h1:FCNjViCLyKYj6lddpnjXybKBTC2eK6eXK9YOaNwLVTM= +github.com/fluxcd/pkg/apis/kustomize v1.18.0/go.mod h1:mvtMtM4NNLipdCna6DYPC6Bd42xeaF15N+tNO+F6kxY= +github.com/fluxcd/pkg/apis/meta v1.27.0 h1:EspByEk5j8w3rs1cGbEh9AjSmpDwQIz7DFG/zzqf6uI= +github.com/fluxcd/pkg/apis/meta v1.27.0/go.mod h1:2t6JyrRfvIBhx6EBnXfFh/6sCCJ1db9WGaqko0JmNOE= github.com/fluxcd/pkg/auth v0.40.0 h1:p6Kw6KH+z8oRqngKhmTt8ILKD/rC+8tP87a//kLZhi8= github.com/fluxcd/pkg/auth v0.40.0/go.mod h1:Oq/hIEKUMTbL2bv5blf+EhC/jXXJLsOjIMtJj/AtG3Y= github.com/fluxcd/pkg/cache v0.13.0 h1:MqtlgOwIVcGKKgV422e39O+KFSVMWuExKeRaMDBjJlk= @@ -151,10 +149,8 @@ github.com/fluxcd/pkg/git v0.46.0 h1:QMh0+ZzQ2jO6rIGj4ffR5trZ8g/cxvt8cVajReJ8Iyw github.com/fluxcd/pkg/git v0.46.0/go.mod h1:iHcIjx9c8zye3PQiajTJYxgOMRiy7WCs+hfLKDswpfI= github.com/fluxcd/pkg/masktoken v0.8.0 h1:Dm5xIVNbg0s6zNttjDvimaG38bKsXwxBVo5b+D7ThVU= github.com/fluxcd/pkg/masktoken v0.8.0/go.mod h1:Gc73ALOqIe+5Gj2V3JggMNiYcBiZ9bNNDYBE9R5XTTg= -github.com/fluxcd/pkg/runtime v0.103.0 h1:J5y5GPhWdkyqIUBlaI1FP2N02TtZmsjbWhhZubuTSFk= -github.com/fluxcd/pkg/runtime v0.103.0/go.mod h1:mbo2f3azo3yVQgm7XZGxQB6/2zvzQ5Wgtd8TjRRwwAw= -github.com/fluxcd/pkg/ssa v0.70.0 h1:IBylYPiTK1IEdCC2DvjKXIhwQcbd5VufXA9WS3zO+tE= -github.com/fluxcd/pkg/ssa v0.70.0/go.mod h1:6igtlt7/zF+nNFQpa5ZAkkvtpL6o36NRU39/PqqC+Bg= +github.com/fluxcd/pkg/ssa v0.74.0 h1:a5VqQXBQ5TQlzucwZ9l37bshzR3IPK5awzfMEBF3pdM= +github.com/fluxcd/pkg/ssa v0.74.0/go.mod h1:6mdhG+O1db8oXsP7Ex3buJTexM5r9F7+LzSybBgT1f0= github.com/fluxcd/pkg/ssh v0.24.0 h1:hrPlxs0hhXf32DRqs68VbsXs0XfQMphyRVIk0rYYJa4= github.com/fluxcd/pkg/ssh v0.24.0/go.mod h1:xWammEqalrpurpcMiixJRXtynRQtBEoqheyU5F/vWrg= github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw= diff --git a/internal/controller/alert_controller.go b/internal/controller/alert_controller.go index 360dd8923..5939dbc63 100644 --- a/internal/controller/alert_controller.go +++ b/internal/controller/alert_controller.go @@ -20,7 +20,7 @@ import ( "context" corev1 "k8s.io/api/core/v1" - kuberecorder "k8s.io/client-go/tools/record" + "k8s.io/client-go/tools/events" ctrl "sigs.k8s.io/controller-runtime" "sigs.k8s.io/controller-runtime/pkg/builder" "sigs.k8s.io/controller-runtime/pkg/client" @@ -37,7 +37,7 @@ import ( // AlertReconciler reconciles an Alert object to migrate it to static Alert. type AlertReconciler struct { client.Client - kuberecorder.EventRecorder + events.AnnotatedEventRecorder ControllerName string } @@ -88,7 +88,7 @@ func (r *AlertReconciler) Reconcile(ctx context.Context, req ctrl.Request) (resu controllerutil.RemoveFinalizer(obj, apiv1.NotificationFinalizer) log.Info("removed finalizer from Alert to migrate to static Alert") - r.Event(obj, corev1.EventTypeNormal, "Migration", "removed finalizer from Alert to migrate to static Alert") + r.AnnotatedEventf(obj, nil, nil, corev1.EventTypeNormal, "Migration", "", "removed finalizer from Alert to migrate to static Alert") return } diff --git a/internal/controller/provider_controller.go b/internal/controller/provider_controller.go index 31a6b1682..4a4a8940d 100644 --- a/internal/controller/provider_controller.go +++ b/internal/controller/provider_controller.go @@ -19,7 +19,7 @@ package controller import ( "context" - kuberecorder "k8s.io/client-go/tools/record" + "k8s.io/client-go/tools/events" ctrl "sigs.k8s.io/controller-runtime" "sigs.k8s.io/controller-runtime/pkg/builder" "sigs.k8s.io/controller-runtime/pkg/client" @@ -42,7 +42,7 @@ import ( // Provider. type ProviderReconciler struct { client.Client - kuberecorder.EventRecorder + events.AnnotatedEventRecorder TokenCache *cache.TokenCache } diff --git a/internal/controller/receiver_controller.go b/internal/controller/receiver_controller.go index 67a410f27..7de4b3735 100644 --- a/internal/controller/receiver_controller.go +++ b/internal/controller/receiver_controller.go @@ -25,7 +25,7 @@ import ( apierrors "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/types" kerrors "k8s.io/apimachinery/pkg/util/errors" - kuberecorder "k8s.io/client-go/tools/record" + "k8s.io/client-go/tools/events" "k8s.io/client-go/util/workqueue" ctrl "sigs.k8s.io/controller-runtime" "sigs.k8s.io/controller-runtime/pkg/builder" @@ -50,7 +50,7 @@ import ( type ReceiverReconciler struct { client.Client helper.Metrics - kuberecorder.EventRecorder + events.AnnotatedEventRecorder ControllerName string } @@ -166,14 +166,14 @@ func (r *ReceiverReconciler) Reconcile(ctx context.Context, req ctrl.Request) (r // Emit warning event if the reconciliation failed. if retErr != nil { - r.Event(obj, corev1.EventTypeWarning, meta.FailedReason, retErr.Error()) + r.AnnotatedEventf(obj, nil, nil, corev1.EventTypeWarning, meta.FailedReason, "", retErr.Error()) } // Log and emit success event. if retErr == nil && conditions.IsReady(obj) { msg := fmt.Sprintf("Reconciliation finished, next run in %s", obj.GetInterval().String()) log.Info(msg) - r.Event(obj, corev1.EventTypeNormal, meta.SucceededReason, msg) + r.AnnotatedEventf(obj, nil, nil, corev1.EventTypeNormal, meta.SucceededReason, "", msg) } }() @@ -215,7 +215,7 @@ func (r *ReceiverReconciler) reconcile(ctx context.Context, obj *apiv1.Receiver) conditions.MarkStalled(obj, meta.InvalidCELExpressionReason, "%s", errMsg) obj.Status.ObservedGeneration = obj.Generation log.Error(err, msg) - r.Event(obj, corev1.EventTypeWarning, meta.InvalidCELExpressionReason, errMsg) + r.AnnotatedEventf(obj, nil, nil, corev1.EventTypeWarning, meta.InvalidCELExpressionReason, "", errMsg) return ctrl.Result{}, nil } } diff --git a/internal/controller/receiver_controller_test.go b/internal/controller/receiver_controller_test.go index 8d12e8bde..1d0f9aeae 100644 --- a/internal/controller/receiver_controller_test.go +++ b/internal/controller/receiver_controller_test.go @@ -31,7 +31,7 @@ import ( metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/types" - "k8s.io/client-go/tools/record" + "k8s.io/client-go/tools/events" ctrl "sigs.k8s.io/controller-runtime" "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil" @@ -74,8 +74,8 @@ func TestReceiverReconciler_deleteBeforeFinalizer(t *testing.T) { g.Expect(k8sClient.Delete(ctx, receiver)).NotTo(HaveOccurred()) r := &ReceiverReconciler{ - Client: k8sClient, - EventRecorder: record.NewFakeRecorder(32), + Client: k8sClient, + AnnotatedEventRecorder: events.NewFakeRecorder(32), } // NOTE: Only a real API server responds with an error in this scenario. _, err := r.Reconcile(ctx, ctrl.Request{NamespacedName: client.ObjectKeyFromObject(receiver)}) diff --git a/internal/controller/suite_test.go b/internal/controller/suite_test.go index 45df74d07..c495df5d7 100644 --- a/internal/controller/suite_test.go +++ b/internal/controller/suite_test.go @@ -75,25 +75,25 @@ func TestMain(m *testing.M) { testMetricsH := controller.NewMetrics(testEnv, metrics.MustMakeRecorder(), apiv1.NotificationFinalizer) if err := (&AlertReconciler{ - Client: testEnv, - ControllerName: controllerName, - EventRecorder: testEnv.GetEventRecorderFor(controllerName), + Client: testEnv, + ControllerName: controllerName, + AnnotatedEventRecorder: testEnv.GetAnnotatedEventRecorder(controllerName), }).SetupWithManager(testEnv); err != nil { panic(fmt.Sprintf("Failed to start AlertReconciler: %v", err)) } if err := (&ProviderReconciler{ - Client: testEnv, - EventRecorder: testEnv.GetEventRecorderFor(controllerName), + Client: testEnv, + AnnotatedEventRecorder: testEnv.GetAnnotatedEventRecorder(controllerName), }).SetupWithManager(testEnv); err != nil { panic(fmt.Sprintf("Failed to start ProviderReconciler: %v", err)) } if err := (&ReceiverReconciler{ - Client: testEnv, - Metrics: testMetricsH, - ControllerName: controllerName, - EventRecorder: testEnv.GetEventRecorderFor(controllerName), + Client: testEnv, + Metrics: testMetricsH, + ControllerName: controllerName, + AnnotatedEventRecorder: testEnv.GetAnnotatedEventRecorder(controllerName), }).SetupWithManager(testEnv, ReceiverReconcilerOptions{ RateLimiter: controller.GetDefaultRateLimiter(), WatchConfigsPredicate: predicate.Not(predicate.Funcs{}), diff --git a/internal/notifier/alertmanager.go b/internal/notifier/alertmanager.go index 8ac4e381b..017059c17 100644 --- a/internal/notifier/alertmanager.go +++ b/internal/notifier/alertmanager.go @@ -28,7 +28,7 @@ import ( "golang.org/x/text/cases" "golang.org/x/text/language" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type Alertmanager struct { diff --git a/internal/notifier/alertmanager_fuzz_test.go b/internal/notifier/alertmanager_fuzz_test.go index c2cfcd7c1..1795e2605 100644 --- a/internal/notifier/alertmanager_fuzz_test.go +++ b/internal/notifier/alertmanager_fuzz_test.go @@ -26,7 +26,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_AlertManager(f *testing.F) { diff --git a/internal/notifier/azure_devops.go b/internal/notifier/azure_devops.go index e99e33b97..59f5d3c29 100644 --- a/internal/notifier/azure_devops.go +++ b/internal/notifier/azure_devops.go @@ -27,7 +27,7 @@ import ( "github.com/microsoft/azure-devops-go-api/azuredevops/v6/git" "sigs.k8s.io/controller-runtime/pkg/client" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" "github.com/fluxcd/pkg/auth/azure" "github.com/fluxcd/pkg/cache" diff --git a/internal/notifier/azure_devops_fuzz_test.go b/internal/notifier/azure_devops_fuzz_test.go index 2d25d96e2..14bd0edc0 100644 --- a/internal/notifier/azure_devops_fuzz_test.go +++ b/internal/notifier/azure_devops_fuzz_test.go @@ -28,7 +28,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) const apiLocations = `{"count":0,"value":[{"area":"","id":"428dd4fb-fda5-4722-af02-9313b80305da","routeTemplate":"","resourceName":"","maxVersion":"6.0","minVersion":"5.0","releasedVersion":"6.0"}]}` diff --git a/internal/notifier/azure_devops_test.go b/internal/notifier/azure_devops_test.go index ae3c3d53c..483fa476e 100644 --- a/internal/notifier/azure_devops_test.go +++ b/internal/notifier/azure_devops_test.go @@ -21,7 +21,7 @@ import ( "testing" "time" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/microsoft/azure-devops-go-api/azuredevops/v6/git" . "github.com/onsi/gomega" corev1 "k8s.io/api/core/v1" diff --git a/internal/notifier/azure_eventhub.go b/internal/notifier/azure_eventhub.go index b23c82468..86ac32cb6 100644 --- a/internal/notifier/azure_eventhub.go +++ b/internal/notifier/azure_eventhub.go @@ -29,7 +29,7 @@ import ( "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/log" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/auth/azure" "github.com/fluxcd/pkg/cache" ) diff --git a/internal/notifier/bitbucket.go b/internal/notifier/bitbucket.go index 09fbc61ac..1ad5c937c 100644 --- a/internal/notifier/bitbucket.go +++ b/internal/notifier/bitbucket.go @@ -27,7 +27,7 @@ import ( "github.com/ktrysmt/go-bitbucket" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" ) diff --git a/internal/notifier/bitbucket_fuzz_test.go b/internal/notifier/bitbucket_fuzz_test.go index 9ccfeee79..8e4fadd3f 100644 --- a/internal/notifier/bitbucket_fuzz_test.go +++ b/internal/notifier/bitbucket_fuzz_test.go @@ -28,7 +28,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Bitbucket(f *testing.F) { diff --git a/internal/notifier/bitbucketserver.go b/internal/notifier/bitbucketserver.go index ee207eb8b..ebbdcf9e0 100644 --- a/internal/notifier/bitbucketserver.go +++ b/internal/notifier/bitbucketserver.go @@ -29,7 +29,7 @@ import ( "strings" "time" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" "github.com/hashicorp/go-retryablehttp" ) diff --git a/internal/notifier/bitbucketserver_test.go b/internal/notifier/bitbucketserver_test.go index ba386b724..cbc1d8c52 100644 --- a/internal/notifier/bitbucketserver_test.go +++ b/internal/notifier/bitbucketserver_test.go @@ -27,7 +27,7 @@ import ( "net/http" "net/http/httptest" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" . "github.com/onsi/gomega" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" diff --git a/internal/notifier/client_test.go b/internal/notifier/client_test.go index 864533e55..43006a117 100644 --- a/internal/notifier/client_test.go +++ b/internal/notifier/client_test.go @@ -29,7 +29,7 @@ import ( "testing" "time" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/hashicorp/go-retryablehttp" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" diff --git a/internal/notifier/datadog.go b/internal/notifier/datadog.go index fe55e01d5..69835584f 100644 --- a/internal/notifier/datadog.go +++ b/internal/notifier/datadog.go @@ -27,7 +27,7 @@ import ( "github.com/DataDog/datadog-api-client-go/v2/api/datadog" "github.com/DataDog/datadog-api-client-go/v2/api/datadogV1" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type DataDog struct { diff --git a/internal/notifier/datadog_fuzz_test.go b/internal/notifier/datadog_fuzz_test.go index fe74577fc..1fc6b7917 100644 --- a/internal/notifier/datadog_fuzz_test.go +++ b/internal/notifier/datadog_fuzz_test.go @@ -10,7 +10,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" . "github.com/onsi/gomega" ) diff --git a/internal/notifier/discord.go b/internal/notifier/discord.go index 932d07ec9..7fc6f6c66 100644 --- a/internal/notifier/discord.go +++ b/internal/notifier/discord.go @@ -23,7 +23,7 @@ import ( "path" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) // Discord holds the hook URL diff --git a/internal/notifier/discord_fuzz_test.go b/internal/notifier/discord_fuzz_test.go index d418a1b7d..b2fe443b3 100644 --- a/internal/notifier/discord_fuzz_test.go +++ b/internal/notifier/discord_fuzz_test.go @@ -25,7 +25,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Discord(f *testing.F) { diff --git a/internal/notifier/forwarder.go b/internal/notifier/forwarder.go index 4963a08cd..ce81c08b5 100644 --- a/internal/notifier/forwarder.go +++ b/internal/notifier/forwarder.go @@ -25,7 +25,7 @@ import ( "fmt" "net/url" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/hashicorp/go-retryablehttp" ) diff --git a/internal/notifier/forwarder_fuzz_test.go b/internal/notifier/forwarder_fuzz_test.go index 85b2e58ea..82f8c217f 100644 --- a/internal/notifier/forwarder_fuzz_test.go +++ b/internal/notifier/forwarder_fuzz_test.go @@ -26,7 +26,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Forwarder(f *testing.F) { diff --git a/internal/notifier/forwarder_test.go b/internal/notifier/forwarder_test.go index cb70a1311..21a109e96 100644 --- a/internal/notifier/forwarder_test.go +++ b/internal/notifier/forwarder_test.go @@ -28,7 +28,7 @@ import ( . "github.com/onsi/gomega" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func TestForwarder_New(t *testing.T) { @@ -89,7 +89,7 @@ func TestForwarder_Post(t *testing.T) { { name: "non-empty HMAC key adds signature header", hmacKey: []byte("7152fed34dd6149a7c75a276c510da27cb6f82b0"), - hmacHeader: "sha256=65b018549b1254e7226d1c08f9567ee45bc9de0fc4e7b1a40253f9a018b08be7", + hmacHeader: "sha256=2662a6dd1a887c05183aa5b9787d5ed92116199f09c7b3c7908ee3bd20bc60d9", xSigHeader: "should be overwritten with actual signature", }, } diff --git a/internal/notifier/git_change_request_comment.go b/internal/notifier/git_change_request_comment.go index 5b9da2703..fbd245d19 100644 --- a/internal/notifier/git_change_request_comment.go +++ b/internal/notifier/git_change_request_comment.go @@ -19,7 +19,7 @@ package notifier import ( "fmt" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) // changeRequestComment contains shared logic for change request comment providers diff --git a/internal/notifier/gitea.go b/internal/notifier/gitea.go index e41b7a593..792e652fe 100644 --- a/internal/notifier/gitea.go +++ b/internal/notifier/gitea.go @@ -23,7 +23,7 @@ import ( "os" "code.gitea.io/sdk/gitea" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" ctrl "sigs.k8s.io/controller-runtime" ) diff --git a/internal/notifier/gitea_pull_request_comment.go b/internal/notifier/gitea_pull_request_comment.go index 545abc63b..40eece7fa 100644 --- a/internal/notifier/gitea_pull_request_comment.go +++ b/internal/notifier/gitea_pull_request_comment.go @@ -25,7 +25,7 @@ import ( "code.gitea.io/sdk/gitea" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type GiteaPullRequestComment struct { diff --git a/internal/notifier/gitea_test.go b/internal/notifier/gitea_test.go index e23c5edaa..50e2b7471 100644 --- a/internal/notifier/gitea_test.go +++ b/internal/notifier/gitea_test.go @@ -21,13 +21,14 @@ import ( "crypto/tls" "crypto/x509" "fmt" - testproxy "github.com/fluxcd/notification-controller/tests/proxy" "net/http" "net/http/httptest" "testing" "time" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + testproxy "github.com/fluxcd/notification-controller/tests/proxy" + + eventv1 "github.com/fluxcd/pkg/apis/event/v1" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" diff --git a/internal/notifier/github.go b/internal/notifier/github.go index cd103dde0..4b3000aca 100644 --- a/internal/notifier/github.go +++ b/internal/notifier/github.go @@ -23,7 +23,7 @@ import ( "github.com/google/go-github/v64/github" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" ) diff --git a/internal/notifier/github_dispatch.go b/internal/notifier/github_dispatch.go index 3dfc8d54a..e7ad1375a 100644 --- a/internal/notifier/github_dispatch.go +++ b/internal/notifier/github_dispatch.go @@ -23,7 +23,7 @@ import ( "github.com/google/go-github/v64/github" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type GitHubDispatch struct { diff --git a/internal/notifier/github_dispatch_fuzz_test.go b/internal/notifier/github_dispatch_fuzz_test.go index 1100a4fb8..5070d3d2f 100644 --- a/internal/notifier/github_dispatch_fuzz_test.go +++ b/internal/notifier/github_dispatch_fuzz_test.go @@ -27,7 +27,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_GitHub_Dispatch(f *testing.F) { diff --git a/internal/notifier/github_fuzz_test.go b/internal/notifier/github_fuzz_test.go index c9728e9a1..7d98ca26a 100644 --- a/internal/notifier/github_fuzz_test.go +++ b/internal/notifier/github_fuzz_test.go @@ -27,7 +27,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_GitHub(f *testing.F) { diff --git a/internal/notifier/github_pull_request_comment.go b/internal/notifier/github_pull_request_comment.go index fdc905d5c..922117f1f 100644 --- a/internal/notifier/github_pull_request_comment.go +++ b/internal/notifier/github_pull_request_comment.go @@ -25,7 +25,7 @@ import ( "github.com/google/go-github/v64/github" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type GitHubPullRequestComment struct { diff --git a/internal/notifier/gitlab.go b/internal/notifier/gitlab.go index 625c6c47e..b3488368b 100644 --- a/internal/notifier/gitlab.go +++ b/internal/notifier/gitlab.go @@ -25,7 +25,7 @@ import ( gitlab "gitlab.com/gitlab-org/api/client-go" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" ) diff --git a/internal/notifier/gitlab_fuzz_test.go b/internal/notifier/gitlab_fuzz_test.go index 740f31b1b..33d88d61e 100644 --- a/internal/notifier/gitlab_fuzz_test.go +++ b/internal/notifier/gitlab_fuzz_test.go @@ -27,7 +27,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_GitLab(f *testing.F) { diff --git a/internal/notifier/gitlab_merge_request_comment.go b/internal/notifier/gitlab_merge_request_comment.go index 10e51b9f9..6401483bc 100644 --- a/internal/notifier/gitlab_merge_request_comment.go +++ b/internal/notifier/gitlab_merge_request_comment.go @@ -27,7 +27,7 @@ import ( gitlab "gitlab.com/gitlab-org/api/client-go" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type GitLabMergeRequestComment struct { diff --git a/internal/notifier/google_chat.go b/internal/notifier/google_chat.go index 74b33f5b4..e12695c8a 100644 --- a/internal/notifier/google_chat.go +++ b/internal/notifier/google_chat.go @@ -22,7 +22,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) // Slack holds the hook URL diff --git a/internal/notifier/google_chat_fuzz_test.go b/internal/notifier/google_chat_fuzz_test.go index 8a490c936..da4c9a770 100644 --- a/internal/notifier/google_chat_fuzz_test.go +++ b/internal/notifier/google_chat_fuzz_test.go @@ -25,7 +25,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_GoogleChat(f *testing.F) { diff --git a/internal/notifier/google_pubsub.go b/internal/notifier/google_pubsub.go index c5a493fd2..4072df15c 100644 --- a/internal/notifier/google_pubsub.go +++ b/internal/notifier/google_pubsub.go @@ -26,7 +26,7 @@ import ( kerrors "k8s.io/apimachinery/pkg/util/errors" "sigs.k8s.io/controller-runtime/pkg/log" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type ( diff --git a/internal/notifier/google_pubsub_test.go b/internal/notifier/google_pubsub_test.go index 07cfcfce5..d7873366d 100644 --- a/internal/notifier/google_pubsub_test.go +++ b/internal/notifier/google_pubsub_test.go @@ -23,7 +23,7 @@ import ( . "github.com/onsi/gomega" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func TestNewGooglePubSub(t *testing.T) { @@ -89,12 +89,12 @@ func TestGooglePubSubPost(t *testing.T) { event: eventv1.Event{ Metadata: map[string]string{"foo": "bar"}, }, - expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","metadata":{"foo":"bar"},"reportingController":""}`, + expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","action":"","metadata":{"foo":"bar"},"reportingController":""}`, publishShouldExecute: true, }, { name: "publish error is relayed", - expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","reportingController":""}`, + expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","action":"","reportingController":""}`, topicName: "projects/projectID/topics/topicID", publishErr: errors.New("publish error"), expectedErr: errors.New("publish error"), @@ -104,7 +104,7 @@ func TestGooglePubSubPost(t *testing.T) { name: "topic and attributes are relayed to the internal client", topicID: "topicID", attrs: map[string]string{"foo": "bar"}, - expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","reportingController":""}`, + expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","action":"","reportingController":""}`, publishShouldExecute: true, }, } diff --git a/internal/notifier/grafana.go b/internal/notifier/grafana.go index 279fa4876..0ff81be50 100644 --- a/internal/notifier/grafana.go +++ b/internal/notifier/grafana.go @@ -23,7 +23,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/hashicorp/go-retryablehttp" ) diff --git a/internal/notifier/grafana_fuzz_test.go b/internal/notifier/grafana_fuzz_test.go index 893b0e875..2ade94961 100644 --- a/internal/notifier/grafana_fuzz_test.go +++ b/internal/notifier/grafana_fuzz_test.go @@ -26,7 +26,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Grafana(f *testing.F) { diff --git a/internal/notifier/lark.go b/internal/notifier/lark.go index 0ba723051..df0aff3eb 100644 --- a/internal/notifier/lark.go +++ b/internal/notifier/lark.go @@ -6,7 +6,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type Lark struct { diff --git a/internal/notifier/lark_fuzz_test.go b/internal/notifier/lark_fuzz_test.go index 80937bec2..b84c6ecb6 100644 --- a/internal/notifier/lark_fuzz_test.go +++ b/internal/notifier/lark_fuzz_test.go @@ -9,7 +9,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Lark(f *testing.F) { diff --git a/internal/notifier/markdown.go b/internal/notifier/markdown.go index cb4ef6ec2..b4a2bc6c5 100644 --- a/internal/notifier/markdown.go +++ b/internal/notifier/markdown.go @@ -21,7 +21,7 @@ import ( "slices" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) // formatMarkdownPost formats the event for Markdown rendering engines. diff --git a/internal/notifier/matrix.go b/internal/notifier/matrix.go index 07eabc098..73b3bf510 100644 --- a/internal/notifier/matrix.go +++ b/internal/notifier/matrix.go @@ -10,7 +10,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/hashicorp/go-retryablehttp" ) diff --git a/internal/notifier/matrix_fuzz_test.go b/internal/notifier/matrix_fuzz_test.go index a7dac07f3..8597c8c04 100644 --- a/internal/notifier/matrix_fuzz_test.go +++ b/internal/notifier/matrix_fuzz_test.go @@ -10,7 +10,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Matrix(f *testing.F) { diff --git a/internal/notifier/matrix_test.go b/internal/notifier/matrix_test.go index 356812179..84963f62b 100644 --- a/internal/notifier/matrix_test.go +++ b/internal/notifier/matrix_test.go @@ -4,7 +4,7 @@ import ( "testing" "time" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" . "github.com/onsi/gomega" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" @@ -32,7 +32,7 @@ func TestSha1Sum(t *testing.T) { ReportingController: "", ReportingInstance: "", }, - sha1: "37d91b4f6a1e44c6a38273b0a0fd408fade7b0f5", + sha1: "b483201be9dd568ab4db38f53bc19fc82da23943", }, } diff --git a/internal/notifier/nats.go b/internal/notifier/nats.go index ad38e5a2f..ddefde567 100644 --- a/internal/notifier/nats.go +++ b/internal/notifier/nats.go @@ -22,7 +22,7 @@ import ( "errors" "fmt" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/nats-io/nats.go" "github.com/nats-io/nkeys" "sigs.k8s.io/controller-runtime/pkg/log" diff --git a/internal/notifier/nats_test.go b/internal/notifier/nats_test.go index 3ef15ebc5..6dff87ac3 100644 --- a/internal/notifier/nats_test.go +++ b/internal/notifier/nats_test.go @@ -6,7 +6,7 @@ import ( "fmt" "testing" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/nats-io/nats.go" . "github.com/onsi/gomega" ) @@ -192,13 +192,13 @@ func TestNATSPost(t *testing.T) { event: eventv1.Event{ Metadata: map[string]string{"foo": "bar"}, }, - expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","metadata":{"foo":"bar"},"reportingController":""}`, + expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","action":"","metadata":{"foo":"bar"},"reportingController":""}`, publishShouldExecute: true, }, { name: "publish error is wrapped and relayed", subject: "test", - expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","reportingController":""}`, + expectedEventPayload: `{"involvedObject":{},"severity":"","timestamp":null,"message":"","reason":"","action":"","reportingController":""}`, publishErr: errors.New("publish error"), expectedErr: fmt.Errorf("error publishing event to subject test: %w", errors.New("publish error")), publishShouldExecute: true, diff --git a/internal/notifier/notifier.go b/internal/notifier/notifier.go index 4268728ce..ce4ecf852 100644 --- a/internal/notifier/notifier.go +++ b/internal/notifier/notifier.go @@ -19,7 +19,7 @@ package notifier import ( "context" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) // OperationPost is the operation name used in cache event metrics diff --git a/internal/notifier/opsgenie.go b/internal/notifier/opsgenie.go index eae923960..8b777eed1 100644 --- a/internal/notifier/opsgenie.go +++ b/internal/notifier/opsgenie.go @@ -23,7 +23,7 @@ import ( "fmt" "net/url" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/hashicorp/go-retryablehttp" ) diff --git a/internal/notifier/opsgenie_fuzz_test.go b/internal/notifier/opsgenie_fuzz_test.go index 1f26dcae2..4862afd1d 100644 --- a/internal/notifier/opsgenie_fuzz_test.go +++ b/internal/notifier/opsgenie_fuzz_test.go @@ -26,7 +26,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_OpsGenie(f *testing.F) { diff --git a/internal/notifier/opsgenie_test.go b/internal/notifier/opsgenie_test.go index 5772db7e7..26911aac2 100644 --- a/internal/notifier/opsgenie_test.go +++ b/internal/notifier/opsgenie_test.go @@ -24,7 +24,7 @@ import ( "net/http/httptest" "testing" - "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" . "github.com/onsi/gomega" ) @@ -42,7 +42,7 @@ func TestOpsgenie_Post(t *testing.T) { tests := []struct { name string - event func() v1beta1.Event + event func() eventv1.Event }{ { name: "test event", @@ -50,7 +50,7 @@ func TestOpsgenie_Post(t *testing.T) { }, { name: "test event with empty metadata", - event: func() v1beta1.Event { + event: func() eventv1.Event { events := testEvent() events.Metadata = nil return events diff --git a/internal/notifier/otel.go b/internal/notifier/otel.go index c83dc0dc5..0cb27e0c6 100644 --- a/internal/notifier/otel.go +++ b/internal/notifier/otel.go @@ -37,7 +37,7 @@ import ( metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "sigs.k8s.io/controller-runtime/pkg/log" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" apiv1beta3 "github.com/fluxcd/notification-controller/api/v1beta3" ) diff --git a/internal/notifier/otel_test.go b/internal/notifier/otel_test.go index 9b433b490..6f50b0649 100644 --- a/internal/notifier/otel_test.go +++ b/internal/notifier/otel_test.go @@ -23,10 +23,9 @@ import ( "testing" "time" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" . "github.com/onsi/gomega" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - - "github.com/fluxcd/pkg/apis/event/v1beta1" ) func TestOTEL_Post(t *testing.T) { @@ -44,11 +43,11 @@ func TestOTEL_Post(t *testing.T) { tests := []struct { name string - event func() v1beta1.Event + event func() eventv1.Event }{ { name: "test event", - event: func() v1beta1.Event { + event: func() eventv1.Event { e := testEvent() // Mocking the data provided by alert.eventMetadata e.Metadata["cluster"] = "my-cluster" diff --git a/internal/notifier/pagerduty.go b/internal/notifier/pagerduty.go index ae4848b6a..d5156f956 100644 --- a/internal/notifier/pagerduty.go +++ b/internal/notifier/pagerduty.go @@ -25,7 +25,7 @@ import ( "github.com/PagerDuty/go-pagerduty" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" ) diff --git a/internal/notifier/pagerduty_fuzz_test.go b/internal/notifier/pagerduty_fuzz_test.go index e4aea1e1f..0b6527903 100644 --- a/internal/notifier/pagerduty_fuzz_test.go +++ b/internal/notifier/pagerduty_fuzz_test.go @@ -9,7 +9,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_PagerDuty(f *testing.F) { diff --git a/internal/notifier/pagerduty_test.go b/internal/notifier/pagerduty_test.go index 93058e4af..51ad602ee 100644 --- a/internal/notifier/pagerduty_test.go +++ b/internal/notifier/pagerduty_test.go @@ -14,7 +14,7 @@ import ( corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" ) diff --git a/internal/notifier/rocket.go b/internal/notifier/rocket.go index 08d46944e..159936bc0 100644 --- a/internal/notifier/rocket.go +++ b/internal/notifier/rocket.go @@ -23,7 +23,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) // Rocket holds the hook URL diff --git a/internal/notifier/rocket_fuzz_test.go b/internal/notifier/rocket_fuzz_test.go index 77216477c..98d732dc1 100644 --- a/internal/notifier/rocket_fuzz_test.go +++ b/internal/notifier/rocket_fuzz_test.go @@ -25,7 +25,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Rocket(f *testing.F) { diff --git a/internal/notifier/sentry.go b/internal/notifier/sentry.go index 98c935cbe..3b2a2a82e 100644 --- a/internal/notifier/sentry.go +++ b/internal/notifier/sentry.go @@ -22,7 +22,7 @@ import ( "fmt" "net/http" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/getsentry/sentry-go" ) diff --git a/internal/notifier/sentry_test.go b/internal/notifier/sentry_test.go index 89f3ae297..41e9ab920 100644 --- a/internal/notifier/sentry_test.go +++ b/internal/notifier/sentry_test.go @@ -21,7 +21,7 @@ import ( "testing" "time" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/getsentry/sentry-go" . "github.com/onsi/gomega" corev1 "k8s.io/api/core/v1" diff --git a/internal/notifier/slack.go b/internal/notifier/slack.go index 80b7185fa..77aded6f6 100644 --- a/internal/notifier/slack.go +++ b/internal/notifier/slack.go @@ -25,7 +25,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/hashicorp/go-retryablehttp" ) diff --git a/internal/notifier/slack_fuzz_test.go b/internal/notifier/slack_fuzz_test.go index b9fbf4cfb..d41f3e6bd 100644 --- a/internal/notifier/slack_fuzz_test.go +++ b/internal/notifier/slack_fuzz_test.go @@ -26,7 +26,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Slack(f *testing.F) { diff --git a/internal/notifier/teams.go b/internal/notifier/teams.go index 43ad99495..39fce1414 100644 --- a/internal/notifier/teams.go +++ b/internal/notifier/teams.go @@ -24,7 +24,7 @@ import ( "slices" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) const ( diff --git a/internal/notifier/teams_fuzz_test.go b/internal/notifier/teams_fuzz_test.go index f36e7a8be..63426b177 100644 --- a/internal/notifier/teams_fuzz_test.go +++ b/internal/notifier/teams_fuzz_test.go @@ -25,7 +25,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_MSTeams(f *testing.F) { diff --git a/internal/notifier/telegram.go b/internal/notifier/telegram.go index cad10e270..da1617565 100644 --- a/internal/notifier/telegram.go +++ b/internal/notifier/telegram.go @@ -7,7 +7,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) const ( diff --git a/internal/notifier/util.go b/internal/notifier/util.go index 74e7e873b..65708dad1 100644 --- a/internal/notifier/util.go +++ b/internal/notifier/util.go @@ -27,7 +27,7 @@ import ( "github.com/fluxcd/pkg/git" giturls "github.com/chainguard-dev/git-urls" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func parseGitAddress(s string) (string, string, error) { diff --git a/internal/notifier/util_fuzz_test.go b/internal/notifier/util_fuzz_test.go index b62f7af42..e92b1e675 100644 --- a/internal/notifier/util_fuzz_test.go +++ b/internal/notifier/util_fuzz_test.go @@ -20,7 +20,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Util_ParseGitAddress(f *testing.F) { diff --git a/internal/notifier/util_test.go b/internal/notifier/util_test.go index cfcd7a43c..51fc3da5a 100644 --- a/internal/notifier/util_test.go +++ b/internal/notifier/util_test.go @@ -22,7 +22,7 @@ import ( . "github.com/onsi/gomega" corev1 "k8s.io/api/core/v1" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func TestUtil_NameAndDescription(t *testing.T) { diff --git a/internal/notifier/webex.go b/internal/notifier/webex.go index 65dd57893..3e9a93a83 100644 --- a/internal/notifier/webex.go +++ b/internal/notifier/webex.go @@ -23,7 +23,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/hashicorp/go-retryablehttp" ) diff --git a/internal/notifier/webex_fuzz_test.go b/internal/notifier/webex_fuzz_test.go index c03df2b52..c169f8026 100644 --- a/internal/notifier/webex_fuzz_test.go +++ b/internal/notifier/webex_fuzz_test.go @@ -26,7 +26,7 @@ import ( "testing" fuzz "github.com/AdaLogics/go-fuzz-headers" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) func Fuzz_Webex(f *testing.F) { diff --git a/internal/notifier/zulip.go b/internal/notifier/zulip.go index 746e6da00..2e90566d6 100644 --- a/internal/notifier/zulip.go +++ b/internal/notifier/zulip.go @@ -23,7 +23,7 @@ import ( "net/url" "strings" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" ) type Zulip struct { diff --git a/internal/notifier/zulip_test.go b/internal/notifier/zulip_test.go index b38f2f8e4..da6e9583f 100644 --- a/internal/notifier/zulip_test.go +++ b/internal/notifier/zulip_test.go @@ -25,7 +25,7 @@ import ( . "github.com/onsi/gomega" corev1 "k8s.io/api/core/v1" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/notification-controller/internal/notifier" ) diff --git a/internal/server/event_handlers.go b/internal/server/event_handlers.go index 0b178370b..6a3e83d56 100644 --- a/internal/server/event_handlers.go +++ b/internal/server/event_handlers.go @@ -36,7 +36,7 @@ import ( "sigs.k8s.io/controller-runtime/pkg/log" "sigs.k8s.io/yaml" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/auth" "github.com/fluxcd/pkg/cache" "github.com/fluxcd/pkg/masktoken" @@ -94,7 +94,7 @@ func (s *EventServer) handleEvent() func(w http.ResponseWriter, r *http.Request) dropped, err := s.dispatchNotification(ctx, event, alert) if err != nil { alertLogger.Error(err, "failed to dispatch notification") - s.Eventf(alert, corev1.EventTypeWarning, "NotificationDispatchFailed", + s.Eventf(alert, nil, corev1.EventTypeWarning, "NotificationDispatchFailed", "", "failed to dispatch notification for %s: %s", involvedObjectString(event.InvolvedObject), err) continue } @@ -208,8 +208,8 @@ func (s *EventServer) messageIsIncluded(ctx context.Context, msg string, alert * } } else { log.FromContext(ctx).Error(err, fmt.Sprintf("failed to compile inclusion regex: %s", exp)) - s.Eventf(alert, corev1.EventTypeWarning, - "InvalidConfig", "failed to compile inclusion regex: %s", exp) + s.Eventf(alert, nil, corev1.EventTypeWarning, + "InvalidConfig", "", "failed to compile inclusion regex: %s", exp) } } return false @@ -229,7 +229,7 @@ func (s *EventServer) messageIsExcluded(ctx context.Context, msg string, alert * } } else { log.FromContext(ctx).Error(err, fmt.Sprintf("failed to compile exclusion regex: %s", exp)) - s.Eventf(alert, corev1.EventTypeWarning, "InvalidConfig", + s.Eventf(alert, nil, corev1.EventTypeWarning, "InvalidConfig", "", "failed to compile exclusion regex: %s", exp) } } @@ -263,7 +263,7 @@ func (s *EventServer) dispatchNotification(ctx context.Context, err = errors.New(maskedErrStr) } log.FromContext(ctx).Error(err, "failed to send notification") - s.Eventf(alert, corev1.EventTypeWarning, "NotificationDispatchFailed", + s.Eventf(alert, nil, corev1.EventTypeWarning, "NotificationDispatchFailed", "", "failed to send notification for %s: %s", involvedObjectString(e.InvolvedObject), err) } }(params.sender, *params.event) @@ -608,7 +608,7 @@ func (s *EventServer) eventMatchesAlertSource(ctx context.Context, event *eventv Name: event.InvolvedObject.Name, }, &obj); err != nil { logger.Error(err, "error getting the involved object") - s.Eventf(alert, corev1.EventTypeWarning, "SourceFetchFailed", + s.Eventf(alert, nil, corev1.EventTypeWarning, "SourceFetchFailed", "", "error getting source object %s", involvedObjectString(event.InvolvedObject)) return false } @@ -618,7 +618,7 @@ func (s *EventServer) eventMatchesAlertSource(ctx context.Context, event *eventv }) if err != nil { logger.Error(err, fmt.Sprintf("error using matchLabels from event source %s", crossNSObjectRefString(source))) - s.Eventf(alert, corev1.EventTypeWarning, "InvalidConfig", + s.Eventf(alert, nil, corev1.EventTypeWarning, "InvalidConfig", "", "error using matchLabels from event source %s", crossNSObjectRefString(source)) return false } @@ -705,7 +705,7 @@ func (s *EventServer) combineEventMetadata(ctx context.Context, event *eventv1.E const msg = "metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information)" slices.SortFunc(conflictingKeys, func(a, b *keyConflict) int { return strings.Compare(a.Key, b.Key) }) l.Info("warning: "+msg, "conflictingKeys", conflictingKeys) - s.AnnotatedEventf(alert, conflictEventAnnotations, corev1.EventTypeWarning, "MetadataAppendFailed", "%s", msg) + s.Eventf(alert, nil, corev1.EventTypeWarning, "MetadataAppendFailed", "", "%s", msg) } if len(metadata) > 0 { diff --git a/internal/server/event_handlers_test.go b/internal/server/event_handlers_test.go index e60071432..3a7717707 100644 --- a/internal/server/event_handlers_test.go +++ b/internal/server/event_handlers_test.go @@ -38,11 +38,11 @@ import ( corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" - "k8s.io/client-go/tools/record" + "k8s.io/client-go/tools/events" fakeclient "sigs.k8s.io/controller-runtime/pkg/client/fake" "sigs.k8s.io/controller-runtime/pkg/log" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" "github.com/fluxcd/pkg/auth" @@ -291,7 +291,7 @@ func TestFilterAlertsForEvent(t *testing.T) { eventServer := EventServer{ kubeClient: builder.Build(), logger: log.Log, - EventRecorder: record.NewFakeRecorder(32), + EventRecorder: events.NewFakeRecorder(32), } result := eventServer.filterAlertsForEvent(context.TODO(), alerts, testEvent) @@ -375,7 +375,7 @@ func TestDispatchNotification(t *testing.T) { eventServer := EventServer{ kubeClient: builder.Build(), logger: log.Log, - EventRecorder: record.NewFakeRecorder(32), + EventRecorder: events.NewFakeRecorder(32), } _, err := eventServer.dispatchNotification(context.TODO(), testEvent, alert) @@ -583,7 +583,7 @@ func TestGetNotificationParams(t *testing.T) { kubeClient: builder.Build(), logger: log.Log, noCrossNamespaceRefs: tt.noCrossNSRefs, - EventRecorder: record.NewFakeRecorder(32), + EventRecorder: events.NewFakeRecorder(32), } params, dropped, err := eventServer.getNotificationParams(context.TODO(), event, alert) @@ -1370,7 +1370,7 @@ func TestEventMatchesAlert(t *testing.T) { eventServer := EventServer{ kubeClient: builder.Build(), logger: log.Log, - EventRecorder: record.NewFakeRecorder(32), + EventRecorder: events.NewFakeRecorder(32), } alert := &apiv1beta3.Alert{ ObjectMeta: metav1.ObjectMeta{ @@ -1442,7 +1442,7 @@ func TestCombineEventMetadata(t *testing.T) { expectedMetadata: map[string]string{ "summary": "alertSummary", }, - conflictEvent: "Warning MetadataAppendFailed metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information) map[summary:involved object annotations, Alert object .spec.summary]", + conflictEvent: "Warning MetadataAppendFailed metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information)", }, "alert event metadata is overriden by summary": { event: eventv1.Event{}, @@ -1457,7 +1457,7 @@ func TestCombineEventMetadata(t *testing.T) { expectedMetadata: map[string]string{ "summary": "alertSummary", }, - conflictEvent: "Warning MetadataAppendFailed metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information) map[summary:Alert object .spec.eventMetadata, Alert object .spec.summary]", + conflictEvent: "Warning MetadataAppendFailed metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information)", }, "summary is overriden by controller metadata": { event: eventv1.Event{ @@ -1473,7 +1473,7 @@ func TestCombineEventMetadata(t *testing.T) { expectedMetadata: map[string]string{ "summary": "controllerSummary", }, - conflictEvent: "Warning MetadataAppendFailed metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information) map[summary:Alert object .spec.summary, involved object controller metadata]", + conflictEvent: "Warning MetadataAppendFailed metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information)", }, "precedence order in RFC 0008 is honered": { event: eventv1.Event{ @@ -1503,13 +1503,13 @@ func TestCombineEventMetadata(t *testing.T) { "alertMetadataOverridenByController": "controllerMetadataValue2", "controllerMetadata": "controllerMetadataValue3", }, - conflictEvent: "Warning MetadataAppendFailed metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information) map[alertMetadataOverridenByController:Alert object .spec.eventMetadata, involved object controller metadata objectMetadataOverridenByAlert:involved object annotations, Alert object .spec.eventMetadata objectMetadataOverridenByController:involved object annotations, involved object controller metadata]", + conflictEvent: "Warning MetadataAppendFailed metadata key conflicts detected (please refer to the Alert API docs and Flux RFC 0008 for more information)", }, } { t.Run(name, func(t *testing.T) { g := NewGomegaWithT(t) - eventRecorder := record.NewFakeRecorder(1) + eventRecorder := events.NewFakeRecorder(1) s := &EventServer{ logger: log.Log, EventRecorder: eventRecorder, diff --git a/internal/server/event_server.go b/internal/server/event_server.go index 18a02b3b7..7e0454101 100644 --- a/internal/server/event_server.go +++ b/internal/server/event_server.go @@ -33,11 +33,11 @@ import ( "github.com/sethvargo/go-limiter/httplimit" "github.com/slok/go-http-metrics/middleware" "github.com/slok/go-http-metrics/middleware/std" - kuberecorder "k8s.io/client-go/tools/record" + "k8s.io/client-go/tools/events" "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/log" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/cache" ) @@ -55,12 +55,12 @@ type EventServer struct { noCrossNamespaceRefs bool exportHTTPPathMetrics bool tokenCache *cache.TokenCache - kuberecorder.EventRecorder + events.EventRecorder } // NewEventServer returns an HTTP server that handles events func NewEventServer(port string, logger logr.Logger, kubeClient client.Client, - eventRecorder kuberecorder.EventRecorder, noCrossNamespaceRefs bool, + eventRecorder events.EventRecorder, noCrossNamespaceRefs bool, exportHTTPPathMetrics bool, tokenCache *cache.TokenCache) *EventServer { return &EventServer{ port: port, diff --git a/internal/server/event_server_test.go b/internal/server/event_server_test.go index 25d1e060c..c1556d60d 100644 --- a/internal/server/event_server_test.go +++ b/internal/server/event_server_test.go @@ -40,11 +40,11 @@ import ( "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/runtime" yamlutil "k8s.io/apimachinery/pkg/util/yaml" - "k8s.io/client-go/tools/record" + "k8s.io/client-go/tools/events" fakeclient "sigs.k8s.io/controller-runtime/pkg/client/fake" log "sigs.k8s.io/controller-runtime/pkg/log" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/apis/meta" apiv1 "github.com/fluxcd/notification-controller/api/v1" @@ -137,7 +137,7 @@ func TestEventServer(t *testing.T) { t.Fatalf("failed to create memory storage") } eventServer := NewEventServer("127.0.0.1:"+eventServerPort, - log.Log, kclient, record.NewFakeRecorder(32), true, true, nil) + log.Log, kclient, events.NewFakeRecorder(32), true, true, nil) stopCh := make(chan struct{}) go eventServer.ListenAndServe(stopCh, eventMdlw, store) defer close(stopCh) diff --git a/internal/server/provider_change_request.go b/internal/server/provider_change_request.go index d02fb76e7..09b2c4630 100644 --- a/internal/server/provider_change_request.go +++ b/internal/server/provider_change_request.go @@ -17,7 +17,7 @@ limitations under the License. package server import ( - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" apiv1beta3 "github.com/fluxcd/notification-controller/api/v1beta3" ) diff --git a/internal/server/provider_commit_status.go b/internal/server/provider_commit_status.go index 2b70ab184..79dbfa1f9 100644 --- a/internal/server/provider_commit_status.go +++ b/internal/server/provider_commit_status.go @@ -25,7 +25,7 @@ import ( "github.com/google/cel-go/common/types" "k8s.io/apimachinery/pkg/runtime" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" "github.com/fluxcd/pkg/runtime/cel" apiv1beta3 "github.com/fluxcd/notification-controller/api/v1beta3" diff --git a/internal/server/provider_commit_status_test.go b/internal/server/provider_commit_status_test.go index 8c2b56b84..ab3ce39f0 100644 --- a/internal/server/provider_commit_status_test.go +++ b/internal/server/provider_commit_status_test.go @@ -20,7 +20,7 @@ import ( "context" "testing" - eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1" + eventv1 "github.com/fluxcd/pkg/apis/event/v1" . "github.com/onsi/gomega" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" diff --git a/main.go b/main.go index a9a6e3176..c37a32517 100644 --- a/main.go +++ b/main.go @@ -234,28 +234,28 @@ func main() { watchConfigs := !disableConfigWatchers if err = (&controller.ProviderReconciler{ - Client: mgr.GetClient(), - EventRecorder: mgr.GetEventRecorderFor(controllerName), - TokenCache: tokenCache, + Client: mgr.GetClient(), + AnnotatedEventRecorder: mgr.GetAnnotatedEventRecorder(controllerName), + TokenCache: tokenCache, }).SetupWithManager(mgr); err != nil { setupLog.Error(err, "unable to create controller", "controller", "Provider") os.Exit(1) } if err = (&controller.AlertReconciler{ - Client: mgr.GetClient(), - ControllerName: controllerName, - EventRecorder: mgr.GetEventRecorderFor(controllerName), + Client: mgr.GetClient(), + ControllerName: controllerName, + AnnotatedEventRecorder: mgr.GetAnnotatedEventRecorder(controllerName), }).SetupWithManager(mgr); err != nil { setupLog.Error(err, "unable to create controller", "controller", "Alert") os.Exit(1) } if err = (&controller.ReceiverReconciler{ - Client: mgr.GetClient(), - ControllerName: controllerName, - Metrics: metricsH, - EventRecorder: mgr.GetEventRecorderFor(controllerName), + Client: mgr.GetClient(), + ControllerName: controllerName, + Metrics: metricsH, + AnnotatedEventRecorder: mgr.GetAnnotatedEventRecorder(controllerName), }).SetupWithManager(mgr, controller.ReceiverReconcilerOptions{ RateLimiter: runtimeCtrl.GetRateLimiter(rateLimiterOptions), WatchConfigs: watchConfigs, @@ -282,7 +282,7 @@ func main() { Registry: ctrlmetrics.Registry, }), }) - eventServer := server.NewEventServer(eventsAddr, ctrl.Log, mgr.GetClient(), mgr.GetEventRecorderFor(controllerName), aclOptions.NoCrossNamespaceRefs, exportHTTPPathMetrics, tokenCache) + eventServer := server.NewEventServer(eventsAddr, ctrl.Log, mgr.GetClient(), mgr.GetEventRecorder(controllerName), aclOptions.NoCrossNamespaceRefs, exportHTTPPathMetrics, tokenCache) go eventServer.ListenAndServe(ctx.Done(), eventMdlw, store) setupLog.Info("starting webhook receiver server", "addr", receiverAddr)