-
Notifications
You must be signed in to change notification settings - Fork 687
Commit
Signed-off-by: Alvaro Neira Ayuso <[email protected]>
- Loading branch information
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -64,7 +64,7 @@ var ( | |
|
||
// Controller implements the main sealed-secrets-controller loop. | ||
type Controller struct { | ||
queue workqueue.RateLimitingInterface | ||
queue workqueue.TypedRateLimitingInterface[any] | ||
ssInformer cache.SharedIndexInformer | ||
sInformer cache.SharedIndexInformer | ||
sclient v1.SecretsGetter | ||
|
@@ -78,7 +78,7 @@ type Controller struct { | |
|
||
// NewController returns the main sealed-secrets controller loop. | ||
func NewController(clientset kubernetes.Interface, ssclientset ssclientset.Interface, ssinformer ssinformer.SharedInformerFactory, sinformer informers.SharedInformerFactory, keyRegistry *KeyRegistry, maxRetriesConfig int) (*Controller, error) { | ||
queue := workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()) | ||
queue := workqueue.NewTypedRateLimitingQueue(workqueue.DefaultTypedControllerRateLimiter()) | ||
Check failure on line 81 in pkg/controller/controller.go GitHub Actions / Build Container
Check failure on line 81 in pkg/controller/controller.go GitHub Actions / Run linters (1.22.8, ubuntu-latest, 1.56.1, 2.19.0)
Check failure on line 81 in pkg/controller/controller.go GitHub Actions / Run linters (1.22.8, ubuntu-latest, 1.56.1, 2.19.0)
Check failure on line 81 in pkg/controller/controller.go GitHub Actions / Build (1.22.8, macos-latest, 1.8.1)
Check failure on line 81 in pkg/controller/controller.go GitHub Actions / Build (1.22.8, macos-latest, 1.8.1)
Check failure on line 81 in pkg/controller/controller.go GitHub Actions / Build (1.22.8, ubuntu-latest, 1.8.1)
Check failure on line 81 in pkg/controller/controller.go GitHub Actions / Build (1.22.8, ubuntu-latest, 1.8.1)
|
||
|
||
utilruntime.Must(ssscheme.AddToScheme(scheme.Scheme)) | ||
eventBroadcaster := record.NewBroadcaster() | ||
|
@@ -115,7 +115,7 @@ func NewController(clientset kubernetes.Interface, ssclientset ssclientset.Inter | |
}, nil | ||
} | ||
|
||
func watchSealedSecrets(ssinformer ssinformer.SharedInformerFactory, queue workqueue.RateLimitingInterface) (cache.SharedIndexInformer, error) { | ||
func watchSealedSecrets(ssinformer ssinformer.SharedInformerFactory, queue workqueue.TypedRateLimitingInterface[any]) (cache.SharedIndexInformer, error) { | ||
ssInformer := ssinformer.Bitnami().V1alpha1().SealedSecrets().Informer() | ||
_, err := ssInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{ | ||
AddFunc: func(obj interface{}) { | ||
|
@@ -162,7 +162,7 @@ func sealedSecretChanged(oldObj, newObj interface{}) bool { | |
return !reflect.DeepEqual(oldSealedSecret.Spec, newSealedSecret.Spec) | ||
} | ||
|
||
func watchSecrets(sinformer informers.SharedInformerFactory, ssclientset ssclientset.Interface, queue workqueue.RateLimitingInterface) (cache.SharedIndexInformer, error) { | ||
func watchSecrets(sinformer informers.SharedInformerFactory, ssclientset ssclientset.Interface, queue workqueue.TypedRateLimitingInterface[any]) (cache.SharedIndexInformer, error) { | ||
sInformer := sinformer.Core().V1().Secrets().Informer() | ||
_, err := sInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{ | ||
DeleteFunc: func(obj interface{}) { | ||
|