@@ -132,7 +132,7 @@ func (r *KustomizationReconciler) SetupWithManager(ctx context.Context, mgr ctrl
132
132
133
133
// Index the Kustomizations by the Bucket references they (may) point at.
134
134
if err := mgr .GetCache ().IndexField (ctx , & kustomizev1.Kustomization {}, bucketIndexKey ,
135
- r .indexBy (sourcev1b2 .BucketKind )); err != nil {
135
+ r .indexBy (sourcev1 .BucketKind )); err != nil {
136
136
return fmt .Errorf ("failed setting index fields: %w" , err )
137
137
}
138
138
@@ -155,7 +155,7 @@ func (r *KustomizationReconciler) SetupWithManager(ctx context.Context, mgr ctrl
155
155
builder .WithPredicates (SourceRevisionChangePredicate {}),
156
156
).
157
157
Watches (
158
- & sourcev1b2 .Bucket {},
158
+ & sourcev1 .Bucket {},
159
159
handler .EnqueueRequestsFromMapFunc (r .requestsForRevisionChangeOf (bucketIndexKey )),
160
160
builder .WithPredicates (SourceRevisionChangePredicate {}),
161
161
).
@@ -561,8 +561,8 @@ func (r *KustomizationReconciler) getSource(ctx context.Context,
561
561
return src , fmt .Errorf ("unable to get source '%s': %w" , namespacedName , err )
562
562
}
563
563
src = & repository
564
- case sourcev1b2 .BucketKind :
565
- var bucket sourcev1b2 .Bucket
564
+ case sourcev1 .BucketKind :
565
+ var bucket sourcev1 .Bucket
566
566
err := r .Client .Get (ctx , namespacedName , & bucket )
567
567
if err != nil {
568
568
if apierrors .IsNotFound (err ) {
0 commit comments