- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for AddPostStartHook (0.23 sec)
-
staging/src/k8s.io/apiserver/pkg/server/hooks.go
// for duplicate registration. originatingStack string } type preShutdownHookEntry struct { hook PreShutdownHookFunc } // AddPostStartHook allows you to add a PostStartHook. func (s *GenericAPIServer) AddPostStartHook(name string, hook PostStartHookFunc) error { if len(name) == 0 { return fmt.Errorf("missing name") } if hook == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
c.ReadyzChecks = append(c.ReadyzChecks, healthChecks...) } // AddPostStartHook allows you to add a PostStartHook that will later be added to the server itself in a New call. // Name conflicts will cause an error. func (c *Config) AddPostStartHook(name string, hook PostStartHookFunc) error { if len(name) == 0 { return fmt.Errorf("missing name") } if hook == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/admission.go
admissionPostStartHook := func(context server.PostStartHookContext) error { discoveryRESTMapper.Reset() go utilwait.Until(discoveryRESTMapper.Reset, 30*time.Second, context.StopCh) return nil } err = c.AddPostStartHook("start-apiserver-admission-initializer", admissionPostStartHook) if err != nil { return fmt.Errorf("failed to add post start hook for policy admission: %w", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 12 08:49:42 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/controlplane/apiserver/aggregator.go
aggregatorConfig.GenericConfig.AggregatedDiscoveryGroupManager.SetGroupVersionPriority(metav1.GroupVersion(gv), int(entry.Group), int(entry.Version)) } } err = aggregatorServer.GenericAPIServer.AddPostStartHook("kube-apiserver-autoregistration", func(context genericapiserver.PostStartHookContext) error { if crdAPIEnabled { go crdRegistrationController.Run(5, context.Done()) } go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 18:08:20 UTC 2024 - 15.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
// add post start hook to start hot reload controller // adding this hook here will ensure that it gets configured exactly once err = c.AddPostStartHook( "start-encryption-provider-config-automatic-reload", func(_ server.PostStartHookContext) error { dynamicEncryptionConfigController := encryptionconfigcontroller.NewDynamicEncryptionConfiguration(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0)