@@ -70,7 +70,6 @@ import (
7070 ssautil "github.com/fluxcd/pkg/ssa/utils"
7171 "github.com/fluxcd/pkg/tar"
7272 sourcev1 "github.com/fluxcd/source-controller/api/v1"
73- sourcev1b2 "github.com/fluxcd/source-controller/api/v1beta2"
7473
7574 kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
7675 intcache "github.com/fluxcd/kustomize-controller/internal/cache"
@@ -129,7 +128,7 @@ func (r *KustomizationReconciler) SetupWithManager(ctx context.Context, mgr ctrl
129128
130129 // Index the Kustomizations by the OCIRepository references they (may) point at.
131130 if err := mgr .GetCache ().IndexField (ctx , & kustomizev1.Kustomization {}, ociRepositoryIndexKey ,
132- r .indexBy (sourcev1b2 .OCIRepositoryKind )); err != nil {
131+ r .indexBy (sourcev1 .OCIRepositoryKind )); err != nil {
133132 return fmt .Errorf ("failed setting index fields: %w" , err )
134133 }
135134
@@ -154,7 +153,7 @@ func (r *KustomizationReconciler) SetupWithManager(ctx context.Context, mgr ctrl
154153 predicate .Or (predicate.GenerationChangedPredicate {}, predicates.ReconcileRequestedPredicate {}),
155154 )).
156155 Watches (
157- & sourcev1b2 .OCIRepository {},
156+ & sourcev1 .OCIRepository {},
158157 handler .EnqueueRequestsFromMapFunc (r .requestsForRevisionChangeOf (ociRepositoryIndexKey )),
159158 builder .WithPredicates (SourceRevisionChangePredicate {}),
160159 ).
@@ -597,8 +596,8 @@ func (r *KustomizationReconciler) getSource(ctx context.Context,
597596 }
598597
599598 switch obj .Spec .SourceRef .Kind {
600- case sourcev1b2 .OCIRepositoryKind :
601- var repository sourcev1b2 .OCIRepository
599+ case sourcev1 .OCIRepositoryKind :
600+ var repository sourcev1 .OCIRepository
602601 err := r .Client .Get (ctx , namespacedName , & repository )
603602 if err != nil {
604603 if apierrors .IsNotFound (err ) {
0 commit comments