Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for AddPostStartHook (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top