github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-07 11:13:48 +00:00
Code Issues Projects Releases Wiki Activity

Make linter happy

Browse Source 
Signed-off-by: Dr. Stefan Schimanski <stefan.schimanski@gmail.com>
This commit is contained in:
Dr. Stefan Schimanski 2024-05-01 16:44:36 +02:00
parent 1d0c72d15a
commit 1aa24b0951
No known key found for this signature in database
GPG Key ID: 4C68E0F19F95EC33
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/controlplane/apiserver/aggregator.go
View File

@ -159,7 +159,7 @@ func CreateAggregatorServer(aggregatorConfig aggregatorapiserver.CompletedConfig
err = aggregatorServer.GenericAPIServer.AddPostStartHook("kube-apiserver-autoregistration", func(context genericapiserver.PostStartHookContext) error { err = aggregatorServer.GenericAPIServer.AddPostStartHook("kube-apiserver-autoregistration", func(context genericapiserver.PostStartHookContext) error {
if crdAPIEnabled { if crdAPIEnabled {
go crdRegistrationController.Run(5, context.StopCh) go crdRegistrationController.Run(5, context.Done())
} }
go func() { go func() {
// let the CRD controller process the initial set of CRDs before starting the autoregistration controller. // let the CRD controller process the initial set of CRDs before starting the autoregistration controller.
@ -172,7 +172,7 @@ func CreateAggregatorServer(aggregatorConfig aggregatorapiserver.CompletedConfig
} else { } else {
klog.Infof("CRD API not enabled, starting APIService registration without waiting for initial CRD sync") klog.Infof("CRD API not enabled, starting APIService registration without waiting for initial CRD sync")
} }
autoRegistrationController.Run(5, context.StopCh) autoRegistrationController.Run(5, context.Done())
}() }()
return nil return nil
}) })
@ -236,10 +236,10 @@ func makeAPIServiceAvailableHealthCheck(name string, apiServices []*v1.APIServic
} }
// Watch add/update events for APIServices // Watch add/update events for APIServices
apiServiceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ apiServiceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ //nolint:errcheck // no way to return error
AddFunc: func(obj interface{}) { handleAPIServiceChange(obj.(*v1.APIService)) }, AddFunc: func(obj interface{}) { handleAPIServiceChange(obj.(*v1.APIService)) },
UpdateFunc: func(old, new interface{}) { handleAPIServiceChange(new.(*v1.APIService)) }, UpdateFunc: func(old, new interface{}) { handleAPIServiceChange(new.(*v1.APIService)) },
}) //nolint:errcheck // no way to return error })
// Don't return healthy until the pending list is empty // Don't return healthy until the pending list is empty
return healthz.NamedCheck(name, func(r *http.Request) error { return healthz.NamedCheck(name, func(r *http.Request) error {