@@ -220,7 +220,7 @@ func (c completedConfig) New(delegationTarget genericapiserver.DelegationTarget)
220
220
)
221
221
222
222
s .GenericAPIServer .AddPostStartHookOrDie ("start-apiextensions-informers" , func (context genericapiserver.PostStartHookContext ) error {
223
- s .Informers .Start (context .StopCh )
223
+ s .Informers .Start (context .Done () )
224
224
return nil
225
225
})
226
226
s .GenericAPIServer .AddPostStartHookOrDie ("start-apiextensions-controllers" , func (context genericapiserver.PostStartHookContext ) error {
@@ -231,20 +231,20 @@ func (c completedConfig) New(delegationTarget genericapiserver.DelegationTarget)
231
231
if s .GenericAPIServer .StaticOpenAPISpec != nil {
232
232
if s .GenericAPIServer .OpenAPIVersionedService != nil {
233
233
openapiController := openapicontroller .NewController (s .Informers .Apiextensions ().V1 ().CustomResourceDefinitions ())
234
- go openapiController .Run (s .GenericAPIServer .StaticOpenAPISpec , s .GenericAPIServer .OpenAPIVersionedService , context .StopCh )
234
+ go openapiController .Run (s .GenericAPIServer .StaticOpenAPISpec , s .GenericAPIServer .OpenAPIVersionedService , context .Done () )
235
235
}
236
236
237
237
if s .GenericAPIServer .OpenAPIV3VersionedService != nil {
238
238
openapiv3Controller := openapiv3controller .NewController (s .Informers .Apiextensions ().V1 ().CustomResourceDefinitions ())
239
- go openapiv3Controller .Run (s .GenericAPIServer .OpenAPIV3VersionedService , context .StopCh )
239
+ go openapiv3Controller .Run (s .GenericAPIServer .OpenAPIV3VersionedService , context .Done () )
240
240
}
241
241
}
242
242
243
- go namingController .Run (context .StopCh )
244
- go establishingController .Run (context .StopCh )
245
- go nonStructuralSchemaController .Run (5 , context .StopCh )
246
- go apiApprovalController .Run (5 , context .StopCh )
247
- go finalizingController .Run (5 , context .StopCh )
243
+ go namingController .Run (context .Done () )
244
+ go establishingController .Run (context .Done () )
245
+ go nonStructuralSchemaController .Run (5 , context .Done () )
246
+ go apiApprovalController .Run (5 , context .Done () )
247
+ go finalizingController .Run (5 , context .Done () )
248
248
249
249
discoverySyncedCh := make (chan struct {})
250
250
go discoveryController .Run (context .StopCh , discoverySyncedCh )
@@ -265,7 +265,7 @@ func (c completedConfig) New(delegationTarget genericapiserver.DelegationTarget)
265
265
return true , nil
266
266
}
267
267
return false , nil
268
- }, context .StopCh )
268
+ }, context .Done () )
269
269
})
270
270
271
271
return s , nil
0 commit comments